Merge pull request apache#29643 [yaml] Append rather than replace yam…

…l label.
Polber · Dec 6, 2023 · f710795 · f710795
2 parents 3d8bb4a + cdbd778
commit f710795
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/sdks/python/apache_beam/yaml/yaml_transform.py b/sdks/python/apache_beam/yaml/yaml_transform.py
@@ -962,7 +962,9 @@ def expand(self, pcolls):
     python_provider = yaml_provider.InlineProvider({})
 
     options = pipeline.options.view_as(GoogleCloudOptions)
-    options.labels = ["yaml=true"]
+    if not options.labels:
+      options.labels = []
+    options.labels += ["yaml=true"]
 
     result = expand_transform(
         self._spec,