Skip to content

Commit 4959d3e

Browse files
authored
Delete records with l_suppkey = 9999 before running (#13389)
1 parent 0913a5c commit 4959d3e

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

ydb/tests/sql/large/test_insert_delete_duplicate_records.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -183,6 +183,12 @@ def read_data():
183183
while not all(f.done() for f in insert_futures):
184184
check_data()
185185

186+
# Delete all records with l_suppkey = 9999
187+
delete_query = f"""
188+
DELETE FROM `{lineitem_table}` WHERE l_suppkey = 9999;
189+
"""
190+
self.query(delete_query)
191+
186192
# Use ThreadPoolExecutor to manage threads
187193
with concurrent.futures.ThreadPoolExecutor(max_workers=num_threads+1) as executor:
188194
# Start insert and delete operations

0 commit comments

Comments
 (0)