fonty422

Producers slow to send new messages after idle period, consumers slow to read new messages after idle period

9

## Steps to reproduce I have a pipeline where a message is produced to topic A, which is processed by a stream processor and sends enriched data to topic B....

Windows lost during/after a worker dies or is re-balanced

7

## Steps to reproduce Run the [windowed_aggreagation](https://github.com/faust-streaming/faust/blob/master/examples/windowed_aggregation.py) example on 2 workers. Kill one worker and observe the output. ## Expected behavior After a re balance (or similar disruption) all old...

QUESTION: Any possibility of getting a sliding window example

10

I note in the docs that it states you support hoping, tumbling, and sliding windows. There's even a `faust.SlidingWindow` class, but I can't seem to figure how to implement it....

Is it possible to use table_route to join windowed results across workers

1

Question I noted that with the word_count example, that the count table can be recalculated on a re-balance (using the @app.table_route option with the @app.page option). But is it possible...

Dealing with 'nan' values

23

I have a setup where a callback fires and returns: pvname, char_value, timestamp, status, severity, upper_alarm_limit_, lower_alarm_limit, upper_warning_limit, lower_alarm_limit, and host. However, I get nans for the lower values. I...

Slider slow when onChange triggers redux state change

2

### Duplicates - [X] I have searched the existing issues ### Latest version - [X] I have tested the latest version ### Steps to reproduce 🕹 Steps: 1. Create a...

Tables don't accept value_serializer kw

16

## Steps to reproduce `table = app.Table('test-table', key_type=str, value_serializer='my_serializer', default=SomeModel)` ## Expected behavior According to [the docs](https://faust.readthedocs.io/en/latest/userguide/tables.html#table-serialization) we should be able to specify our own table serializer. ## Actual behavior...

Model Validation is not working as expected

2

## Steps to reproduce ```python class Metadata(Record, validation=True, serializer='json'): desc:str=StringField(coerce=False) lolo:Optional[float] low:Optional[float] high:Optional[float] hihi:Optional[float] units:Optional[str] prec:Optional[int] ``` then try to initialise an instance with anything other than a string for...

Allow suppression of info characters when log level set to warn

4

## Checklist - [x ] I have included information about relevant versions - [ x] I have verified that the issue persists when using the `master` branch of Faust. ##...

error: unable to find vcvarsall.bat

18

After working around the stupid issues with python and Anaconda with respect to path issues, i managed to get somewhere with the install. But it now fails with the error...