include event emitter in flows (#1740)

* include event emitter in flows

* Clean up

* Fix linter
This commit is contained in:
Brandon Hancock (bhancock_ai)
2024-12-11 10:16:05 -05:00
committed by GitHub
parent da9220fa81
commit 1df61aba4c
5 changed files with 94 additions and 9 deletions

View File

@@ -0,0 +1,33 @@
from dataclasses import dataclass, field
from datetime import datetime
from typing import Any, Optional
@dataclass
class Event:
type: str
flow_name: str
timestamp: datetime = field(init=False)
def __post_init__(self):
self.timestamp = datetime.now()
@dataclass
class FlowStartedEvent(Event):
pass
@dataclass
class MethodExecutionStartedEvent(Event):
method_name: str
@dataclass
class MethodExecutionFinishedEvent(Event):
method_name: str
@dataclass
class FlowFinishedEvent(Event):
result: Optional[Any] = None