You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: batch_sliding_window/README.md
+3-3Lines changed: 3 additions & 3 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -10,12 +10,12 @@ A single instance of `SlidingWindowWorkflow` has limited window size and through
10
10
11
11
### Running This Sample
12
12
13
-
To run, first see [README.md](../README.md) for prerequisites. Then, run the following from this directory to start the worker:
13
+
To run, first see [README.md](../README.md) for prerequisites. Then, run the following from root directory to start the worker:
14
14
15
-
uv run worker.py
15
+
uv run batch_sliding_window/worker.py
16
16
17
17
This will start the worker. Then, in another terminal, run the following to execute the workflow:
18
18
19
-
uv run starter.py
19
+
uv run batch_sliding_window/starter.py
20
20
21
21
The workflow will process 90 records using a sliding window of 10 parallel workers across 3 partitions, with a page size of 5 records per continue-as-new iteration.
0 commit comments