faust.assignor.leader_assignor

Leader assignor.

class faust.assignor.leader_assignor.LeaderAssignor(app: faust.types.app.AppT, **kwargs: Any) → None[source]

Leader assignor, ensures election of a leader.

async on_start() → None[source]

Service is starting.

Return type

None

is_leader() → bool[source]
Return type

bool

logger = <Logger faust.assignor.leader_assignor (WARNING)>