From 3f319bdb224b91b72c3731341ccf4e670d785bd1 Mon Sep 17 00:00:00 2001 From: Oleksii Moskalenko Date: Fri, 15 Jan 2021 14:04:20 +0800 Subject: [PATCH] increase js control loop waiting time Signed-off-by: Oleksii Moskalenko --- tests/e2e/test_online_features.py | 2 +- tests/e2e/test_validation.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/e2e/test_online_features.py b/tests/e2e/test_online_features.py index e038936da88..6c2df4391a1 100644 --- a/tests/e2e/test_online_features.py +++ b/tests/e2e/test_online_features.py @@ -134,7 +134,7 @@ def test_streaming_ingestion( job = None wait_retry_backoff( - lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 120 + lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 300 ) test_data = generate_data()[["s2id", "unique_drivers", "event_timestamp"]] diff --git a/tests/e2e/test_validation.py b/tests/e2e/test_validation.py index 276d1126f6b..dcb7ac8a1eb 100644 --- a/tests/e2e/test_validation.py +++ b/tests/e2e/test_validation.py @@ -103,7 +103,7 @@ def test_validation_with_ge(feast_client: Client, kafka_server, pytestconfig): job = start_job(feast_client, feature_table, pytestconfig) wait_retry_backoff( - lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 120 + lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 300 ) test_data = generate_test_data() @@ -170,7 +170,7 @@ def test_validation_reports_metrics( job = start_job(feast_client, feature_table, pytestconfig) wait_retry_backoff( - lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 120 + lambda: (None, check_consumer_exist(kafka_broker, topic_name)), 300 ) test_data = generate_test_data()