numaflow-python
numaflow-python copied to clipboard
numaproj
Numaflow Python SDK
Adds python servicer to address https://github.com/numaproj/numaflow/issues/1688. The main 'issue' with this implementation is that since there are now two functions the servicer needs to be aware of, the `__invoke*` function...
# Summary --- Currently, we are not testing certain flows such as server start for Async in our UT. Need to add these back to coverage and ensure functionality 1)...
# Summary As per Sidhant's [comment](https://github.com/numaproj/numaflow-python/pull/153#discussion_r1558487324). # Use Cases When would you use this? --- **Message from the maintainers**: If you wish to see this enhancement implemented please add a...
# Description _This is probably just me not understanding how things are supposed to work._ I have created a user-defined source, based on the async source example that sets up...
**Describe the bug** Logging handler in a library should be null. It should not define its own handler. **Message from the maintainers**: Impacted by this bug? Give it a 👍....
# Summary What change needs making? # Use Cases When would you use this? --- **Message from the maintainers**: If you wish to see this enhancement implemented please add a...
# Summary The example images are quite large in size, and take a while to build. We should optimize this to reduce both size and build time. Considered solution: Build...
I just tried to get an overview of the server classes fingerprints (`pynumaflow 0.7.0`); | module | class_name | arg_name | arg_type | |--------|------------|----------|----------| | pynumaflow.mapper | MapServer | mapper_instance...
PR to make source streaming in nature. We have removed the sync source from the implementation Refer: https://grpc.io/docs/guides/performance/#python _Streaming RPCs create extra threads for receiving and possibly sending the messages,...