robertwb commented on code in PR #35660:
URL: https://github.com/apache/beam/pull/35660#discussion_r2231501217
##########
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:
Good point, it has gotten to the point that it deserves some tests. Done.
--
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: github-unsubscr...@beam.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
