From 00568413619dd2232c2c7fd71d278a70f0618e0a Mon Sep 17 00:00:00 2001 From: Ahmed Abualsaud Date: Fri, 15 Nov 2024 21:17:11 -0500 Subject: [PATCH] copy over annotations --- sdks/python/apache_beam/transforms/external.py | 1 + 1 file changed, 1 insertion(+) diff --git a/sdks/python/apache_beam/transforms/external.py b/sdks/python/apache_beam/transforms/external.py index 83c439ca8ddd..cdf5d874d7fa 100644 --- 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)