faust.agents.manager

Agent manager.

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

Agent manager.

async on_start() → None[source]

Call when agents are being started.

Return type

None

service_reset() → None[source]

Reset service state on restart.

Return type

None

async on_stop() → None[source]

Call when agents are being stopped.

Return type

None

async stop() → None[source]

Stop all running agents.

Return type

None

cancel() → None[source]

Cancel all running agents.

Return type

None

update_topic_index() → None[source]

Update indices.

Return type

None

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)>