From 4959d3ed8fecbd18c9b9f26e43373d3f384f66a5 Mon Sep 17 00:00:00 2001 From: Alexander Avdonkin Date: Wed, 15 Jan 2025 15:05:00 +0300 Subject: [PATCH] Delete records with l_suppkey = 9999 before running (#13389) --- ydb/tests/sql/large/test_insert_delete_duplicate_records.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/ydb/tests/sql/large/test_insert_delete_duplicate_records.py b/ydb/tests/sql/large/test_insert_delete_duplicate_records.py index be52cbe3439a..e0eeb689694b 100644 --- a/ydb/tests/sql/large/test_insert_delete_duplicate_records.py +++ b/ydb/tests/sql/large/test_insert_delete_duplicate_records.py @@ -183,6 +183,12 @@ def read_data(): while not all(f.done() for f in insert_futures): check_data() + # Delete all records with l_suppkey = 9999 + delete_query = f""" + DELETE FROM `{lineitem_table}` WHERE l_suppkey = 9999; + """ + self.query(delete_query) + # Use ThreadPoolExecutor to manage threads with concurrent.futures.ThreadPoolExecutor(max_workers=num_threads+1) as executor: # Start insert and delete operations