Skip to content

Commit 18e3c12

Browse files
committed
removed ListOpenTasks
1 parent fb1d26e commit 18e3c12

File tree

3 files changed

+6
-70
lines changed

3 files changed

+6
-70
lines changed

core/src/main/java/io/temporal/samples/taskinteraction/README.md

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,7 @@ The basic implementation consist on three parts:
77
- Block the workflow execution `Workflow.await` awaiting a Signal.
88
- The workflow will eventually receive a signal that unblocks it.
99

10-
Additionally, the example allows to track task state (PENDING, STARTED, COMPLETED...) and
11-
list open task.
10+
Additionally, the example allows to track task state (PENDING, STARTED, COMPLETED...).
1211

1312
> If the client can not send a Signal to the workflow execution, steps 2 and 3 can be replaced by an activity
1413
that polls using one of [these three strategies](../polling).
@@ -27,18 +26,13 @@ that polls using one of [these three strategies](../polling).
2726
./gradlew -q execute -PmainClass=io.temporal.samples.taskinteraction.client.StartWorkflow
2827
```
2928

30-
- List task
31-
32-
This process will query the workflow execution every 10 seconds, and print open tasks (state != COMPLETED).
33-
```bash
34-
./gradlew -q execute -PmainClass=io.temporal.samples.taskinteraction.client.ListOpenTasks
35-
36-
37-
38-
```
3929
- Update task
4030

4131
Update one of the open task to the next state (PENDING -> STARTED -> COMPLETED)
4232
```bash
43-
./gradlew -q execute -PmainClass=io.temporal.samples.taskinteraction.client.ListOpenTasks
33+
./gradlew -q execute -PmainClass=io.temporal.samples.taskinteraction.client.UpdateTask
4434
```
35+
36+
The workflow has three task, each task has three different states and is created in PENDING state.
37+
You will have to run this class six times to move each task from PENDING to STARTED and to COMPLETED.
38+
Once the last task is completed the workflow completes.

core/src/main/java/io/temporal/samples/taskinteraction/TaskService.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -86,10 +86,6 @@ public R executeTask(Callback<R> callback, String token) {
8686
return promise.get();
8787
}
8888

89-
public List<Task> getOpenTasks() {
90-
return listener.getOpenTasks();
91-
}
92-
9389
public interface Callback<T> {
9490
T execute();
9591
}

core/src/main/java/io/temporal/samples/taskinteraction/client/ListOpenTasks.java

Lines changed: 0 additions & 54 deletions
This file was deleted.

0 commit comments

Comments
 (0)