diff --git a/ydb/tests/olap/lib/results_processor.py b/ydb/tests/olap/lib/results_processor.py
index 3a2d3fcaa1bd..bec253ff303e 100644
--- a/ydb/tests/olap/lib/results_processor.py
+++ b/ydb/tests/olap/lib/results_processor.py
@@ -15,8 +15,10 @@ def __init__(self, ep: str, db: str, table: str, key: str, iam_file: str) -> Non
             self._table = table
 
         def send_data(self, data):
-            self._driver.table_client.bulk_upsert(
-                os.path.join(self._db, self._table), [data], ResultsProcessor._columns_types
+            ydb.retry_operation_sync(
+                lambda: self._driver.table_client.bulk_upsert(
+                    os.path.join(self._db, self._table), [data], ResultsProcessor._columns_types
+                )
             )
 
     _endpoints : list[ResultsProcessor.Endpoint] = None