workflow timeout and update

Author: dandavison

core/src/main/java/io/temporal/samples/workflowtimeout/Makefile

@@ -0,0 +1,9 @@
+worker:
+	ls *.java | entr -r \
+		sh -c 'cd $$(git rev-parse --show-toplevel) && ./gradlew -q execute -P mainClass=io.temporal.samples.basic.MyWorker'
+
+run:
+	cd $$(git rev-parse --show-toplevel) && \
+	./gradlew -q execute -P mainClass=io.temporal.samples.basic.MyStarter
+
+.PHONY: run worker

core/src/main/java/io/temporal/samples/workflowtimeout/MyActivity.java

@@ -0,0 +1,11 @@
+package io.temporal.samples.basic;
+
+import io.temporal.activity.ActivityInterface;
+import io.temporal.activity.ActivityMethod;
+
+@ActivityInterface
+public interface MyActivity {
+
+  @ActivityMethod
+  int myActivityMethod();
+}

core/src/main/java/io/temporal/samples/workflowtimeout/MyActivityImpl.java

@@ -0,0 +1,8 @@
+package io.temporal.samples.basic;
+
+public class MyActivityImpl implements MyActivity {
+  @Override
+  public int myActivityMethod() {
+    return 7;
+  }
+}

core/src/main/java/io/temporal/samples/workflowtimeout/MyStarter.java

@@ -0,0 +1,38 @@
+package io.temporal.samples.basic;
+
+import io.temporal.api.enums.v1.WorkflowIdConflictPolicy;
+import io.temporal.client.WorkflowClient;
+import io.temporal.client.WorkflowOptions;
+import io.temporal.serviceclient.WorkflowServiceStubs;
+
+public class MyStarter {
+
+  static final String WORKFLOW_ID = "wid";
+
+  public static void main(String[] args) throws Exception {
+
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
+
+    WorkflowClient client = WorkflowClient.newInstance(service);
+
+    WorkflowOptions workflowOptions =
+        WorkflowOptions.newBuilder()
+            .setTaskQueue(MyWorker.TASK_QUEUE)
+            .setWorkflowId(WORKFLOW_ID)
+            .setWorkflowIdConflictPolicy(
+                WorkflowIdConflictPolicy.WORKFLOW_ID_CONFLICT_POLICY_TERMINATE_EXISTING)
+            .setWorkflowExecutionTimeout(java.time.Duration.ofSeconds(2))
+            .build();
+    MyWorkflow workflow = client.newWorkflowStub(MyWorkflow.class, workflowOptions);
+
+    WorkflowClient.start(workflow::run);
+
+    int upResult = workflow.myUpdate();
+    System.out.println("upResult: " + upResult);
+
+    int wfResult = workflow.run();
+    System.out.println("wfResult: " + wfResult);
+
+    System.exit(0);
+  }
+}

core/src/main/java/io/temporal/samples/workflowtimeout/MyWorker.java

@@ -0,0 +1,23 @@
+package io.temporal.samples.basic;
+
+import io.temporal.client.WorkflowClient;
+import io.temporal.serviceclient.WorkflowServiceStubs;
+import io.temporal.worker.Worker;
+import io.temporal.worker.WorkerFactory;
+
+public class MyWorker {
+  static final String TASK_QUEUE = "tq";
+
+  public static void main(String[] args) throws Exception {
+
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
+
+    WorkflowClient client = WorkflowClient.newInstance(service);
+
+    WorkerFactory factory = WorkerFactory.newInstance(client);
+    Worker worker = factory.newWorker(TASK_QUEUE);
+    worker.registerWorkflowImplementationTypes(MyWorkflowImpl.class);
+    worker.registerActivitiesImplementations(new MyActivityImpl());
+    factory.start();
+  }
+}

core/src/main/java/io/temporal/samples/workflowtimeout/MyWorkflow.java

@@ -0,0 +1,14 @@
+package io.temporal.samples.basic;
+
+import io.temporal.workflow.UpdateMethod;
+import io.temporal.workflow.WorkflowInterface;
+import io.temporal.workflow.WorkflowMethod;
+
+@WorkflowInterface
+public interface MyWorkflow {
+  @WorkflowMethod
+  int run();
+
+  @UpdateMethod
+  int myUpdate();
+}

core/src/main/java/io/temporal/samples/workflowtimeout/MyWorkflowImpl.java

@@ -0,0 +1,34 @@
+package io.temporal.samples.basic;
+
+import io.temporal.activity.ActivityOptions;
+import io.temporal.common.RetryOptions;
+import io.temporal.workflow.Workflow;
+import java.time.Duration;
+
+public class MyWorkflowImpl implements MyWorkflow {
+
+  private final MyActivity activity =
+      Workflow.newActivityStub(
+          MyActivity.class,
+          ActivityOptions.newBuilder()
+              .setStartToCloseTimeout(Duration.ofSeconds(2))
+              .setRetryOptions(RetryOptions.newBuilder().setMaximumAttempts(1).build())
+              .build());
+
+  //  private boolean done;
+
+  @Override
+  public int run() {
+    Workflow.sleep(Duration.ofSeconds(3));
+    // Workflow.await(() -> done);
+    return 8;
+  }
+
+  @Override
+  public int myUpdate() {
+    Workflow.sleep(Duration.ofSeconds(2));
+    int result = activity.myActivityMethod();
+    //  done = true;
+    return result;
+  }
+}