This is an automated email from the ASF dual-hosted git repository.
jrmccluskey pushed a commit to branch release-2.47.0
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/release-2.47.0 by this push:
new a5bae0dd1d3 Bump streaming test timeouts (#26489) (#26499)
a5bae0dd1d3 is described below
commit a5bae0dd1d3dbabcde5d26d161266d9f0e688978
Author: Jack McCluskey <[email protected]>
AuthorDate: Tue May 2 11:40:45 2023 -0400
Bump streaming test timeouts (#26489) (#26499)
* Bump streaming WC test timeout
* Bump metrics test timeout
---
sdks/python/apache_beam/examples/streaming_wordcount_it_test.py | 2 +-
.../dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py
b/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py
index 8c70594ddea..3a2938e20cd 100644
--- a/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py
+++ b/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py
@@ -53,7 +53,7 @@ INPUT_SUB = 'wc_subscription_input'
OUTPUT_SUB = 'wc_subscription_output'
DEFAULT_INPUT_NUMBERS = 500
-WAIT_UNTIL_FINISH_DURATION = 6 * 60 * 1000 # in milliseconds
+WAIT_UNTIL_FINISH_DURATION = 10 * 60 * 1000 # in milliseconds
class StreamingWordCountIT(unittest.TestCase):
diff --git
a/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py
b/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py
index f79e79e7e60..768096512d5 100644
---
a/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py
+++
b/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py
@@ -54,7 +54,7 @@ INPUT_SUB = 'exercise_streaming_metrics_subscription_input'
OUTPUT_TOPIC = 'exercise_streaming_metrics_topic_output'
OUTPUT_SUB = 'exercise_streaming_metrics_subscription_output'
-WAIT_UNTIL_FINISH_DURATION = 1 * 60 * 1000 # in milliseconds
+WAIT_UNTIL_FINISH_DURATION = 5 * 60 * 1000 # in milliseconds
MESSAGES_TO_PUBLISH = ["message a", "message b b", "message c"]
SLEEP_TIME_SECS = 1
