Abacn commented on code in PR #39467:
URL: https://github.com/apache/beam/pull/39467#discussion_r3678650766
##########
sdks/python/apache_beam/io/external/xlang_jmsio_it_test.py:
##########
@@ -227,9 +248,136 @@ def test_xlang_jms_write_read_queue(self):
self._run_streaming_test(
source_queue='xlang-jms-source',
sink_queue='xlang-jms-sink',
+ acknowledge_mode='CLIENT_ACKNOWLEDGE_UNSAFE',
connection_param='jms.prefetchPolicy.all=0')
+class IbmMqJmsIOTest(_BaseJmsIOTest):
Review Comment:
IBM MQ test seems flakier than others:
https://github.com/apache/beam/actions/runs/30409437929
https://github.com/apache/beam/actions/runs/30421527691
Currently single GHA workflow runs both Python 3.10 and 3.14 tests in
parallel, and each involves test containers that came with overhead. It may
spin up multiple container at the same time. We may consider only run messaging
xlang IO postcommit on one Python version only as it's sufficient for the
coverage.
--
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]
