andre/crewAI
1
0
Fork 0
mirror of https://github.com/crewAIInc/crewAI.git synced 2026-01-19 21:08:13 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Merge branch 'feature/procedure_v2' into brandon/cre-107-pipeline-conditional-routing#

Browse Source
This commit is contained in:
Brandon Hancock
2024-07-30 09:44:23 -04:00
parent 46fdada5e4 e1a03ad97d
commit e4b3b32b50
2 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/crewai/pipeline/pipeline.py
View File

@@ -114,7 +114,7 @@ class Pipeline(BaseModel):
check_nesting_and_type(stage)
return values
async def process_runs(
async def kickoff(
self, run_inputs: List[Dict[str, Any]]
) -> List[PipelineRunResult]:
"""
@@ -130,7 +130,7 @@ class Pipeline(BaseModel):
# Process all runs in parallel
all_run_results = await asyncio.gather(
*(self.process_single_run(input_data) for input_data in run_inputs)
*(self.process_single_kickoff(input_data) for input_data in run_inputs)
)
# Flatten the list of lists into a single list of results
@@ -140,7 +140,7 @@ class Pipeline(BaseModel):
return pipeline_results
async def process_single_run(
async def process_single_kickoff(
self, run_input: Dict[str, Any]
) -> List[PipelineRunResult]:
"""