From 7315ecc54ddf451842f3f2b514c39e2b440b51d2 Mon Sep 17 00:00:00 2001
From: Alexander Avdonkin <aavdonkin@yandex.ru>
Date: Wed, 15 Jan 2025 14:49:25 +0300
Subject: [PATCH] Delete records with l_suppkey = 9999 before running

---
 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