faust.agents.manager

Agent manager.

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

Agent manager.

service_reset() → None[source]

Reset service state on restart.

Return type

None

cancel() → None[source]

Cancel all running agents.

Return type

None

update_topic_index() → None[source]

Update indices.

Return type

None

logger = <Logger faust.agents.manager (WARNING)>