mirror of
https://github.com/hwchase17/langchain.git
synced 2025-07-14 08:56:27 +00:00
Fix locking (#13725)
This commit is contained in:
parent
16af282429
commit
5b90fe5b1c
@ -979,6 +979,7 @@ def _prepare_run_on_dataset(
|
|||||||
evaluators=run_evaluators or [],
|
evaluators=run_evaluators or [],
|
||||||
client=client,
|
client=client,
|
||||||
example_id=example.id,
|
example_id=example.id,
|
||||||
|
max_concurrency=0,
|
||||||
),
|
),
|
||||||
progress_bar,
|
progress_bar,
|
||||||
],
|
],
|
||||||
@ -1088,7 +1089,6 @@ async def arun_on_dataset(
|
|||||||
concurrency_level,
|
concurrency_level,
|
||||||
project_metadata=project_metadata,
|
project_metadata=project_metadata,
|
||||||
)
|
)
|
||||||
|
|
||||||
batch_results = await runnable_utils.gather_with_concurrency(
|
batch_results = await runnable_utils.gather_with_concurrency(
|
||||||
configs[0].get("max_concurrency"),
|
configs[0].get("max_concurrency"),
|
||||||
*map(
|
*map(
|
||||||
|
Loading…
Reference in New Issue
Block a user