search

numaproj / numaflow-python

Numaflow Python SDK
Apache License 2.0
52 stars 18 forks source link

feat: add support for new reduce proto #133

Closed kohlisid closed 7 months ago

kohlisid commented 7 months ago

Fixes #1545 1) Add support for new proto specifications 2) Refactor reducer to include task manager

codecov[bot] commented 7 months ago

Codecov Report

Attention: Patch coverage is 97.12230% with 4 lines in your changes are missing coverage. Please review.

Project coverage is 95.24%. Comparing base (882302b) to head (5bfd9ea).

Files Patch % Lines
pynumaflow/reducer/servicer/async_servicer.py 92.00% 0 Missing and 2 partials :warning:
pynumaflow/reducer/servicer/task_manager.py 96.87% 1 Missing and 1 partial :warning:
Additional details and impacted files ```diff @@ Coverage Diff @@ ## main #133 +/- ## ========================================== + Coverage 95.21% 95.24% +0.02% ========================================== Files 45 46 +1 Lines 1442 1513 +71 Branches 81 83 +2 ========================================== + Hits 1373 1441 +68 - Misses 50 51 +1 - Partials 19 21 +2 ```

:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.