faust.agents.manager

Agent manager.

class faust.agents.manager.AgentManager(app: faust.types.app.AppT, **kwargs) → None[source]

Agent manager.

service_reset() → None[source]
Return type:None
cancel() → None[source]
Return type:None
update_topic_index() → None[source]
Return type:None
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]

Service is starting.

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

Service is being stopped/restarted.

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

Stop the service.

Return type:None