diff --git a/ingestion/tests/cli_e2e/base/test_cli_db.py b/ingestion/tests/cli_e2e/base/test_cli_db.py index 7f30426f00c..c3afd497d44 100644 --- a/ingestion/tests/cli_e2e/base/test_cli_db.py +++ b/ingestion/tests/cli_e2e/base/test_cli_db.py @@ -225,9 +225,8 @@ class CliDBBase(TestCase): ) self.delete_table_rows() self.update_table_row() - # Add 120 second delay for system - # tables to register the change - time.sleep(120) + # Add 5min delay for system tables to register the change + time.sleep(5 * 60) result = self.run_command("profile") sink_status, source_status = self.retrieve_statuses(result) self.assert_for_system_metrics(source_status, sink_status) diff --git a/ingestion/tests/cli_e2e/test_cli_snowflake.py b/ingestion/tests/cli_e2e/test_cli_snowflake.py index acdb19bb7f0..87fe73818e2 100644 --- a/ingestion/tests/cli_e2e/test_cli_snowflake.py +++ b/ingestion/tests/cli_e2e/test_cli_snowflake.py @@ -142,9 +142,8 @@ class SnowflakeCliTest(CliCommonDB.TestSuite, SQACommonMethods): ) self.delete_table_rows() self.update_table_row() - # Add 120 second delay for system - # tables to register the change - time.sleep(120) + # Add 5min delay for system tables to register the change + time.sleep(5 * 60) result = self.run_command("profile") sink_status, source_status = self.retrieve_statuses(result) self.assert_for_system_metrics(source_status, sink_status)