mirror of
https://github.com/crewAIInc/crewAI.git
synced 2026-01-10 16:48:30 +00:00
48 lines
1.5 KiB
Python
48 lines
1.5 KiB
Python
tasks_order = []
|
|
|
|
|
|
def task(func):
|
|
func.is_task = True
|
|
tasks_order.append(func.__name__)
|
|
return func
|
|
|
|
|
|
def agent(func):
|
|
func.is_agent = True
|
|
return func
|
|
|
|
|
|
def crew(func):
|
|
def wrapper(self, *args, **kwargs):
|
|
instantiated_tasks = []
|
|
instantiated_agents = []
|
|
|
|
agent_roles = set()
|
|
# Iterate over tasks_order to maintain the defined order
|
|
for task_name in tasks_order:
|
|
possible_task = getattr(self, task_name)
|
|
if callable(possible_task):
|
|
task_instance = possible_task()
|
|
instantiated_tasks.append(task_instance)
|
|
if hasattr(task_instance, "agent"):
|
|
agent_instance = task_instance.agent
|
|
if agent_instance.role not in agent_roles:
|
|
instantiated_agents.append(agent_instance)
|
|
agent_roles.add(agent_instance.role)
|
|
|
|
# Instantiate any additional agents not already included by tasks
|
|
for attr_name in dir(self):
|
|
possible_agent = getattr(self, attr_name)
|
|
if callable(possible_agent) and hasattr(possible_agent, "is_agent"):
|
|
temp_agent_instance = possible_agent()
|
|
if temp_agent_instance.role not in agent_roles:
|
|
instantiated_agents.append(temp_agent_instance)
|
|
agent_roles.add(temp_agent_instance.role)
|
|
|
|
self.agents = instantiated_agents
|
|
self.tasks = instantiated_tasks
|
|
|
|
return func(self, *args, **kwargs)
|
|
|
|
return wrapper
|