`faust.tables.manager`¶

Tables (changelog stream).

class faust.tables.manager.TableManager(app: faust.types.app.AppT, **kwargs) → None[source]¶

Manage tables used by Faust worker.

add(table: faust.types.tables.CollectionT) → faust.types.tables.CollectionT[source]¶

Return type:	`CollectionT`[]

coroutine on_partitions_assigned(self, assigned: Set[faust.types.tuples.TP]) → None[source]¶

Return type:	`None`

coroutine on_partitions_revoked(self, revoked: Set[faust.types.tuples.TP]) → None[source]¶

Return type:	`None`

coroutine on_start(self) → None[source]¶

Called every time before the service is started/restarted.

Return type:	`None`

coroutine on_stop(self) → None[source]¶

Called every time before the service is stopped/restarted.

Return type:	`None`

Faust