andre/crewAI
1
0
Fork 0
mirror of https://github.com/crewAIInc/crewAI.git synced 2026-01-28 01:28:14 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Fix pre-existing lint and type-checker errors in flow.py

Browse Source 
- Import PrinterColor type from utilities.printer
- Replace unused variable 'condition_type' with '_' at line 1091
- Fix type annotation for '_log_flow_event' color parameter to use PrinterColor instead of str

These were pre-existing errors that prevented CI from passing after modifying flow.py

Co-Authored-By: João <joao@crewai.com>
This commit is contained in:
Devin AI
2025-10-01 17:37:53 +00:00
parent 1ce52c6616
commit 53d94df7de
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/crewai/flow/flow.py
View File

@@ -31,7 +31,7 @@ from crewai.flow.flow_visualizer import plot_flow
from crewai.flow.persistence.base import FlowPersistence from crewai.flow.persistence.base import FlowPersistence
from crewai.flow.types import FlowExecutionData from crewai.flow.types import FlowExecutionData
from crewai.flow.utils import get_possible_return_constants from crewai.flow.utils import get_possible_return_constants
from crewai.utilities.printer import Printer from crewai.utilities.printer import Printer, PrinterColor
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@@ -1088,7 +1088,7 @@ class Flow(Generic[T], metaclass=FlowMeta):
for method_name in self._start_methods: for method_name in self._start_methods:
# Check if this start method is triggered by the current trigger # Check if this start method is triggered by the current trigger
if method_name in self._listeners: if method_name in self._listeners:
condition_type, trigger_methods = self._listeners[ _, trigger_methods = self._listeners[
method_name method_name
] ]
if current_trigger in trigger_methods: if current_trigger in trigger_methods:
@@ -1220,7 +1220,7 @@ class Flow(Generic[T], metaclass=FlowMeta):
raise raise
def _log_flow_event( def _log_flow_event(
self, message: str, color: str = "yellow", level: str = "info" self, message: str, color: PrinterColor = "yellow", level: str = "info"
) -> None: ) -> None:
"""Centralized logging method for flow events. """Centralized logging method for flow events.