Event System

Compatibility facade for events.

Subscriptions are removed by design. The app uses DB polling (see Task table) for coordination between components.

class shared.event_system.Event(event_type, data=None, created_at=<factory>)

Bases: object

Simple event record used by the compatibility facade.

Variables:

• event_type – Category of the event.

• data – Optional payload with event-specific fields.

• created_at – Creation timestamp.

Parameters:

• event_type (EventType)

• data (Dict[str, Any] | None)

• created_at (datetime)

created_at: datetime

data: Optional[Dict[str, Any]] = None

event_type: EventType

class shared.event_system.EventType(*values)

Bases: Enum

Event types used for high-level coordination.

MESSAGE_RECEIVED = 'message_received'

RESPONSE_READY = 'response_ready'

TASK_COMPLETED = 'task_completed'

TASK_CREATED = 'task_created'

TASK_FAILED = 'task_failed'