Skip to content

Commit a58932d

Browse files
authored
Add reties to send results (#6686)
1 parent 290adff commit a58932d

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

ydb/tests/olap/lib/results_processor.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,8 +15,10 @@ def __init__(self, ep: str, db: str, table: str, key: str, iam_file: str) -> Non
1515
self._table = table
1616

1717
def send_data(self, data):
18-
self._driver.table_client.bulk_upsert(
19-
os.path.join(self._db, self._table), [data], ResultsProcessor._columns_types
18+
ydb.retry_operation_sync(
19+
lambda: self._driver.table_client.bulk_upsert(
20+
os.path.join(self._db, self._table), [data], ResultsProcessor._columns_types
21+
)
2022
)
2123

2224
_endpoints : list[ResultsProcessor.Endpoint] = None

0 commit comments

Comments
 (0)