numaproj/numaflow-python

Issues

• Class based approach for passing the handler

  #106 opened 8 months ago by vigith
  0

• User Defined Async Source - "Readiness probe failed" when there are no more messages

  #128 opened 9 months ago by tolmanam
  5

• Multiprocess server does not load-balance correctly

  #111 opened 9 months ago by ab93
  2

• Need to finish implementing Sourcer async_server support

  #119 opened 10 months ago by tolmanam
  8

• Improve testing coverage for SDK

  #121 opened 10 months ago by kohlisid
  0

• AttributeError: module 'pynumaflow.sourcer.proto.source_pb2_grpc' has no attribute 'add_sourceServicer_to_server'

  #117 opened 10 months ago by tolmanam
  0

• Support Python 3.12

  #113 opened a year ago by ab93
  0

• Python SDK Changes

  #103 opened a year ago by yhl25
  0

• Raising error does not increase the num_delivered, and the server keep retrying the same message

  #87 opened a year ago by sandangel
  10

• Add badges in readme

  #20 opened a year ago by ab93
  0

• use env vars provided by Numaflow to compute available CPU and MEM

  #84 opened a year ago by vigith
  0

• Support for async UDFs for Map

  #31 opened a year ago by ab93
  1

• Document developer guide

  #48 opened a year ago by vigith
  1

• Decorators for simple message forwarding

  #24 opened a year ago by ab93
  1

• UDF Failed to execute health check for long running task

  #32 opened a year ago by alexanghh
  5

• AsyncIO for UDSink

  #59 opened a year ago by vigith
  2

• AsyncIO for Map UDF

  #58 opened a year ago by vigith
  1

• Raising crash error in map fn will result in message drop

  #68 opened a year ago by sandangel
  4

• AsyncIO for MapT Transformer

  #70 opened a year ago by whynowy
  0

• Async reduce UDF returns Runtime error for asynchronous generator

  #63 opened a year ago by kohlisid
  0

• numaflow-python changes to support gRPC bidirectional streaming for reduce

  #53 opened 2 years ago by yhl25
  0

• Documentation: examples for asyncio with ThreadPoolExecutor and ProcessPoolExecutor

  #52 opened 2 years ago by ashwinidulams
  0

• 20x hit in performance after using gRPC python SDK

  #25 opened 2 years ago by vigith
  0

• Python sdk gRPC health check failure

  #11 opened 2 years ago by cosmic-chichu
  1

• wrap the handlers using try/catch

  #16 opened 2 years ago by vigith
  0

• Add changelog generator workflow

  #14 opened 2 years ago by ab93
  0

• Set up auto pypi publish

  #7 opened 2 years ago by ab93
  0

• Set up linting in workflow

  #8 opened 2 years ago by ab93
  0