diff --git a/src/crewai/task.py b/src/crewai/task.py index 82266bed0..6da0b64a2 100644 --- a/src/crewai/task.py +++ b/src/crewai/task.py @@ -180,7 +180,7 @@ class Task(BaseModel): tools: Optional[List[Any]] = None, ) -> Future[TaskOutput]: """Execute the task asynchronously.""" - future = Future() + future: Future[TaskOutput] = Future() threading.Thread( target=self._execute_task_async, args=(agent, context, tools, future) ).start() @@ -388,7 +388,6 @@ class Task(BaseModel): converter.to_pydantic() if self.output_pydantic else converter.to_json() ) - if isinstance(exported_result, ConverterError): Printer().print( content=f"{exported_result.message} Using raw output instead.", diff --git a/tests/crew_test.py b/tests/crew_test.py index 829917d2d..027783e79 100644 --- a/tests/crew_test.py +++ b/tests/crew_test.py @@ -7,7 +7,6 @@ from unittest.mock import patch import pydantic_core import pytest - from crewai.agent import Agent from crewai.agents.cache import CacheHandler from crewai.crew import Crew @@ -709,7 +708,6 @@ def test_kickoff_for_each_single_input(): @pytest.mark.vcr(filter_headers=["authorization"]) def test_kickoff_for_each_multiple_inputs(): """Tests if kickoff_for_each works with multiple inputs.""" - from unittest.mock import patch inputs = [ {"topic": "dog"}, @@ -1084,7 +1082,6 @@ def test_code_execution_flag_adds_code_tool_upon_kickoff(): @pytest.mark.vcr(filter_headers=["authorization"]) def test_delegation_is_not_enabled_if_there_are_only_one_agent(): - from unittest.mock import patch researcher = Agent( role="Researcher",