faust.assignor.leader_assignor

Leader assignor.

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

Leader assignor, ensures election of a leader.

is_leader() → bool[source]
Return type:bool
logger = <Logger faust.assignor.leader_assignor (WARNING)>
coroutine on_start(self) → None[source]

Called every time before the service is started/restarted.

Return type:None