numaflow-python
numaflow-python copied to clipboard
[WIP]feat: add multiproc async
UDS Mode
(venv11) skohli@macos-JQWR9T560R async_multiproc_map % kubectl logs simple-pipeline-mult-0-ssrln -f | head -n 10
+ python example.py
2025-05-21 23:03:15 INFO Async GRPC Server listening on: unix:///var/run/numaflow/multiproc2.sock with max threads: 4
2025-05-21 23:03:15 INFO Async GRPC Server listening on: unix:///var/run/numaflow/multiproc0.sock with max threads: 4
2025-05-21 23:03:15 INFO Async GRPC Server listening on: unix:///var/run/numaflow/multiproc1.sock with max threads: 4
TCP Mode
(venv11) skohli@macos-JQWR9T560R async_multiproc_map % kubectl logs simple-pipeline-mult-0-wi104 -f | head -n 10
+ python example.py
2025-05-21 23:04:44 INFO Async GRPC Server listening on: 0.0.0.0:42285 with max threads: 4
2025-05-21 23:04:44 INFO Async GRPC Server listening on: 0.0.0.0:35685 with max threads: 4
2025-05-21 23:04:44 INFO Async GRPC Server listening on: 0.0.0.0:33085 with max threads: 4
Codecov Report
:x: Patch coverage is 52.94118% with 40 lines in your changes missing coverage. Please review.
:white_check_mark: Project coverage is 92.80%. Comparing base (6ccd49e) to head (62b7a85).
:warning: Report is 28 commits behind head on main.
Additional details and impacted files
@@ Coverage Diff @@
## main #224 +/- ##
==========================================
- Coverage 94.19% 92.80% -1.39%
==========================================
Files 58 59 +1
Lines 2359 2419 +60
Branches 119 124 +5
==========================================
+ Hits 2222 2245 +23
- Misses 100 136 +36
- Partials 37 38 +1
:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.
:rocket: New features to boost your workflow:
- :snowflake: Test Analytics: Detect flaky tests, report on failures, and find test suite problems.