numaproj / numaflow-python

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

AsyncIO for Map UDF #58

Closed vigith closed 1 year ago

vigith commented 1 year ago

Summary

Along with procedural python code (blocking), we also need to support asynchronous (asyncio) for Map UDF.

Use Cases

We have seen significant improvement when using asycnio for Reduce code, Map should hence support both blocking and async.


Message from the maintainers:

If you wish to see this enhancement implemented please add a 👍 reaction to this issue! We often sort issues this way to know what to prioritize.

kohlisid commented 1 year ago

Closed by #79