From 8b7040577fb5553d14cb40f45edd75c88d987114 Mon Sep 17 00:00:00 2001
From: Lorenze Jay <lorenzejaytech@gmail.com>
Date: Fri, 12 Jul 2024 08:56:47 -0700
Subject: [PATCH] ensure hierarchical works

---
 src/crewai/crew.py | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/crewai/crew.py b/src/crewai/crew.py
index b0b6a75ac..6a6749f7e 100644
--- a/src/crewai/crew.py
+++ b/src/crewai/crew.py
@@ -593,6 +593,7 @@ class Crew(BaseModel):
         Returns:
             CrewOutput: Final output of the crew
         """
+
         task_outputs: List[TaskOutput] = []
         futures: List[Tuple[Task, Future[TaskOutput], int]] = []
         last_sync_output: Optional[TaskOutput] = None
@@ -608,12 +609,16 @@ class Crew(BaseModel):
                 continue
 
             self._prepare_task(task, manager)
-            agent_to_use = task.agent if task.agent else manager
+            if self.process == Process.hierarchical:
+                agent_to_use = manager
+            else:
+                agent_to_use = task.agent
             if agent_to_use is None:
                 raise ValueError(
                     f"No agent available for task: {task.description}. Ensure that either the task has an assigned agent or a manager agent is provided."
                 )
             self._log_task_start(task, agent_to_use)
+
             if task.async_execution:
                 context = self._set_context(
                     task, [last_sync_output] if last_sync_output else []