tvalentyn commented on code in PR #35660:
URL: https://github.com/apache/beam/pull/35660#discussion_r2231143799
##########
sdks/python/apache_beam/transforms/ptransform.py:
##########
@@ -1030,11 +1031,30 @@ def expand(self, pcoll):
pass
return self._fn(pcoll, *args, **kwargs)
- def default_label(self):
+ def set_options(self, options):
+ # Avoid circular import.
+ from apache_beam.transforms.util import is_compat_version_prior_to
+ self._use_backwards_compatible_label = is_compat_version_prior_to(
+ options, '2.68.0')
+
+ def default_label(self) -> str:
Review Comment:
could you add a test for this logic please?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
