`faust.agents.manager`¶

Agent manager.

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

Agent manager.

update_topic_index() → None[source]¶

Return type:	`None`

coroutine on_partitions_assigned(self, assigned: Set[faust.types.tuples.TP]) → None[source]¶

Return type:	`None`

coroutine on_partitions_revoked(self, revoked: Set[faust.types.tuples.TP]) → None[source]¶

Return type:	`None`

class faust.agents.manager.AgentManagerService(agents: faust.agents.manager.AgentManager, **kwargs) → None[source]¶

service_reset() → None[source]¶

Return type:	`None`

cancel() → None[source]¶

Return type:	`None`

coroutine on_start(self) → None[source]¶

Called every time before the service is started/restarted.

Return type:	`None`

coroutine on_stop(self) → None[source]¶

Called every time before the service is stopped/restarted.

Return type:	`None`

coroutine stop(self) → None[source]¶

Stop the service.

Return type:	`None`

Faust