search

numaproj / numaflow-python

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

feat: introduce `MapStreamFn` for streaming map udf in async sever #93

Closed xdevxy closed 1 year ago

codecov[bot] commented 1 year ago

Codecov Report

Merging #93 (0be40b6) into main (e642cec) will decrease coverage by 0.18%. The diff coverage is 93.93%.

@@            Coverage Diff             @@
##             main      #93      +/-   ##
==========================================
- Coverage   97.22%   97.04%   -0.18%     
==========================================
  Files          16       16              
  Lines         721      745      +24     
  Branches       45       47       +2     
==========================================
+ Hits          701      723      +22     
  Misses         10       10              
- Partials       10       12       +2
Impacted Files Coverage Δ
pynumaflow/function/async_server.py 96.45% <86.66%> (-1.23%) :arrow_down:
pynumaflow/function/multiproc_server.py 97.59% <100.00%> (+0.18%) :arrow_up:
pynumaflow/function/server.py 97.46% <100.00%> (+0.20%) :arrow_up:

:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more