Skip to content

Commit af19d43

Browse files
chore: update accumulator example with initSourceDelay. (#287)
Signed-off-by: vtiwari5 <[email protected]> Signed-off-by: Vigith Maurice <[email protected]> Co-authored-by: Vigith Maurice <[email protected]>
1 parent cf047af commit af19d43

File tree

1 file changed

+5
-0
lines changed
  • packages/pynumaflow/examples/accumulator/streamsorter

1 file changed

+5
-0
lines changed

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,14 @@ spec:
88
watermark:
99
maxDelay: 5s
1010
idleSource:
11+
# Duration to be added to the current watermark to progress the watermark when source is idling
1112
incrementBy: 1s
13+
# Duration between the subsequent increment of the watermark as long the source remains idle.
1214
stepInterval: 1s
15+
# Duration after which a source is marked as idle due to lack of data. If determined idle then the watermark is progressed by `incrementBy`
1316
threshold: 5s
17+
# 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.
18+
initSourceDelay: 30s
1419
vertices:
1520
- name: http-one
1621
scale:

0 commit comments

Comments
 (0)