Merge a937ce0 into a6eb07c

Author: iddqdex

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