numaproj/numaflow-python issues and pull requests

#103 - Python SDK Changes

Issue - State: closed - Opened by yhl25 over 1 year ago

#102 - feat: Add side input functionality

Pull Request - State: closed - Opened by kohlisid over 1 year ago - 2 comments

#101 - chore: set default max gRPC msg size to 64 MB

Pull Request - State: closed - Opened by whynowy over 1 year ago - 1 comment

#100 - chore: add instructions on building multi-platform images

Pull Request - State: closed - Opened by KeranYang over 1 year ago - 1 comment

#99 - Update flatmap stream sdk version dependency

Pull Request - State: closed - Opened by xdevxy over 1 year ago

#98 - chore: bump version to '0.4.2'

Pull Request - State: closed - Opened by xdevxy over 1 year ago - 1 comment

#97 - chore: improve udsink dtypes

Pull Request - State: closed - Opened by ab93 over 1 year ago - 1 comment
Labels: documentation, chore

#96 - feat!: support len, iter and indexing on udf datatypes

Pull Request - State: closed - Opened by ab93 over 1 year ago - 1 comment
Labels: enhancement

#95 - chore: add map stream udf example

Pull Request - State: closed - Opened by xdevxy over 1 year ago - 3 comments

#94 - chore: use ruff for linting; add precommit conf

Pull Request - State: closed - Opened by ab93 over 1 year ago - 1 comment
Labels: documentation, chore

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

Pull Request - State: closed - Opened by xdevxy over 1 year ago - 1 comment

#92 - fix: update event time filter transformer to use tag

Pull Request - State: closed - Opened by KeranYang over 1 year ago - 1 comment

#91 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] over 1 year ago - 1 comment

#90 - chore: bump version to 0.4.1

Pull Request - State: closed - Opened by ab93 over 1 year ago - 1 comment
Labels: chore

#89 - feat: introduce handshake to client and gRPC server

Pull Request - State: closed - Opened by kohlisid over 1 year ago - 1 comment

#88 - chore: graceful grpc error handling

Pull Request - State: closed - Opened by ashwinidulams over 1 year ago - 4 comments

#87 - Raising error does not increase the num_delivered, and the server keep retrying the same message

Issue - State: closed - Opened by sandangel over 1 year ago - 10 comments
Labels: bug

#86 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] over 1 year ago

#85 - chore!: remove support for py3.8; add 3.11

Pull Request - State: closed - Opened by ab93 over 1 year ago - 1 comment

#84 - use env vars provided by Numaflow to compute available CPU and MEM

Issue - State: closed - Opened by vigith over 1 year ago
Labels: enhancement

#83 - chore: fix MessageT constructor

Pull Request - State: closed - Opened by yhl25 over 1 year ago - 1 comment

#82 - chore: rename sync_server to server

Pull Request - State: closed - Opened by vigith over 1 year ago

#81 - chore: refactor into server classes

Pull Request - State: closed - Opened by kohlisid over 1 year ago - 1 comment

#80 - chore: refactoring sync and async servers

Pull Request - State: closed - Opened by ashwinidulams over 1 year ago - 2 comments

#79 - chore: Class refactor

Pull Request - State: closed - Opened by kohlisid over 1 year ago - 1 comment

#78 - doc: explain how to use datum metadata.

Pull Request - State: closed - Opened by xdevxy over 1 year ago - 1 comment

#77 - feat: Add ID and numDelivered fields to Datum in udf

Pull Request - State: closed - Opened by xdevxy over 1 year ago - 4 comments

#76 - feat: introducing tags for conditional forwarding

Pull Request - State: closed - Opened by yhl25 over 1 year ago - 1 comment

#75 - fix: doc typo fix

Pull Request - State: closed - Opened by vigith over 1 year ago - 1 comment

#74 - chore: convert keys to list

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#73 - feat: add multiprocessing support for Map

Pull Request - State: closed - Opened by kohlisid over 1 year ago - 1 comment

#72 - feat: support for multi keys

Pull Request - State: closed - Opened by yhl25 over 1 year ago - 1 comment

#71 - chore: re-raise UDFError instead of dropping messages

Pull Request - State: closed - Opened by KeranYang over 1 year ago - 1 comment

#70 - AsyncIO for MapT Transformer

Issue - State: open - Opened by whynowy over 1 year ago
Labels: enhancement

