From bde023332be013c37bf3a985ee9866cec0c54b2d Mon Sep 17 00:00:00 2001 From: revi cheng Date: Wed, 1 Nov 2023 09:50:13 -0700 Subject: [PATCH] remove sleeps --- .../test_schema_evolution_w_auto_table_creation_avro_sr.py | 1 - .../test_schema_evolution_w_auto_table_creation_json.py | 2 -- test/test_suit/test_schema_evolution_w_random_row_count.py | 2 -- 3 files changed, 5 deletions(-) diff --git a/test/test_suit/test_schema_evolution_w_auto_table_creation_avro_sr.py b/test/test_suit/test_schema_evolution_w_auto_table_creation_avro_sr.py index 91317160d..81257b63c 100644 --- a/test/test_suit/test_schema_evolution_w_auto_table_creation_avro_sr.py +++ b/test/test_suit/test_schema_evolution_w_auto_table_creation_avro_sr.py @@ -1,6 +1,5 @@ from confluent_kafka import avro from test_suit.test_utils import NonRetryableError -from time import sleep # test if the table is updated with the correct column diff --git a/test/test_suit/test_schema_evolution_w_auto_table_creation_json.py b/test/test_suit/test_schema_evolution_w_auto_table_creation_json.py index e5d3a7157..103279ea6 100644 --- a/test/test_suit/test_schema_evolution_w_auto_table_creation_json.py +++ b/test/test_suit/test_schema_evolution_w_auto_table_creation_json.py @@ -1,7 +1,6 @@ import json from test_suit.test_utils import NonRetryableError -from time import sleep # test if the table is updated with the correct column @@ -70,7 +69,6 @@ def send(self): self.driver.sendBytesData(topic, value, key) def verify(self, round): - sleep(60) rows = self.driver.snowflake_conn.cursor().execute( "desc table {}".format(self.table)).fetchall() res_col = {} diff --git a/test/test_suit/test_schema_evolution_w_random_row_count.py b/test/test_suit/test_schema_evolution_w_random_row_count.py index b2dd6b01f..fbd26b977 100644 --- a/test/test_suit/test_schema_evolution_w_random_row_count.py +++ b/test/test_suit/test_schema_evolution_w_random_row_count.py @@ -2,7 +2,6 @@ import random from test_suit.test_utils import NonRetryableError -from time import sleep # test if the ingestion works when the schematization alter table invalidation happens @@ -71,7 +70,6 @@ def send(self): self.driver.sendBytesData(topic, value, key) def verify(self, round): - sleep(60) rows = self.driver.snowflake_conn.cursor().execute( "desc table {}".format(self.table)).fetchall() res_col = {}