capture_events

Captures and processes events from the application's message broker, managing connection retries and updating the display state in a continuous loop.

def capture_events(
    app: Celery,
    state: State,
    display: Display
)

Starts a continuous loop to capture and process Celery events from the message broker, updating the display state in real-time.

Parameters

Name	Type	Description
app	Celery	The Celery application instance used to establish broker connections and access event receivers.
state	State	The internal state object that tracks and stores incoming event data for processing.
display	Display	The UI component responsible for screen initialization and rendering the captured event data.