You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2019/06/23 13:56:08 UTC
[beam] branch master updated: Add to docstring of
advance_watermark_to_infinity
This is an automated email from the ASF dual-hosted git repository.
pabloem 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 a2aa4b9 Add to docstring of advance_watermark_to_infinity
new b4093ad Merge pull request #8922 from ttanay/adv_watermark_docstring
a2aa4b9 is described below
commit a2aa4b9215cbbee2185c252a43341c5f0b1f7809
Author: ttanay <tt...@gmail.com>
AuthorDate: Fri Jun 21 15:43:07 2019 +0530
Add to docstring of advance_watermark_to_infinity
---
sdks/python/apache_beam/testing/test_stream.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/testing/test_stream.py b/sdks/python/apache_beam/testing/test_stream.py
index dc01a99..a5e9574 100644
--- a/sdks/python/apache_beam/testing/test_stream.py
+++ b/sdks/python/apache_beam/testing/test_stream.py
@@ -194,7 +194,7 @@ class TestStream(PTransform):
return self
def advance_watermark_to_infinity(self):
- """Advance the watermark to the end of time."""
+ """Advance the watermark to the end of time, completing this TestStream."""
self.advance_watermark_to(timestamp.MAX_TIMESTAMP)
return self