Overview

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

• Windowing operators now correctly respectnow_getter and
  to_system_utc inEventClock.

• 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 withinwait_for_system_duration of each other.

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

What's Changed

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

New Contributors

• @michel-tricot made their first contribution in#506
• @wjrtz made their first contribution in#517

Full Changelog:v0.21.0...v0.21.1

Contributors