faust.agents.manager
¶
Agent manager.
-
class
faust.agents.manager.
AgentManager
(app: faust.types.app.AppT, **kwargs) → None[source]¶ Agent manager.
-
logger
= <Logger faust.agents.manager (WARNING)>¶
-
coroutine
on_rebalance
(self, revoked: Set[faust.types.tuples.TP], newly_assigned: Set[faust.types.tuples.TP]) → None[source]¶ Return type: None
-
coroutine
on_start
(self) → None[source]¶ Called every time before the service is started/restarted.
Return type: None
-