faust.agents.actor

Actor - Individual Agent instances.

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[source]

An actor is a specific agent instance.

mundane_level = 'debug'
cancel() → None[source]
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[source]
Return type:None
coroutine on_isolated_partition_revoked(self, tp: faust.types.tuples.TP) → None[source]
Return type:None
coroutine on_start(self) → None[source]

Service is starting.

Return type:None
coroutine on_stop(self) → None[source]

Service is being 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[source]

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[source]

Used for actor function that do not yield.

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