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'¶
-
logger
= <Logger faust.agents.actor (WARNING)>¶
-
coroutine
on_isolated_partition_assigned
(self, tp: faust.types.tuples.TP) → None[source]¶ - 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)>¶
-