Messaging

domain.fetch_pipeline.ports.messaging

Summary

Messaging port for fetch pipeline progress events.

Wraps the SSE in-memory bus used to stream progress to connected clients.

Classes

ProgressEventBus

ProgressEventBus()

Publish and replay progress events for a fetch request.

Notes

Backed by an SSEInMemoryBus[ProgressEvent]; events are kept in memory only.

Functions

get_events

get_events(fr_id: str) -> List[ProgressEvent]

Return the events published for a fetch request.

Parameters:

Name	Type	Description	Default
fr_id	str	Fetch request id.	required

Returns:

Type	Description
List[ProgressEvent]	List[ProgressEvent]: Events seen for that request.

publish async

publish(event: ProgressEvent) -> None

Publish a progress event to subscribers.

Parameters:

Name	Type	Description	Default
event	ProgressEvent	The event to broadcast.	required

Returns:

Name	Type	Description
None	None	Nothing.