Source code for faust.tables.globaltable

from faust.tables.table import Table
from faust.types.tables import GlobalTableT


[docs]class GlobalTable(Table, GlobalTableT): """ .. warning:: Using a GlobalTable with multiple app instances may cause an app to be stuck in an infinite recovery loop. The current fix for this is to run the table with the following options:: app.GlobalTable(..., partitions=1, recovery_buffer_size=1) """