Skip to content

Commit de97159

Browse files
vaibhavtiwari33vtiwari5
authored andcommitted
Update python example with initSourceDelay.
Add description of each item as comment Signed-off-by: vtiwari5 <[email protected]>
1 parent cf047af commit de97159

File tree

1 file changed

+4
-3
lines changed
  • packages/pynumaflow/examples/accumulator/streamsorter

1 file changed

+4
-3
lines changed

packages/pynumaflow/examples/accumulator/streamsorter/pipeline.yaml

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,10 @@ spec:
88
watermark:
99
maxDelay: 5s
1010
idleSource:
11-
incrementBy: 1s
12-
stepInterval: 1s
13-
threshold: 5s
11+
incrementBy: 1s # Duration to be added to the current watermark to progress the watermark when source is idling
12+
stepInterval: 1s # Duration between the subsequent increment of the watermark as long the source remains idle.
13+
threshold: 5s # Duration after which a source is marked as idle due to lack of data. If determined idle then the watermark is progressed by `incrementBy`
14+
initSourceDelay: 30s # Duration after which, if source doesn't produce any data (from the pipeline's inception), the watermark is initialized with the current wall clock time.
1415
vertices:
1516
- name: http-one
1617
scale:

0 commit comments

Comments
 (0)