v0.10.8

What's Changed

• Hotfix key_may_exist() by @wbarnha in #481

This is the final patch for basic rocksdict support. You can swap your driver over from python-rocksdb to rocksdict. But note that since you're switching from a library that uses RocksDB 6 to RocksDB 7, you will not be available to revert to python-rocksdb.

Full Changelog: v0.10.7...v0.10.8

v0.10.7

What's Changed

• Fix test case for test_apply_changelog_batch by @wbarnha in #480

Full Changelog: v0.10.6...v0.10.7

v0.10.6

What's Changed

• Hotfix rocksdict methods by @wbarnha in #476
• Bump actions/deploy-pages from 1 to 2 by @dependabot in #477
• Add unit tests for rocksdict to guarantee reliability by @wbarnha in #478
• use key_may_exist() from rocksdict by @wbarnha in #479

Full Changelog: v0.10.5...v0.10.6

v0.10.5

What's Changed

• Fix spelling of NLTK by @jack-mcivor in #445
• Update project for flake8 changes by @wbarnha in #453
• Update pip installs from remaining faust to faust-streaming by @gpapia in #452
• add OPT_NON_STR_KEYS to orjson by @wbarnha in #455
• Bump actions/upload-artifact from 2 to 3 by @dependabot in #456
• Remove pytest-openfiles due to deprecation by @wbarnha in #464
• doc: update testing doc by @thomas-chauvet in #467
• Add support for rocksdict by @wbarnha in #470
• Allow users to specify RocksDB drivers by @wbarnha in #472
• Bump rocksdict minimum requirement to 0.3.7 by @wbarnha in #475

Give pip install faust-streaming[rocksdict] a try!

New Contributors

• @jack-mcivor made their first contribution in #445
• @gpapia made their first contribution in #452
• @thomas-chauvet made their first contribution in #467

Full Changelog: v0.10.4...v0.10.5

v0.10.4

What's Changed

• fix: set loop for services where missing by @dabdada in #441

Full Changelog: v0.10.3...v0.10.4

v0.10.3: resolving wrong reference (#438)

* 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

* resolved reference error self.table.use_partitioner -> table.usepartitioner

* run code formatter

Co-authored-by: Alexander Oberegger <[email protected]>
Co-authored-by: aoberegg <[email protected]>
Co-authored-by: Marco Julian Moser <[email protected]>

v0.10.2

What's Changed

• Global global tables by @aoberegg in #431
• fix: set missing loop param for service inits by @dabdada in #436
• #307: Allow custom headers in self.error view method by @popadi in #437

New Contributors

• @dabdada made their first contribution in #436
• @popadi made their first contribution in #437

Full Changelog: v0.10.1...v0.10.2

v0.10.1

What's Changed

• Commit reformatting fixes by @wbarnha in #423
• Assign blessed_key to metadata if blessed_key is defined by @wbarnha in #422
• Update Slack invite link by @wbarnha in #425
• Global global tables by @aoberegg in #426
• fix for issue 419 by @patkivikram in #420

Full Changelog: v0.10.0...v0.10.1

v0.10.0

What's Changed

We now support Python 3.11!

• Update statsd requirement from ~=3.3.0 to ~=4.0.1 in /requirements by @dependabot in #409
• Add support for python3.11 by @wbarnha in #366
• Add get_event_loop_policy() to all get_event_loop() calls by @wbarnha in #415

Full Changelog: v0.9.5...v0.10.0

v0.9.5

What's Changed

• Update aiokafka requirement from <0.8.0,>=0.7.1 to >=0.7.1,<0.9.0 in /requirements by @dependabot in #413
• version limit mode-streaming to >=0.2.0,<0.3.0 while we're working on testing things out by @wbarnha in #414

Full Changelog: v0.9.4...v0.9.5