numaflow-rs

numaflow-rs copied to clipboard

- [x] sink - [x] map - [x] reduce - [x] source - [x] source transformer - [x] batch map - [ ] session window - [ ] reduce streaming

yhl25

yhl25

While adding a new PR, we should have a workflow which builds the SDK image without **pushing** This will help to ensure that all builds are consistent

kohlisid

Generate code coverage for unit tests and upload to codecov.

whynowy

yhl25

yhl25

yhl25

We currently panic in multiple places; ideally, we should propagate the error back to the client before panicking.

yhl25

Do we really need the Drop semantics for Rust because Rust has Option?

vigith

yhl25