shunping commented on code in PR #34612:
URL: https://github.com/apache/beam/pull/34612#discussion_r2205100528
##########
sdks/python/apache_beam/transforms/util_test.py:
##########
@@ -254,8 +254,8 @@ def test_constant_batch_no_metrics(self):
self.assertEqual(len(results["distributions"]), 0)
def test_grows_to_max_batch(self):
- # Assumes a single bundle...
- with TestPipeline() as p:
+ # Assumes a single bundle, so we pin to the FnApiRunner
Review Comment:
Do we have a reliable way of getting elements in a single bundle? Maybe only
for testing purpose. This seems to be a recurrent issue I met when I am working
on some other tests.
Alternatively, we may be able to change the tests so that they won't rely on
this assumption, but it is not working all the time.
--
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]
