faust
faust copied to clipboard
Python Stream Processing. A Faust fork
## Checklist Issue is with master branch ## Steps to reproduce When I use autodiscover while an agent has import errors, it just gives a warning. ## Expected behavior I...
## Checklist - [X] I have included information about relevant versions - [ ] I have verified that the issue persists when using the `master` branch of Faust. ## Steps...
## 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...
Hello I have an error after changing the package faust to faust-streaming. I have a timer that sends a message to a channel at a cyclic interval. An agent iterates...
## Steps to reproduce Basically I commented bits and bits of my entire app until I ended up with two agents doing...nothing. I didn't post my entire app because at...
I am facing a problem with the example in the documentation (https://faust.readthedocs.io/en/latest/userguide/streams.html#combining-streams) for Combining Streams. In case of such combined topics, the data in the first topic is consumed as...
## Checklist - [x] I have included information about relevant versions - [ ] I have verified that the issue persists when using the `master` branch of Faust. ## Steps...
## Checklist - [x] I have included information about relevant versions - [ ] I have verified that the issue persists when using the `master` branch of Faust. ## Steps...
## Steps to reproduce When I do specify coercions on a Record class they are ignored, e.g. a UUIDAwareRecord from uuid import UUID, uuid4 import faust class Account(faust.Record, coerce=True, coercions={UUID:...
## Checklist - [X] I have included information about relevant versions - [X] I have verified that the issue persists when using the `master` branch of Faust. 1. Create a...