faust.assignor.leader_assignor

Leader assignor.

class faust.assignor.leader_assignor.LeaderAssignor(app: AppT, **kwargs: Any)[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: logging.Logger = <Logger faust.assignor.leader_assignor (WARNING)>
log: CompositeLogger
diag: DiagT
async_exit_stack: AsyncExitStack
exit_stack: ExitStack