copy over annotations

apache · Nov 16, 2024 · 0056841 · 0056841
1 parent 4a12d93
commit 0056841
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/sdks/python/apache_beam/transforms/external.py b/sdks/python/apache_beam/transforms/external.py
@@ -923,6 +923,7 @@ def _normalize(coder_proto):
             for tag,
             pcoll in self._expanded_transform.outputs.items()
         },
+        annotations=self._expanded_transform.annotations,
         environment_id=self._expanded_transform.environment_id)