faust
faust copied to clipboard
faust-streaming
Python Stream Processing. A Faust fork
I want to run the `Worker` class from my code. There's a [docstring on the class](https://github.com/faust-streaming/faust/blob/master/faust/worker.py#L172) explaining how to do it. It looks to be outdated, though, as there's no...
Hi everyone, I am interested in contributing to the project, but I lack an overview of the priorities and current needs. I am primarily interested in working on the documentation...
Hi, I am new to Faust and I am trying to understand how to make sure I have processed the oldest event by partition. I am using the group_by syntax...
I'm not sure if this will be welcomed as an issue - but I'm going to call this ~ 'small contributions' and ask for grace. ## Steps to reproduce I...
Running a basic application for any extended period of time - sometimes just a few minutes - leads to consumers slowly dying one-by-one until they've all stopped responding and the...
It looks like `mypy` is treating every value of type `faust.Record` as `Any`: absolutely no type checking is done on them. This is related to #233, but larger than only...
## Description This is a work in progress for #132, fixing `make develop`. As I said in [that issue](https://github.com/faust-streaming/faust/issues/132#issuecomment-831544577), > I fixed this, but then I saw that make develop...
*Note*: Before submitting this pull request, please review our [contributing guidelines](https://fauststream.com/en/latest/contributing.html). ## Description This includes an agent_stopper functionality that kills the main agent without producing exit status 0 Fixes https://github.com/faust-streaming/faust/issues/324...
## Checklist - [x] I have included information about relevant versions - [x] I have verified that the issue persists when using the `master` branch of Faust. ## Steps to...
