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

An actor is a specific agent instance.

mundane_level = 'debug'

cancel() → None

Tell actor to stop reading from the stream.

Return type

None

property label

Return human readable description of actor. :rtype: str

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

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)>