mirror of
https://github.com/crewAIInc/crewAI.git
synced 2026-01-09 08:08:32 +00:00
linting
This commit is contained in:
@@ -7,6 +7,7 @@ and memory management.
|
|||||||
from __future__ import annotations
|
from __future__ import annotations
|
||||||
|
|
||||||
from collections.abc import Callable
|
from collections.abc import Callable
|
||||||
|
import logging
|
||||||
from typing import TYPE_CHECKING, Any, Literal, cast
|
from typing import TYPE_CHECKING, Any, Literal, cast
|
||||||
|
|
||||||
from pydantic import BaseModel, GetCoreSchemaHandler
|
from pydantic import BaseModel, GetCoreSchemaHandler
|
||||||
@@ -51,6 +52,8 @@ from crewai.utilities.tool_utils import (
|
|||||||
from crewai.utilities.training_handler import CrewTrainingHandler
|
from crewai.utilities.training_handler import CrewTrainingHandler
|
||||||
|
|
||||||
|
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
if TYPE_CHECKING:
|
if TYPE_CHECKING:
|
||||||
from crewai.agent import Agent
|
from crewai.agent import Agent
|
||||||
from crewai.agents.tools_handler import ToolsHandler
|
from crewai.agents.tools_handler import ToolsHandler
|
||||||
@@ -554,8 +557,8 @@ class CrewAgentExecutor(CrewAgentExecutorMixin):
|
|||||||
if future is not None:
|
if future is not None:
|
||||||
try:
|
try:
|
||||||
future.result(timeout=5.0)
|
future.result(timeout=5.0)
|
||||||
except Exception:
|
except Exception as e:
|
||||||
pass
|
logger.error(f"Failed to show logs for agent execution event: {e}")
|
||||||
|
|
||||||
def _handle_crew_training_output(
|
def _handle_crew_training_output(
|
||||||
self, result: AgentFinish, human_feedback: str | None = None
|
self, result: AgentFinish, human_feedback: str | None = None
|
||||||
|
|||||||
Reference in New Issue
Block a user