mirror of
https://github.com/crewAIInc/crewAI.git
synced 2026-01-08 23:58:34 +00:00
f845fac4da
- Renamed `CrewEvent` to `BaseEvent` across the codebase for consistency - Created a `CrewBaseEvent` that automatically identifies fingerprints for DRY - Added a new `to_json()` method for serializing events
74 lines
1.6 KiB
Python
74 lines
1.6 KiB
Python
from typing import Any, Dict, Optional, Union
|
|
|
|
from pydantic import BaseModel, ConfigDict
|
|
|
|
from .base_events import BaseEvent
|
|
|
|
|
|
class FlowEvent(BaseEvent):
|
|
"""Base class for all flow events"""
|
|
|
|
type: str
|
|
flow_name: str
|
|
|
|
|
|
class FlowStartedEvent(FlowEvent):
|
|
"""Event emitted when a flow starts execution"""
|
|
|
|
flow_name: str
|
|
inputs: Optional[Dict[str, Any]] = None
|
|
type: str = "flow_started"
|
|
|
|
|
|
class FlowCreatedEvent(FlowEvent):
|
|
"""Event emitted when a flow is created"""
|
|
|
|
flow_name: str
|
|
type: str = "flow_created"
|
|
|
|
|
|
class MethodExecutionStartedEvent(FlowEvent):
|
|
"""Event emitted when a flow method starts execution"""
|
|
|
|
flow_name: str
|
|
method_name: str
|
|
state: Union[Dict[str, Any], BaseModel]
|
|
params: Optional[Dict[str, Any]] = None
|
|
type: str = "method_execution_started"
|
|
|
|
|
|
class MethodExecutionFinishedEvent(FlowEvent):
|
|
"""Event emitted when a flow method completes execution"""
|
|
|
|
flow_name: str
|
|
method_name: str
|
|
result: Any = None
|
|
state: Union[Dict[str, Any], BaseModel]
|
|
type: str = "method_execution_finished"
|
|
|
|
|
|
class MethodExecutionFailedEvent(FlowEvent):
|
|
"""Event emitted when a flow method fails execution"""
|
|
|
|
flow_name: str
|
|
method_name: str
|
|
error: Exception
|
|
type: str = "method_execution_failed"
|
|
|
|
model_config = ConfigDict(arbitrary_types_allowed=True)
|
|
|
|
|
|
class FlowFinishedEvent(FlowEvent):
|
|
"""Event emitted when a flow completes execution"""
|
|
|
|
flow_name: str
|
|
result: Optional[Any] = None
|
|
type: str = "flow_finished"
|
|
|
|
|
|
class FlowPlotEvent(FlowEvent):
|
|
"""Event emitted when a flow plot is created"""
|
|
|
|
flow_name: str
|
|
type: str = "flow_plot"
|