fix circular deps

This commit is contained in:
Brandon Hancock
2025-03-20 11:09:16 -04:00
parent c852d772d4
commit d16144bbaa

View File

@@ -1,11 +1,12 @@
import re import re
from typing import Any, Dict, List, Optional, Union from typing import TYPE_CHECKING, Any, Dict, List, Optional, Union
from crewai.task import Task if TYPE_CHECKING:
from crewai.tasks.task_output import TaskOutput from crewai.task import Task
from crewai.tasks.task_output import TaskOutput
def aggregate_raw_outputs_from_task_outputs(task_outputs: List[TaskOutput]) -> str: def aggregate_raw_outputs_from_task_outputs(task_outputs: List["TaskOutput"]) -> str:
"""Generate string context from the task outputs.""" """Generate string context from the task outputs."""
dividers = "\n\n----------\n\n" dividers = "\n\n----------\n\n"
@@ -14,7 +15,7 @@ def aggregate_raw_outputs_from_task_outputs(task_outputs: List[TaskOutput]) -> s
return context return context
def aggregate_raw_outputs_from_tasks(tasks: List[Task]) -> str: def aggregate_raw_outputs_from_tasks(tasks: List["Task"]) -> str:
"""Generate string context from the tasks.""" """Generate string context from the tasks."""
task_outputs = [task.output for task in tasks if task.output is not None] task_outputs = [task.output for task in tasks if task.output is not None]