We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b4ce458 commit 5454ebaCopy full SHA for 5454eba
docs/modules/ROOT/examples/merging/tutorial001.py
@@ -3,7 +3,7 @@
3
4
# imagine we actually have 3 incoming events with 3 records each
5
@stream(merge_events=True)
6
-def task_app(event: StreamTimeEvent, api: Api):
+def app(event: StreamTimeEvent, api: Api):
7
# since we passed merge_events=True all 3 incoming events
8
# and their records will be merged into a single event with 9 records
9
assert len(event.records) == 9 # this will not fail
0 commit comments