This is an automated email from the ASF dual-hosted git repository.
jrmccluskey pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 73b9b092e36 Bump streaming test timeouts (#26489)
73b9b092e36 is described below
commit 73b9b092e3679e45c5258dd96e8dd1a9519bb3a1
Author: Jack McCluskey <[email protected]>
AuthorDate: Tue May 2 09:37:26 2023 -0400
Bump streaming test timeouts (#26489)
* 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
