This is an automated email from the ASF dual-hosted git repository.

tvalentyn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new db57e4ae351 [Docs] Add CHANGES entries for Python UnboundedSource and 
Watch (#39579)
db57e4ae351 is described below

commit db57e4ae351bd5169ccf138ccf11a6ad6cc16502
Author: Elia Liu <[email protected]>
AuthorDate: Tue Aug 4 03:16:01 2026 +1000

    [Docs] Add CHANGES entries for Python UnboundedSource and Watch (#39579)
    
    * [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.
    
    * Update CHANGES.md
    
    ---------
    
    Co-authored-by: Yi Hu <[email protected]>
    Co-authored-by: tvalentyn <[email protected]>
---
 CHANGES.md | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/CHANGES.md b/CHANGES.md
index 076413d2043..bda50ac6cd1 100644
--- a/CHANGES.md
+++ b/CHANGES.md
@@ -76,6 +76,10 @@
 * (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 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`, 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)).
 
 ## Breaking Changes

Reply via email to