diff --git a/src/crewai/crew.py b/src/crewai/crew.py index 0b88d5e4b..3c3cdbbfb 100644 --- a/src/crewai/crew.py +++ b/src/crewai/crew.py @@ -354,7 +354,8 @@ class Crew(BaseModel): def _set_tasks_callbacks(self) -> str: """Sets callback for every task suing task_callback""" for task in self.tasks: - self.task_callback = task.callback + if not task.callback: + task.callback = self.task_callback def _interpolate_inputs(self, inputs: Dict[str, Any]) -> str: """Interpolates the inputs in the tasks and agents."""