add retry locks to execute_str

iterative · Aug 21, 2024 · 99c21f8 · 99c21f8
1 parent 77947c8
commit 99c21f8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/datachain/data_storage/sqlite.py b/src/datachain/data_storage/sqlite.py
@@ -209,6 +209,7 @@ def executemany(
             return cursor.executemany(self.compile(query).string, params)
         return self.db.executemany(self.compile(query).string, params)
 
+    @retry_sqlite_locks
     def execute_str(self, sql: str, parameters=None) -> sqlite3.Cursor:
         if parameters is None:
             return self.db.execute(sql)