From 12da0c97304dd27657d6bdaac5033d00a5a94059 Mon Sep 17 00:00:00 2001 From: Ivan Shcheklein Date: Wed, 8 Jan 2025 20:05:23 -0800 Subject: [PATCH] fix(db): revert use_new_connection=True --- src/datachain/data_storage/warehouse.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/datachain/data_storage/warehouse.py b/src/datachain/data_storage/warehouse.py index 843095485..32dfb5385 100644 --- 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