faust.agents.actor

class faust.agents.actor.Actor(agent: faust.types.agents.AgentT, stream: faust.types.streams.StreamT, it: _T, index: int = None, active_partitions: Set[faust.types.tuples.TP] = None, **kwargs) → None

An actor is a specific agent instance.

cancel() → None

Return type:None

label

Label used for graphs. :rtype: str

logger = <Logger faust.agents.actor (WARNING)>

coroutine on_isolated_partition_assigned(self, tp: faust.types.tuples.TP) → None

Return type:None

coroutine on_isolated_partition_revoked(self, tp: faust.types.tuples.TP) → None

Return type:None

coroutine on_start(self) → None

Called every time before the service is started/restarted.

Return type:None

coroutine on_stop(self) → None

Called every time before the service is stopped/restarted.

Return type:None

class faust.agents.actor.AsyncIterableActor(agent: faust.types.agents.AgentT, stream: faust.types.streams.StreamT, it: _T, index: int = None, active_partitions: Set[faust.types.tuples.TP] = None, **kwargs) → None

Used for agent function that yields.

logger = <Logger faust.agents.actor (WARNING)>

class faust.agents.actor.AwaitableActor(agent: faust.types.agents.AgentT, stream: faust.types.streams.StreamT, it: _T, index: int = None, active_partitions: Set[faust.types.tuples.TP] = None, **kwargs) → None

Used for actor function that do not yield.

logger = <Logger faust.agents.actor (WARNING)>