faust.agents.manager
¶
Agent manager.
-
class
faust.agents.manager.
AgentManager
(app: faust.types.app.AppT, **kwargs: Any) → None[source]¶ Agent manager.
-
async
on_rebalance
(revoked: Set[faust.types.tuples.TP], newly_assigned: Set[faust.types.tuples.TP]) → None[source]¶ Call when a rebalance is needed.
- Return type
None
-
logger
= <Logger faust.agents.manager (WARNING)>¶
-
async