Bytewax Files

Overview

• join_window operator now supports using stream-order via the ordered parameter.

• Windowing operators now correctly respect now_getter and to_system_utc in EventClock.

• Fixes an issue where the runtime would not properly report the correct exception being raised by dataflow code.

• Fixes a bug where window closing will be delayed if using event time and all values for a key fall into a single window and event timestamps are within wait_for_system_duration of each other.

• Fixes a bug where using EventClock on macOS systems would randomly assert.

What's Changed

• Adds documentation about runtime by @davidselassie in https://github.com/bytewax/bytewax/pull/503
• Hash requirements for docs, pin uv by @whoahbot in https://github.com/bytewax/bytewax/pull/505
• Fix typo by @michel-tricot in https://github.com/bytewax/bytewax/pull/506
• Next awake should take into account ordering queue by @davidselassie in https://github.com/bytewax/bytewax/pull/507
• Add operator code snippets by @lfunderburk in https://github.com/bytewax/bytewax/pull/508
• Updating waxctl documentation by @miccioest in https://github.com/bytewax/bytewax/pull/509
• add stateless operator tutorial by @lfunderburk in https://github.com/bytewax/bytewax/pull/512
• fix redistribute example, fix errors in input example by @lfunderburk in https://github.com/bytewax/bytewax/pull/513
• Use raise ... from ... in reraise error handlers by @whoahbot in https://github.com/bytewax/bytewax/pull/510
• Clarify event time table by @davidselassie in https://github.com/bytewax/bytewax/pull/515
• Prevent EventClock's internal system time from going backwards by @davidselassie in https://github.com/bytewax/bytewax/pull/518
• join_window: properly shim EventClock by @wjrtz in https://github.com/bytewax/bytewax/pull/517
• join_window: enable emitting in stream order. by @wjrtz in https://github.com/bytewax/bytewax/pull/519
• Adding kafka dependencies to bytewax installation in docker images by @miccioest in https://github.com/bytewax/bytewax/pull/523
• Windowing operators by @lfunderburk in https://github.com/bytewax/bytewax/pull/514
• Prepare v0.21.1 release by @davidselassie in https://github.com/bytewax/bytewax/pull/525

New Contributors

• @michel-tricot made their first contribution in https://github.com/bytewax/bytewax/pull/506
• @wjrtz made their first contribution in https://github.com/bytewax/bytewax/pull/517

Full Changelog: https://github.com/bytewax/bytewax/compare/v0.21.0...v0.21.1