faust
faust copied to clipboard
faust-streaming
Python Stream Processing. A Faust fork
## Checklist - [ x ] I have included information about relevant versions - [ ] I have verified that the issue persists when using the `master` branch of Faust....
I'm using Faust in combination with a Django backend. Faust is integrated as a Django app but runs in a separate container, similar to how Celery workers operate — except...
Bumps [actions/setup-python](https://github.com/actions/setup-python) from 5 to 6. Release notes Sourced from actions/setup-python's releases. v6.0.0 What's Changed Breaking Changes Upgrade to node 24 by @salmanmkc in actions/setup-python#1164 Make sure your runner is...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [actions/upload-pages-artifact](https://github.com/actions/upload-pages-artifact) from 3 to 4. Release notes Sourced from actions/upload-pages-artifact's releases. v4.0.0 What's Changed Potentially breaking change: hidden files (specifically dotfiles) will not be included in the artifact by...
Bumps [actions/checkout](https://github.com/actions/checkout) from 4 to 5. Release notes Sourced from actions/checkout's releases. v5.0.0 What's Changed Update actions checkout to use node 24 by @salmanmkc in actions/checkout#2226 Prepare v5.0.0 release by...
*Note*: Before submitting this pull request, please review our [contributing guidelines](https://faust-streaming.github.io/faust/contributing.html). ## Description * Fixed / added type annotations mostly for `StreamT` class. * Fixed generic argument for `EventT` class....
In 2022 Faust added a fallback to Round Robin w/ PR #402 when `table_standby_replicas` wasn't used. In 2024 Faust added support for KIP-345 kafka static-partition-assignment #600. When a user is...
Hello Faust team, I am currently working on a project where I need to “snooze” streams to a specific time based on a process_time field specified in the record. I...
Issue [#556](https://github.com/faust-streaming/faust/issues/556) This pull request includes several changes to the `faust` library, specifically in the `faust/app/base.py` and `faust/tables/base.py` files. The most important changes involve the addition of a `value_serializer` parameter...
## Problem The `_slurp_changelogs` in `faust/faust/tables/recovery.py` method in the recovery process doesn't properly handle None events that can occasionally be received from the changelog queue. When a None event is...
