charlespnh commented on code in PR #35882:
URL: https://github.com/apache/beam/pull/35882#discussion_r2279891711
##########
sdks/python/apache_beam/yaml/yaml_testing_test.py:
##########
@@ -225,6 +224,97 @@ def test_create(self):
self.assertGreaterEqual(len(test_spec['expected_inputs'][0]['elements']),
5)
yaml_testing.run_test(pipeline, test_spec)
+ def test_join_transform_serialization(self):
+ """Test that Join transforms work with YAML testing framework and
cloudpickle.
+
+ This test validates the fix for the grpc channel serialization issue
+ that was causing TypeError: no default __reduce__ due to non-trivial
__cinit__
+ when using Join transforms with the YAML testing framework.
+ """
+ join_pipeline = '''
+pipeline:
Review Comment:
nit: tab to align within the function body
--
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
