From fd27feb2f4c6abe6424834e043b3e6a0b51b2952 Mon Sep 17 00:00:00 2001 From: Eliaazzz Date: Sun, 2 Aug 2026 13:40:28 +1000 Subject: [PATCH 1/2] [Docs] Add CHANGES entries for Python UnboundedSource and Watch Both landed after the 2.75.0 branch was cut and are absent from release-2.75, so they belong to 2.76.0. --- CHANGES.md | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/CHANGES.md b/CHANGES.md index d853314a0ad3..039698405e58 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -76,6 +76,12 @@ * (Python) Added `equal_to_approx`, an `assert_that` matcher that compares numeric pipeline outputs with a configurable tolerance ([#18028](https://github.com/apache/beam/issues/18028)). * (Python) `Timestamp` now supports variable subsecond precision, up to nanoseconds. The portable `beam:logical_type:timestamp:v1` logical type now maps to Python's `Timestamp` ([#39344](https://github.com/apache/beam/issues/39344)). +* (Python) Added `UnboundedSource`, an experimental interface for reading an infinite stream of records + with checkpointing, watermark reporting, and bundle finalization. Read one with `beam.io.Read` + ([#19137](https://github.com/apache/beam/issues/19137)). +* (Python) Added `Watch`, an experimental transform that polls a growing set of outputs for each input + element, deduplicates outputs across poll rounds, and stops per a user-supplied termination condition + ([#21521](https://github.com/apache/beam/issues/21521)). * X feature added (Java/Python) ([#X](https://github.com/apache/beam/issues/X)). ## Breaking Changes From db863cc2a874c53903902a2678328591aea8b9ee Mon Sep 17 00:00:00 2001 From: tvalentyn Date: Mon, 3 Aug 2026 10:15:32 -0700 Subject: [PATCH 2/2] Update CHANGES.md --- CHANGES.md | 1 - 1 file changed, 1 deletion(-) diff --git a/CHANGES.md b/CHANGES.md index 264b5a4a8ec8..bda50ac6cd18 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -81,7 +81,6 @@ * (Python) Added `Watch`, a transform that polls a growing set of outputs for each input element, deduplicates outputs across poll rounds, and stops per a user-supplied termination condition ([#21521](https://github.com/apache/beam/issues/21521)). * (Python) Added support to analyze core dumps created after python worker segmentation faults with `pystack` (or `gdb` if installed) using the `--profiler_agent=coredump` pipeline option. ([#39484](https://github.com/apache/beam/issues/39484)). -* X feature added (Java/Python) ([#X](https://github.com/apache/beam/issues/X)). ## Breaking Changes