Skip to content

Commit 43584f6

Browse files
Wendong-Fancoolbeevip
authored andcommitted
enhance: Refactor WorkforceCallback and all related callbacks to asyn… (#3464)
1 parent e47f40e commit 43584f6

File tree

5 files changed

+347
-39
lines changed

5 files changed

+347
-39
lines changed

camel/benchmarks/browsecomp.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -591,7 +591,9 @@ def process_benchmark_row(row: Dict[str, Any]) -> Dict[str, Any]:
591591
input_message, response_format=QueryResponse
592592
)
593593
elif isinstance(pipeline_template, Workforce):
594-
workforce_pipeline = asyncio.run(pipeline_template.clone())
594+
workforce_pipeline = asyncio.run(
595+
pipeline_template.clone_async()
596+
)
595597
task = Task(content=input_message, id="0")
596598
task = asyncio.run(
597599
workforce_pipeline.process_task_async(task)

0 commit comments

Comments
 (0)