#69 - fix: stream to stdout stderr based on log level

Pull Request - State: closed - Opened by sandangel over 1 year ago - 1 comment

#68 - Raising crash error in map fn will result in message drop

Issue - State: closed - Opened by sandangel over 1 year ago - 4 comments
Labels: bug

#67 - refactor: make default constructor private for Message/MessageT

Pull Request - State: closed - Opened by KeranYang over 1 year ago - 5 comments

#66 - fix: store strong references of task objects

Pull Request - State: closed - Opened by kohlisid over 1 year ago - 2 comments

#65 - chore: add named parameters to UDF call

Pull Request - State: closed - Opened by kohlisid over 1 year ago - 1 comment

#64 - feat: add mapt sdk support

Pull Request - State: closed - Opened by KeranYang over 1 year ago - 1 comment

#63 - Async reduce UDF returns Runtime error for asynchronous generator

Issue - State: closed - Opened by kohlisid over 1 year ago
Labels: bug

#62 - chore: allow protobuf 3.20 and above

Pull Request - State: closed - Opened by ab93 over 1 year ago - 1 comment
Labels: chore

#61 - docs: examples for asyncio with ThreadPoolExecutor and ProcessPoolExecutor

Pull Request - State: closed - Opened by kohlisid over 1 year ago - 1 comment

#60 - docs: examples for asyncio with ThreadPoolExecutor and ProcessPoolExecutor

Pull Request - State: closed - Opened by kohlisid over 1 year ago - 1 comment

#59 - AsyncIO for UDSink

Issue - State: closed - Opened by vigith over 1 year ago - 2 comments
Labels: enhancement

#58 - AsyncIO for Map UDF

Issue - State: closed - Opened by vigith over 1 year ago - 1 comment
Labels: enhancement

#57 - feat: add sdk support for mapt functionality

Pull Request - State: closed - Opened by KeranYang over 1 year ago - 1 comment

#56 - chore: update protobuf version

Pull Request - State: closed - Opened by sandangel over 1 year ago - 4 comments

#55 - feat: bidirectional streaming for reduce

Pull Request - State: closed - Opened by yhl25 almost 2 years ago - 1 comment

#54 - feat: examples for asyncio with ThreadPoolExecutor and ProcessPoolExecutor

Pull Request - State: closed - Opened by kohlisid almost 2 years ago - 3 comments

#53 - numaflow-python changes to support gRPC bidirectional streaming for reduce

Issue - State: closed - Opened by yhl25 almost 2 years ago
Labels: enhancement, gRPC, area/reduce

#52 - Documentation: examples for asyncio with ThreadPoolExecutor and ProcessPoolExecutor

Issue - State: closed - Opened by ashwinidulams almost 2 years ago
Labels: documentation, good first issue

#51 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] almost 2 years ago

#50 - chore: aiorun to manage lifecycle of ayncio processes

Pull Request - State: closed - Opened by ashwinidulams almost 2 years ago - 1 comment

#49 - feat: reduce stream per window using asyncio

Pull Request - State: closed - Opened by ashwinidulams almost 2 years ago - 1 comment
Labels: performance

#48 - Document developer guide

Issue - State: closed - Opened by vigith almost 2 years ago - 1 comment
Labels: documentation, good first issue

#47 - perf: improve performance by adding slots

Pull Request - State: closed - Opened by ab93 almost 2 years ago - 3 comments
Labels: performance

#46 - chore: update example pynumaflow version

Pull Request - State: closed - Opened by jy4096 almost 2 years ago - 1 comment

#45 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] almost 2 years ago

#44 - fix: time unit bug/dockerfile/add a guide

Pull Request - State: closed - Opened by jy4096 almost 2 years ago - 1 comment

#43 - chore: update example 0.3.1

Pull Request - State: closed - Opened by jy4096 almost 2 years ago - 1 comment

#42 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] almost 2 years ago

#41 - chore: bump version to v0.3.1

Pull Request - State: closed - Opened by ab93 almost 2 years ago - 1 comment
Labels: chore

#40 - feat: udf reduce

Pull Request - State: closed - Opened by jy4096 almost 2 years ago - 1 comment

#39 - chore: update examples

Pull Request - State: closed - Opened by jy4096 almost 2 years ago - 1 comment

#38 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] almost 2 years ago

#37 - chore: bump version to v0.3

