numaflow
numaflow copied to clipboard
implement source-sink that bypasses ISB
### Tasks
- [ ] https://github.com/numaproj/numaflow/pull/1904
- [ ] https://github.com/numaproj/numaflow/issues/1908
- [ ] emit basic metrics
- [x] lag reader and pending
- [x] integrate with soucer-sinker numaflow-model
- [ ] unit testing