faust

faust copied to clipboard

Start testing table.last_closed_window

1

Hopefully this will clarify things for https://github.com/faust-streaming/faust/issues/381.

wbarnha

add variable bound agent example

2

## Description Add variable-bound agent example with dead letter handling use case

joonjeong

Unit test `on_window_close` for window aggregation

4

## Checklist - [ x] I have included information about relevant versions I am using faust in the latest version `0.8.11`. - [ ] I have verified that the issue...

thomas-chauvet

Add hopping example

1

Originally based off #349.

wbarnha

`relative_to_field` raised error when the field is string type(isoformat)

1

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

rightx2

Gotta be sure we're not stepping on https://github.com/faust-streaming/faust/pull/287. We should probably add a unit test.

wbarnha

Window expiration doesn't work with RockDB after recovery

2

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

novotl

Migrate from opentracing to opentelemetry

4

The `opentracing` project is deprecated in favor of `opentelemetry`. Due to ongoing flaws with `opentracing`, we have had difficulty troubleshooting particular bugs that rely on the usage of `opentracing.Span` objects....

wbarnha

Fix table restoration for compacted changelogs

6

Fixes #176.

wbarnha

Add support for python3.11

1

Prepare for upcoming release of Python 3.11 on 10/24

wbarnha