feat: add default value for crew.name (#3252)
Some checks failed
Notify Downstream / notify-downstream (push) Has been cancelled

Co-authored-by: Lorenze Jay <63378463+lorenzejay@users.noreply.github.com>
This commit is contained in:
Lucas Gomide
2025-08-05 13:25:50 -03:00
committed by GitHub
parent 66567bdc2f
commit 477bc1f09e
2 changed files with 20 additions and 10 deletions

View File

@@ -133,7 +133,7 @@ class Crew(FlowTrackable, BaseModel):
default_factory=TaskOutputStorageHandler default_factory=TaskOutputStorageHandler
) )
name: Optional[str] = Field(default=None) name: Optional[str] = Field(default="crew")
cache: bool = Field(default=True) cache: bool = Field(default=True)
tasks: List[Task] = Field(default_factory=list) tasks: List[Task] = Field(default_factory=list)
agents: List[BaseAgent] = Field(default_factory=list) agents: List[BaseAgent] = Field(default_factory=list)
@@ -575,7 +575,7 @@ class Crew(FlowTrackable, BaseModel):
crewai_event_bus.emit( crewai_event_bus.emit(
self, self,
CrewTrainStartedEvent( CrewTrainStartedEvent(
crew_name=self.name or "crew", crew_name=self.name,
n_iterations=n_iterations, n_iterations=n_iterations,
filename=filename, filename=filename,
inputs=inputs, inputs=inputs,
@@ -602,7 +602,7 @@ class Crew(FlowTrackable, BaseModel):
crewai_event_bus.emit( crewai_event_bus.emit(
self, self,
CrewTrainCompletedEvent( CrewTrainCompletedEvent(
crew_name=self.name or "crew", crew_name=self.name,
n_iterations=n_iterations, n_iterations=n_iterations,
filename=filename, filename=filename,
), ),
@@ -610,7 +610,7 @@ class Crew(FlowTrackable, BaseModel):
except Exception as e: except Exception as e:
crewai_event_bus.emit( crewai_event_bus.emit(
self, self,
CrewTrainFailedEvent(error=str(e), crew_name=self.name or "crew"), CrewTrainFailedEvent(error=str(e), crew_name=self.name),
) )
self._logger.log("error", f"Training failed: {e}", color="red") self._logger.log("error", f"Training failed: {e}", color="red")
CrewTrainingHandler(TRAINING_DATA_FILE).clear() CrewTrainingHandler(TRAINING_DATA_FILE).clear()
@@ -634,7 +634,7 @@ class Crew(FlowTrackable, BaseModel):
crewai_event_bus.emit( crewai_event_bus.emit(
self, self,
CrewKickoffStartedEvent(crew_name=self.name or "crew", inputs=inputs), CrewKickoffStartedEvent(crew_name=self.name, inputs=inputs),
) )
# Starts the crew to work on its assigned tasks. # Starts the crew to work on its assigned tasks.
@@ -683,7 +683,7 @@ class Crew(FlowTrackable, BaseModel):
except Exception as e: except Exception as e:
crewai_event_bus.emit( crewai_event_bus.emit(
self, self,
CrewKickoffFailedEvent(error=str(e), crew_name=self.name or "crew"), CrewKickoffFailedEvent(error=str(e), crew_name=self.name),
) )
raise raise
finally: finally:
@@ -1077,7 +1077,7 @@ class Crew(FlowTrackable, BaseModel):
crewai_event_bus.emit( crewai_event_bus.emit(
self, self,
CrewKickoffCompletedEvent( CrewKickoffCompletedEvent(
crew_name=self.name or "crew", output=final_task_output crew_name=self.name, output=final_task_output
), ),
) )
return CrewOutput( return CrewOutput(
@@ -1325,7 +1325,7 @@ class Crew(FlowTrackable, BaseModel):
crewai_event_bus.emit( crewai_event_bus.emit(
self, self,
CrewTestStartedEvent( CrewTestStartedEvent(
crew_name=self.name or "crew", crew_name=self.name,
n_iterations=n_iterations, n_iterations=n_iterations,
eval_llm=llm_instance, eval_llm=llm_instance,
inputs=inputs, inputs=inputs,
@@ -1344,13 +1344,13 @@ class Crew(FlowTrackable, BaseModel):
crewai_event_bus.emit( crewai_event_bus.emit(
self, self,
CrewTestCompletedEvent( CrewTestCompletedEvent(
crew_name=self.name or "crew", crew_name=self.name,
), ),
) )
except Exception as e: except Exception as e:
crewai_event_bus.emit( crewai_event_bus.emit(
self, self,
CrewTestFailedEvent(error=str(e), crew_name=self.name or "crew"), CrewTestFailedEvent(error=str(e), crew_name=self.name),
) )
raise raise

View File

@@ -4756,3 +4756,13 @@ def test_reset_agent_knowledge_with_only_agent_knowledge(researcher, writer):
mock_reset_agent_knowledge.assert_called_once_with( mock_reset_agent_knowledge.assert_called_once_with(
[mock_ks_research, mock_ks_writer] [mock_ks_research, mock_ks_writer]
) )
def test_default_crew_name(researcher, writer):
crew = Crew(
agents=[researcher, writer],
tasks=[
Task(description="Task 1", expected_output="output", agent=researcher),
Task(description="Task 2", expected_output="output", agent=writer),
],
)
assert crew.name == "crew"