`faust.livecheck.signals`¶

LiveCheck Signals - Test communication and synchronization.

class faust.livecheck.signals.BaseSignal(name: str = '', case: faust.livecheck.signals._Case = None, index: int = -1) → None[source]¶

Generic base class for signals.

async send(value: VT = None, *, key: Any = None, force: bool = False) → None[source]¶

Notify test that this signal is now complete.

async wait(*, key: Any = None, timeout: Union[datetime.timedelta, float, str] = None) → VT[source]¶

Wait for signal to be completed.

async resolve(key: Any, event: faust.livecheck.models.SignalEvent) → None[source]¶

Resolve signal with value.

clone(**kwargs: Any) → faust.livecheck.signals.BaseSignal[source]¶

Clone this signal using keyword arguments.

class faust.livecheck.signals.Signal(name: str = '', case: faust.livecheck.signals._Case = None, index: int = -1) → None[source]¶

Signal for test case using Kafka.

Used to wait for something to happen elsewhere.

async send(value: VT = None, *, key: Any = None, force: bool = False) → None[source]¶

Notify test that this signal is now complete.

async wait(*, key: Any = None, timeout: Union[datetime.timedelta, float, str] = None) → VT[source]¶

Wait for signal to be completed.

Faust