faust.app.service

class faust.app.service.App

class faust.app.service.AppService(app: faust.app.service.App, **kwargs) → None

Service responsible for starting/stopping an application.

on_init_dependencies() → Iterable[mode.types.services.ServiceT]

Callback to be used to add service dependencies.

Return type:Iterable[ServiceT[]]

logger = <Logger faust.app.service (WARNING)>

coroutine on_first_start(self) → None

Called only the first time the service is started.

Return type:None

coroutine on_init_extra_service(self, service: Union[mode.types.services.ServiceT, typing.Type[mode.types.services.ServiceT]]) → mode.types.services.ServiceT

Return type:ServiceT[]

coroutine on_restart(self) → None

Called every time when the service is restarted.

Return type:None

coroutine on_shutdown(self) → None

Called every time after the service is stopped/restarted

Return type:None

coroutine on_start(self) → None

Called every time before the service is started/restarted.

Return type:None

coroutine on_started(self) → None

Called every time after the service is started/restarted.

Return type:None

coroutine on_started_init_extra_services(self) → None

Return type:None

coroutine on_started_init_extra_tasks(self) → None

Return type:None

coroutine on_stop(self) → None

Called every time before the service is stopped/restarted.

Return type:None

coroutine wait_for_table_recovery_completed(self) → None

Return type:None

label

Label used for graphs. :rtype: str

shortlabel

Label used for logging. :rtype: str