Global global tables (faust-streaming#431)

* add static partition assignment possibilities * add global partitions as actives as well * pin mode as long we didn't switch to newest faust version that supports python 3.11 * first version of global global tables * add GlobalGlobalTable Object * have global global as attribute of global table * use use_partitioner also for having all partitions as standby * Update requirements.txt * fix tests, assert that global flag is set in case global global is used, linting * remove test artefact * fix linting again * rename global global to synchronize_all_active_partitions * fix linting * add base.py changes * fixed synchornized_all_active_partitions attribute handling in GlobalTable Constructor Co-authored-by: Alexander Oberegger <alexander.oberegger@smaxtec.com> Co-authored-by: Marco Julian Moser <marco.moser@smaxtec.com>
popadi · Jan 10, 2023 · c0fde84 · c0fde84
1 parent 89b82ab
commit c0fde84
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/faust/app/base.py b/faust/app/base.py
@@ -1186,6 +1186,7 @@ def GlobalTable(
         window: Optional[WindowT] = None,
         partitions: Optional[int] = None,
         help: Optional[str] = None,
+        synchronize_all_active_partitions: Optional[bool] = False,
         **kwargs: Any,
     ) -> GlobalTableT:
         """Define new global table.
@@ -1220,7 +1221,7 @@ def GlobalTable(
                     # as they come min (using 1 buffer size).
                     standby_buffer_size=1,
                     is_global=True,
-                    synchronize_all_active_partitions=False,
+                    synchronize_all_active_partitions=synchronize_all_active_partitions,
                     help=help,
                     **kwargs,
                 ),