All pull requests

Pull requests

• pynumaflow-lite: Use exception group to report all errors in Sinker

  #384·by BulkBeing was merged Sep 28, 2026Contributor·

  ·
  1

• pynumaflow-lite: Pythonic APIs for mapstreamer

  #383·by BulkBeing was merged Sep 27, 2026Contributor·

  ·
  1

• refactor(pynumaflow-lite): Pythonic APIs for BatchMapper

  #382·by BulkBeing was merged Sep 26, 2026Contributor·

  ·
  2

• feat(pynumaflow-lite): nack option for source/trf/map/sink

  #377·by vigith was merged Sep 16, 2026Member·

  ·
  2

  2

• chore: update the push template for concurrent_sink

  #376·by AdityaSoni19031997 was merged Sep 14, 2026Contributor·

  ·
  1

• pynumaflow-lite: fix double signal handling in map server

  #375·by vigith was merged Sep 13, 2026Member·

  ·

• pynumaflow-lite: Make mapper APIs more Pythonic.

  #374·by BulkBeing was merged Sep 13, 2026Contributor·

  ·
  4

• chore(revert): Pythonic APIs for unary/batchmap/mapstream

  #373·by vigith was merged Sep 11, 2026Member·

  ·
  1

• feat(example): concurrent processing using BatchMapper with BatchMapAsyncServer

  #372·by AdityaSoni19031997 was merged Sep 14, 2026Contributor·

  ·
  13

• feat: introduce API to fail a message in udf/transformer

  #370·by vaibhavtiwari33 was merged Sep 2, 2026Contributor·

  ·
  1

• chore(pynumaflow-lite): Pythonic APIs for unary/batchmap/mapstream

  #368·by BulkBeing was merged Sep 9, 2026Contributor·

  ·
  3

• docs: updated CHANGELOG.md

  #366·by github-actions[bot] was merged Jul 5, 2026Bot·

  ·

• feat: end to end wiring for per message nack

  #365·by ayildirim21 was merged Jul 27, 2026Member·

  ·
  1

  6

• chore: release v0.14.0

  #364·by vaibhavtiwari33 was merged Jul 4, 2026Contributor·

  ·
  10

• pynumaflow-lite: Upgrade dependencies, setup CI

  #362·by BulkBeing was merged Jul 8, 2026Contributor·

  ·
  1

• feat: Port async sourcetransformer to Rust

  #361·by BulkBeing was closed Jun 17, 2026Contributor·Draft·

  ·
  4

• fix: use the closed window in the eof response

  #360·by vaibhavtiwari33 was merged Jun 24, 2026Contributor·

  ·
  9

• feat: allow creating drop message for accumulator

  #358·by vaibhavtiwari33 was merged Sep 23, 2026Contributor·

  ·
  1

  6

• Release 0.13.0

  #355·by BulkBeing was merged Apr 16, 2026Contributor·

  ·
  1

• docs: updated CHANGELOG.md

  #354·by github-actions[bot] was merged Jun 18, 2026Bot·

  ·

• chore: 0.12.2 release preparation

  #353·by BulkBeing was merged Apr 16, 2026Contributor·

  ·
  1

• fix: Avoid event loop starvation if user has tight loops in streaming UDFs

  #352·by BulkBeing was merged Apr 14, 2026Contributor·

  ·
  1

  1

• docs: refine pynumaflow README

  #351·by kohlisid was merged Apr 10, 2026Contributor·

  ·
  8

• fix: Avoid UDF call in map streaming from starving eventloop

  #349·by BulkBeing was merged Apr 6, 2026Contributor·

  ·
  1

  9

• chore: linting and static checks for pynumaflow-lite

  #346·by vaibhavtiwari33 was merged Mar 29, 2026Contributor·

  ·
  7