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())

Reply via email to