This is an automated email from the ASF dual-hosted git repository. damccorm pushed a commit to branch users/damccorm/flatten-docs in repository https://gitbox.apache.org/repos/asf/beam.git
commit 62969b28b80cad5070ca6e8c66d953562f587c34 Author: Danny McCormick <[email protected]> AuthorDate: Tue Oct 24 13:00:55 2023 -0400 Fix flatten docs --- learning/katas/python/Core Transforms/Flatten/Flatten/task.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/learning/katas/python/Core Transforms/Flatten/Flatten/task.py b/learning/katas/python/Core Transforms/Flatten/Flatten/task.py index ae0f5c81d95..5547fb793e0 100644 --- a/learning/katas/python/Core Transforms/Flatten/Flatten/task.py +++ b/learning/katas/python/Core Transforms/Flatten/Flatten/task.py @@ -18,7 +18,7 @@ # name: Flatten # description: Task from katas that merges two PCollections of words into a single PCollection. # multifile: false -# context_line: 31 +# context_line: 32 # categories: # - Flatten # complexity: BASIC @@ -26,6 +26,7 @@ # - merge # - strings +# [START flatten] import apache_beam as beam with beam.Pipeline() as p: @@ -39,3 +40,4 @@ with beam.Pipeline() as p: ((wordsStartingWithA, wordsStartingWithB) | beam.Flatten() | beam.LogElements()) + # [END flatten]
