Changes to work with v0.23.1 of service and Java SDK (#11)

* Changed version to 0.19

* Fixed unit test

* Changes to work with v23.1

* Systemexit is back

Author: mfateev

build.gradle

@@ -36,7 +36,7 @@ repositories {
 }
 
 dependencies {
-    compile group: 'io.temporal', name: 'temporal-sdk', version: '0.19.0'
+    compile group: 'io.temporal', name: 'temporal-sdk', version: '0.23.1'
 
     compile group: 'commons-configuration', name: 'commons-configuration', version: '1.9'
     compile group: 'ch.qos.logback', name: 'logback-classic', version: '1.2.3'

src/main/java/io/temporal/samples/bookingsaga/TripBookingSaga.java

@@ -21,6 +21,7 @@
 
 import io.temporal.client.WorkflowClient;
 import io.temporal.client.WorkflowException;
+import io.temporal.client.WorkflowOptions;
 import io.temporal.serviceclient.WorkflowServiceStubs;
 import io.temporal.worker.Worker;
 import io.temporal.worker.WorkerFactory;
@@ -54,15 +55,16 @@ public static void main(String[] args) {
     System.out.println("Worker started for task list: " + TASK_LIST);
 
     // now we can start running instances of our saga - its state will be persisted
-    TripBookingWorkflow trip1 = client.newWorkflowStub(TripBookingWorkflow.class);
+    WorkflowOptions options = WorkflowOptions.newBuilder().setTaskList(TASK_LIST).build();
+    TripBookingWorkflow trip1 = client.newWorkflowStub(TripBookingWorkflow.class, options);
     try {
       trip1.bookTrip("trip1");
     } catch (WorkflowException e) {
       // Expected
     }
 
     try {
-      TripBookingWorkflow trip2 = client.newWorkflowStub(TripBookingWorkflow.class);
+      TripBookingWorkflow trip2 = client.newWorkflowStub(TripBookingWorkflow.class, options);
       trip2.bookTrip("trip2");
     } catch (WorkflowException e) {
       // Expected

src/main/java/io/temporal/samples/bookingsaga/TripBookingWorkflow.java

@@ -19,14 +19,11 @@
 
 package io.temporal.samples.bookingsaga;
 
-import static io.temporal.samples.bookingsaga.TripBookingSaga.TASK_LIST;
-
 import io.temporal.workflow.WorkflowInterface;
 import io.temporal.workflow.WorkflowMethod;
 
 @WorkflowInterface
 public interface TripBookingWorkflow {
-
-  @WorkflowMethod(executionStartToCloseTimeoutSeconds = 3600, taskList = TASK_LIST)
+  @WorkflowMethod
   void bookTrip(String name);
 }

src/main/java/io/temporal/samples/bookingsaga/TripBookingWorkflowImpl.java

@@ -20,6 +20,7 @@
 package io.temporal.samples.bookingsaga;
 
 import io.temporal.activity.ActivityOptions;
+import io.temporal.common.RetryOptions;
 import io.temporal.workflow.ActivityException;
 import io.temporal.workflow.Saga;
 import io.temporal.workflow.Workflow;
@@ -28,7 +29,11 @@
 public class TripBookingWorkflowImpl implements TripBookingWorkflow {
 
   private final ActivityOptions options =
-      ActivityOptions.newBuilder().setScheduleToCloseTimeout(Duration.ofHours(1)).build();
+      ActivityOptions.newBuilder()
+          .setScheduleToCloseTimeout(Duration.ofHours(1))
+          // disable retries for example to run faster
+          .setRetryOptions(RetryOptions.newBuilder().setMaximumAttempts(1).build())
+          .build();
   private final TripBookingActivities activities =
       Workflow.newActivityStub(TripBookingActivities.class, options);
 

src/main/java/io/temporal/samples/common/QueryWorkflowExecution.java

@@ -21,7 +21,7 @@
 
 import io.temporal.client.WorkflowClient;
 import io.temporal.client.WorkflowStub;
-import io.temporal.proto.execution.WorkflowExecution;
+import io.temporal.proto.common.WorkflowExecution;
 import io.temporal.serviceclient.WorkflowServiceStubs;
 import java.util.Optional;
 

src/main/java/io/temporal/samples/fileprocessing/FileProcessingStarter.java

@@ -19,7 +19,10 @@
 
 package io.temporal.samples.fileprocessing;
 
+import static io.temporal.samples.fileprocessing.FileProcessingWorker.TASK_LIST;
+
 import io.temporal.client.WorkflowClient;
+import io.temporal.client.WorkflowOptions;
 import io.temporal.serviceclient.WorkflowServiceStubs;
 import java.net.URL;
 
@@ -31,7 +34,10 @@ public static void main(String[] args) throws Exception {
     WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
     // client that can be used to start and signal workflows
     WorkflowClient client = WorkflowClient.newInstance(service);
-    FileProcessingWorkflow workflow = client.newWorkflowStub(FileProcessingWorkflow.class);
+    FileProcessingWorkflow workflow =
+        client.newWorkflowStub(
+            FileProcessingWorkflow.class,
+            WorkflowOptions.newBuilder().setTaskList(TASK_LIST).build());
 
     System.out.println("Executing FileProcessingWorkflow");
 

src/main/java/io/temporal/samples/fileprocessing/FileProcessingWorkflow.java

@@ -26,10 +26,6 @@
 /** Contract for file processing workflow. */
 @WorkflowInterface
 public interface FileProcessingWorkflow {
-
-  @WorkflowMethod(
-    taskList = FileProcessingWorker.TASK_LIST,
-    executionStartToCloseTimeoutSeconds = 30
-  )
+  @WorkflowMethod
   void processFile(URL source, URL destination);
 }

src/main/java/io/temporal/samples/fileprocessing/FileProcessingWorkflowImpl.java

@@ -24,6 +24,7 @@
 import io.temporal.workflow.Workflow;
 import java.net.URL;
 import java.time.Duration;
+import java.util.Optional;
 
 /**
  * This implementation of FileProcessingWorkflow downloads the file, zips it, and uploads it to a
@@ -51,12 +52,12 @@ public FileProcessingWorkflowImpl() {
   @Override
   public void processFile(URL source, URL destination) {
     RetryOptions retryOptions =
-        RetryOptions.newBuilder()
-            .setExpiration(Duration.ofSeconds(10))
-            .setInitialInterval(Duration.ofSeconds(1))
-            .build();
+        RetryOptions.newBuilder().setInitialInterval(Duration.ofSeconds(1)).build();
     // Retries the whole sequence on any failure, potentially on a different host.
-    Workflow.retry(retryOptions, () -> processFileImpl(source, destination));
+    Workflow.retry(
+        retryOptions,
+        Optional.of(Duration.ofSeconds(10)),
+        () -> processFileImpl(source, destination));
   }
 
   private void processFileImpl(URL source, URL destination) {

src/main/java/io/temporal/samples/hello/HelloActivity.java

@@ -23,6 +23,7 @@
 import io.temporal.activity.ActivityMethod;
 import io.temporal.activity.ActivityOptions;
 import io.temporal.client.WorkflowClient;
+import io.temporal.client.WorkflowOptions;
 import io.temporal.serviceclient.WorkflowServiceStubs;
 import io.temporal.worker.Worker;
 import io.temporal.worker.WorkerFactory;
@@ -43,7 +44,7 @@ public class HelloActivity {
   @WorkflowInterface
   public interface GreetingWorkflow {
     /** @return greeting string */
-    @WorkflowMethod(executionStartToCloseTimeoutSeconds = 10, taskList = TASK_LIST)
+    @WorkflowMethod
     String getGreeting(String name);
   }
 
@@ -100,7 +101,9 @@ public static void main(String[] args) {
 
     // Start a workflow execution. Usually this is done from another program.
     // Uses task list from the GreetingWorkflow @WorkflowMethod annotation.
-    GreetingWorkflow workflow = client.newWorkflowStub(GreetingWorkflow.class);
+    GreetingWorkflow workflow =
+        client.newWorkflowStub(
+            GreetingWorkflow.class, WorkflowOptions.newBuilder().setTaskList(TASK_LIST).build());
     // Execute a workflow waiting for it to complete. See {@link
     // io.temporal.samples.hello.HelloSignal}
     // for an example of starting workflow without waiting synchronously for its result.

src/main/java/io/temporal/samples/hello/HelloActivityRetry.java

@@ -72,7 +72,6 @@ public static class GreetingWorkflowImpl implements GreetingWorkflow {
                 .setRetryOptions(
                     RetryOptions.newBuilder()
                         .setInitialInterval(Duration.ofSeconds(1))
-                        .setExpiration(Duration.ofMinutes(1))
                         .setDoNotRetry(IllegalArgumentException.class)
                         .build())
                 .build());
@@ -122,11 +121,7 @@ public static void main(String[] args) {
     factory.start();
 
     // Get a workflow stub using the same task list the worker uses.
-    WorkflowOptions workflowOptions =
-        WorkflowOptions.newBuilder()
-            .setTaskList(TASK_LIST)
-            .setExecutionStartToCloseTimeout(Duration.ofSeconds(30))
-            .build();
+    WorkflowOptions workflowOptions = WorkflowOptions.newBuilder().setTaskList(TASK_LIST).build();
     GreetingWorkflow workflow = client.newWorkflowStub(GreetingWorkflow.class, workflowOptions);
     // Execute a workflow waiting for it to complete.
     String greeting = workflow.getGreeting("World");