fix(db): revert use_new_connection=True

iterative · Jan 9, 2025 · 12da0c9 · 12da0c9
1 parent 5b15006
commit 12da0c9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/datachain/data_storage/warehouse.py b/src/datachain/data_storage/warehouse.py
@@ -219,7 +219,7 @@ def dataset_select_paginated(
         num_yielded = 0
 
         # Ensure we're using a thread-local connection
-        with self.clone(use_new_connection=True) as wh:
+        with self.clone() as wh:
             while True:
                 if limit is not None:
                     limit -= num_yielded