This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a commit to branch users/damccorm/compactDocs
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/users/damccorm/compactDocs by
this push:
new 79d055a9f2b Update python example
79d055a9f2b is described below
commit 79d055a9f2b4a510e387d03e16be0930dfd7ec0e
Author: Danny McCormick <[email protected]>
AuthorDate: Fri Nov 17 04:12:49 2023 -0800
Update python example
---
sdks/python/apache_beam/examples/snippets/snippets_test.py | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/sdks/python/apache_beam/examples/snippets/snippets_test.py
b/sdks/python/apache_beam/examples/snippets/snippets_test.py
index ec52ca37af3..10d8e255ef0 100644
--- a/sdks/python/apache_beam/examples/snippets/snippets_test.py
+++ b/sdks/python/apache_beam/examples/snippets/snippets_test.py
@@ -1261,6 +1261,10 @@ class CombineTest(unittest.TestCase):
(sum, count) = sum_count
return sum / count if count else float('NaN')
+ def combine(self, accumulator):
+ # No-op
+ return accumulator
+
# [END combine_custom_average_define]
# [START combine_custom_average_execute]
average = pc | beam.CombineGlobally(AverageFn())