fix: bump bytewax from 0.17.1 to 0.20.1

[dependabot]

Bumps bytewax from 0.17.1 to 0.20.1.

Release notes

Sourced from bytewax's releases.

v0.20.1

Overview

• Fixes a bug when using {py:obj}~bytewax.operators.windowing.EventClock where in-order but "slow" data results in watermark assertion errors.

What's Changed

• Fix watermark assertion errors with EventClock by @​davidselassie in bytewax/bytewax#470
• Prep for v0.20.1 release by @​davidselassie in bytewax/bytewax#471

Full Changelog: bytewax/bytewax@v0.20.0...v0.21.1

v0.20.0

Overview

• Adds a dataflow structure visualizer. Run python -m bytewax.visualize.

• Breaking change The internal format of recovery databases has been changed from using JsonPickle to Python's built-in {py:obj}pickle. Recovery stores that used the old format will not be usable after upgrading.

• Breaking change The unary operator and UnaryLogic have been renamed to stateful and StatefulLogic respectively.

• Adds a stateful_batch operator to allow for lower-level batch control while managing state.

• StatefulLogic.on_notify, StatefulLogic.on_eof, and StatefulLogic.notify_at are now optional overrides. The defaults retain the state and emit nothing.

• Breaking change Windowing operators have been moved from bytewax.operators.window into bytewax.operators.windowing.

• Breaking change ClockConfigs have had Config dropped from their name and are just Clocks. E.g. If you previously from bytewax.operators.window import SystemClockConfig now from bytewax.operators.windowing import SystemClock.

• Breaking change WindowConfigs have been renamed to Windowers. E.g. If you previously from bytewax.operators.window import SessionWindow now from bytewax.operators.windowing import SessionWindower.

• Breaking change All windowing operators now return a set of streams {py:obj}~bytewax.operators.windowing.WindowOut.

... (truncated)

Changelog

Sourced from bytewax's changelog.

v0.20.1

• Fixes a bug when using {py:obj}~bytewax.operators.windowing.EventClock where in-order but "slow" data results in watermark assertion errors.

v0.20.0

• Adds a dataflow structure visualizer. Run python -m bytewax.visualize.

• Breaking change The internal format of recovery databases has been changed from using JsonPickle to Python's built-in {py:obj}pickle. Recovery stores that used the old format will not be usable after upgrading.

• Breaking change The unary operator and UnaryLogic have been renamed to stateful and StatefulLogic respectively.

• Adds a stateful_batch operator to allow for lower-level batch control while managing state.

• StatefulLogic.on_notify, StatefulLogic.on_eof, and StatefulLogic.notify_at are now optional overrides. The defaults retain the state and emit nothing.

• Breaking change Windowing operators have been moved from bytewax.operators.window into bytewax.operators.windowing.

• Breaking change ClockConfigs have had Config dropped from their name and are just Clocks. E.g. If you previously from bytewax.operators.window import SystemClockConfig now from bytewax.operators.windowing import SystemClock.

• Breaking change WindowConfigs have been renamed to Windowers. E.g. If you previously from bytewax.operators.window import SessionWindow now from bytewax.operators.windowing import SessionWindower.

• Breaking change All windowing operators now return a set of streams {py:obj}~bytewax.operators.windowing.WindowOut. {py:obj}~bytewax.operators.windowing.WindowMetadata now is branched into its own stream and is no longer part of the single downstream. All window operator emitted items are labeled with the unique window ID they came from to facilitate joining the data later.

• Breaking change {py:obj}~bytewax.operators.windowing.fold_window now requires a merge argument. This handles whenever the session

... (truncated)

Commits

• b701a72 Missing link bracket
• 3883634 Merge pull request #471 from bytewax/prep-0.20.1
• ad30824 Add code block captions in the release steps to explain where to make changes
• de02a4c Prep for v0.21.1 release
• 92ed1b2 Merge pull request #470 from bytewax/watermark-fix
• f741ab7 Fix watermark assertion errors with EventClock
• 808ebb6 Bump version to v0.20.0
• 81f1caf Merge pull request #466 from bytewax/prepare_0.20.0
• b877a0b Fix {py:obj} xrefs
• 40fd70a Update docs/guide/reference/migration.md
• Additional commits viewable in compare view

Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting @dependabot rebase.

---

Dependabot commands and options

You can trigger Dependabot actions by commenting on this PR:

• @dependabot rebase will rebase this PR
• @dependabot recreate will recreate this PR, overwriting any edits that have been made to it
• @dependabot merge will merge this PR after your CI passes on it
• @dependabot squash and merge will squash and merge this PR after your CI passes on it
• @dependabot cancel merge will cancel a previously requested merge and block automerging
• @dependabot reopen will reopen this PR if it is closed
• @dependabot close will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually
• @dependabot show <dependency name> ignore conditions will show all of the ignore conditions of the specified dependency
• @dependabot ignore this major version will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this minor version will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this dependency will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself)

[dependabot]

Superseded by #31.