`kafka_dae_control.event_with_error`

Module containing utilities for passing events between threads with an exception.

Members

Create the event object.

class kafka_dae_control.event_with_error.EventWithError[source]

Create the event object.

property err: Exception | None

The exception.

Returns: The exception.

wait(timeout: float | None = None) → bool[source]

Wait for the event to be set.

Either return after waiting, or raise if there is an exception.

kafka_dae_control.event_with_error