From fd27feb2f4c6abe6424834e043b3e6a0b51b2952 Mon Sep 17 00:00:00 2001 From: Eliaazzz Date: Sun, 2 Aug 2026 13:40:28 +1000 Subject: [PATCH] [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