faust

faust copied to clipboard

self._committed_offset.update(committable_offsets) if did_commit==False

1

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

ostetsenko

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

Aaronzinhoo

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

Robbie-Palmer

Passing custom command line argument to faust app

1

## 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...

misty256

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

mozTheFuzz

changelog_topic argument in Table declaration seems to be ignored

2

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

cezary69

Issue: Autodiscovery error logs not showing up

1

## 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...

blazing-gig

Stream.take not shutdown on SIGINT

2

If we use `stream.take(..., within=...)`, then send value to topic, and send SIGINT signal, faust did not shutdown gracefully ## Checklist - [x] I have included information about relevant versions...

Roman1us

orjson never used ?

1

I found this code in `utils/json.py` ```py if typing.TYPE_CHECKING: import orjson else: # pragma: no cover orjson = None # noqa ``` If I understand correctly, `orjson` is imported only...

elrik75

Use Case: Windowing per key/partition

1

## Question I have a general question on Faust. Using [windowed aggregation](https://github.com/robinhood/faust/blob/6a9d55b92a18e5bb17b04fc74816f4f88645c476/examples/windowed_aggregation.py) as an example. I understand that once having defined a table, we can use windows for processing the...

nogreintel