numaflow-python

numaflow-python copied to clipboard

vigith

feat: add udstore and response-serve

1

Kindly explain what this PR does.

kohlisid

Graceful shutdown of gRPC servers when there are exceptions in the User Code

7

on returning exception from executor layer in the sync servers in some of the cases we were updating the gRPC context with errors with parallel running thread even after we...

kohlisid

Component Testing for Python SDK

5

# Summary Test Kit for users to write unit testing, e.g., [Java's Map Test Kit](https://github.com/numaproj/numaflow-java/blob/main/src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java). # Use Cases Component testing for Python SDK users. --- **Message from the maintainers**: If...

vigith

DON'T MERGE: test

1

Kindly explain what this PR does.

kohlisid

# Summary While creating a PR we should a CI workflow for building example images without pushing. This will ensure no regression

kohlisid

We need to make sure it is available for all the components

vigith

documentation for pynumaflow-lite

3

vigith

integrate - CI for running tests

3

vigith

[WIP]feat: add multiproc async

1

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:...

kohlisid