Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
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>
- Loading branch information