Pull Request - State: closed - Opened by ab93 almost 2 years ago - 1 comment
Labels: chore

#36 - chore: bump version to v0.2.7

Pull Request - State: closed - Opened by ab93 almost 2 years ago - 3 comments
Labels: chore

#35 - fix: .flake8 file

Pull Request - State: closed - Opened by ab93 almost 2 years ago - 1 comment
Labels: bug

#34 - feat: udsink gRPC stream

Pull Request - State: closed - Opened by jy4096 almost 2 years ago - 3 comments

#33 - chore: update the pynumaflow version in the examples.

Pull Request - State: closed - Opened by vigith almost 2 years ago

#32 - UDF Failed to execute health check for long running task

Issue - State: closed - Opened by alexanghh almost 2 years ago - 5 comments
Labels: bug

#31 - Support for async UDFs for Map

Issue - State: closed - Opened by ab93 almost 2 years ago - 1 comment
Labels: bug

#30 - docs: update udf and udsink links in README.md

Pull Request - State: closed - Opened by dseapy about 2 years ago

#29 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] about 2 years ago

#28 - chore: bump version to v0.2.6

Pull Request - State: closed - Opened by ab93 about 2 years ago - 1 comment
Labels: chore

#27 - feat: introduces sync gRPC server

Pull Request - State: closed - Opened by ab93 about 2 years ago - 2 comments
Labels: enhancement, performance

#26 - chore: debug logs

Pull Request - State: closed - Opened by nkoppisetty about 2 years ago

#25 - 20x hit in performance after using gRPC python SDK

Issue - State: closed - Opened by vigith about 2 years ago
Labels: bug, performance

#24 - Decorators for simple message forwarding

Issue - State: closed - Opened by ab93 about 2 years ago - 1 comment
Labels: enhancement

#23 - feat: add support to configure max message size

Pull Request - State: closed - Opened by jy4096 about 2 years ago - 1 comment

#22 - docs: updated CHANGELOG.md

Pull Request - State: closed - Opened by github-actions[bot] about 2 years ago

#21 - chore: bump version to v0.2.5

Pull Request - State: closed - Opened by ab93 about 2 years ago - 1 comment

#20 - Add badges in readme

Issue - State: closed - Opened by ab93 about 2 years ago
Labels: chore

#19 - chore: add auto changelog generation

Pull Request - State: closed - Opened by ab93 about 2 years ago - 1 comment

#18 - fix: catch exception in udf and udsink

Pull Request - State: closed - Opened by ab93 about 2 years ago - 1 comment

#17 - chore: remove unwanted dependencies

Pull Request - State: closed - Opened by ab93 about 2 years ago - 1 comment

#16 - wrap the handlers using try/catch

Issue - State: closed - Opened by vigith about 2 years ago
Labels: enhancement, good first issue

#15 - chore: flatmap and simple udsink examples push to quay

Pull Request - State: closed - Opened by whynowy about 2 years ago - 1 comment

#14 - Add changelog generator workflow

Issue - State: closed - Opened by ab93 about 2 years ago
Labels: enhancement

#13 - chore: bump version to 0.2.4

Pull Request - State: closed - Opened by ab93 about 2 years ago - 1 comment

#12 - update function socket

Pull Request - State: closed - Opened by cosmic-chichu about 2 years ago - 1 comment

#11 - Python sdk gRPC health check failure

Issue - State: closed - Opened by cosmic-chichu about 2 years ago - 1 comment
Labels: bug

#10 - doc: update UDSink

Pull Request - State: closed - Opened by vigith about 2 years ago - 1 comment

#9 - chore: add linting workflow

Pull Request - State: closed - Opened by ab93 about 2 years ago - 1 comment

#8 - Set up linting in workflow

Issue - State: closed - Opened by ab93 about 2 years ago

#7 - Set up auto pypi publish

Issue - State: closed - Opened by ab93 about 2 years ago

#6 - fix: unix domain socket path and examples

Pull Request - State: closed - Opened by jy4096 about 2 years ago - 1 comment

#5 - feature: udsink gRPC

Pull Request - State: closed - Opened by jy4096 about 2 years ago - 1 comment

#4 - feature: gRPC

Pull Request - State: closed - Opened by jy4096 about 2 years ago - 8 comments

GitHub / numaproj/numaflow-python issues and pull requests