Merge pull request #166 from orkes-io/fix_examples

Example Fixes

build.gradle

@@ -27,7 +27,7 @@ ext {
             spectator       : '1.3.7',
             awsSsm          : '1.12.300',
             azureSsm        : '4.2.3',
-            azureIdentity   : '1.3.7',
+            azureIdentity   : '1.12.2',
             eureka          : '1.10.17',
             wiremock        : '2.33.2',
             ioGRPC          : '1.63.1',
@@ -251,5 +251,5 @@ signing {
 tasks.withType(Test)  {
     maxParallelForks = 1
 }
-sourceSets.main.java.srcDirs += ['example/java', 'example/resources']
+//sourceSets.main.java.srcDirs += ['examples/java', 'examples/resources']
 

docs/workflow/README.md

@@ -110,7 +110,7 @@ public class ConductorWorkers {
 }
 ```
 
-See [DynamicWorkflow](../../examples/java/io/orkes/conductor/sdk/DynamicWorkflow) for a fully functional example.
+See [DynamicWorkflow](../../examples/java/io/orkes/conductor/sdk/dynamicworkflow) for a fully functional example.
 
 ### Kitchen-Sink Workflow
 

examples/java/io/orkes/conductor/sdk/AbstractWorkflowTests.java → examples/java/io/orkes/conductor/sdk/examples/AbstractWorkflowTests.java

@@ -10,30 +10,31 @@
  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package io.orkes.conductor.sdk;
+package io.orkes.conductor.sdk.examples;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import com.netflix.conductor.common.config.ObjectMapperProvider;
 import com.netflix.conductor.common.metadata.tasks.TaskResult;
 import com.netflix.conductor.common.metadata.tasks.TaskType;
 import com.netflix.conductor.common.metadata.workflow.WorkflowDef;
 import com.netflix.conductor.common.metadata.workflow.WorkflowTask;
 import com.netflix.conductor.common.run.Workflow;
+import com.netflix.conductor.common.run.WorkflowTestRequest;
+
 import io.orkes.conductor.client.ApiClient;
 import io.orkes.conductor.client.MetadataClient;
 import io.orkes.conductor.client.OrkesClients;
 import io.orkes.conductor.client.WorkflowClient;
-import io.orkes.conductor.client.model.WorkflowTestRequest;
 
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
 
 
 
@@ -135,4 +136,3 @@ protected Map<String, List<WorkflowTestRequest.TaskMock>> getTestInputs(String p
 
 
     }
-

examples/java/io/orkes/conductor/sdk/ApiUtil.java → examples/java/io/orkes/conductor/sdk/examples/ApiUtil.java

@@ -10,7 +10,7 @@
  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package io.orkes.conductor.sdk;
+package io.orkes.conductor.sdk.examples;
 
 import io.orkes.conductor.client.ApiClient;
 import io.orkes.conductor.client.OrkesClients;

examples/java/io/orkes/conductor/sdk/AuthorizationManagement.java → examples/java/io/orkes/conductor/sdk/examples/AuthorizationManagement.java

@@ -10,18 +10,14 @@
  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package io.orkes.conductor.sdk;
+package io.orkes.conductor.sdk.examples;
 
 import java.util.Arrays;
 import java.util.UUID;
 
 import io.orkes.conductor.client.AuthorizationClient;
 import io.orkes.conductor.client.OrkesClients;
-import io.orkes.conductor.client.model.AuthorizationRequest;
-import io.orkes.conductor.client.model.SubjectRef;
-import io.orkes.conductor.client.model.TargetRef;
-import io.orkes.conductor.client.model.UpsertGroupRequest;
-import io.orkes.conductor.client.model.UpsertUserRequest;
+import io.orkes.conductor.client.model.*;
 
 /**
  * Examples for managing user authorization in Orkes Conductor

examples/java/io/orkes/conductor/sdk/KitchenSink.java → examples/java/io/orkes/conductor/sdk/examples/KitchenSink.java

@@ -1,17 +1,28 @@
-package io.orkes.conductor.sdk;
+/*
+ * Copyright 2024 Orkes, Inc.
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package io.orkes.conductor.sdk.examples;
+
+import java.time.Duration;
 
 import com.netflix.conductor.sdk.workflow.def.ConductorWorkflow;
 import com.netflix.conductor.sdk.workflow.def.tasks.*;
 import com.netflix.conductor.sdk.workflow.executor.WorkflowExecutor;
-import com.netflix.conductor.sdk.workflow.def.tasks.JQ;
-
 
-
-import java.time.Duration;
+import io.orkes.conductor.sdk.examples.helloworld.workflow.WorkflowInput;
 
 public class KitchenSink {
     private final WorkflowExecutor executor;
-    public GreetingsWorkflow(WorkflowExecutor executor) {
+    public KitchenSink(WorkflowExecutor executor) {
         this.executor = executor;
     }
     public ConductorWorkflow<WorkflowInput> createWorkflow() {

examples/java/io/orkes/conductor/sdk/MetadataManagement.java → examples/java/io/orkes/conductor/sdk/examples/MetadataManagement.java

@@ -10,7 +10,7 @@
  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package io.orkes.conductor.sdk;
+package io.orkes.conductor.sdk.examples;
 
 import java.util.Arrays;
 import java.util.Map;

examples/java/io/orkes/conductor/sdk/OrkesClientExceptionExample.java → examples/java/io/orkes/conductor/sdk/examples/OrkesClientExceptionExample.java

@@ -10,7 +10,7 @@
  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package io.orkes.conductor.sdk;
+package io.orkes.conductor.sdk.examples;
 
 import io.orkes.conductor.client.MetadataClient;
 import io.orkes.conductor.client.OrkesClientException;

examples/java/io/orkes/conductor/sdk/SchedulerManagement.java → examples/java/io/orkes/conductor/sdk/examples/SchedulerManagement.java

@@ -10,7 +10,7 @@
  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package io.orkes.conductor.sdk;
+package io.orkes.conductor.sdk.examples;
 
 import java.util.List;
 

examples/java/io/orkes/conductor/sdk/TaskConfigure.java → examples/java/io/orkes/conductor/sdk/examples/TaskConfigure.java

@@ -1,17 +1,30 @@
-package io.orkes.conductor.sdk;
+/*
+ * Copyright 2024 Orkes, Inc.
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package io.orkes.conductor.sdk.examples;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeoutException;
 
 import com.netflix.conductor.common.metadata.tasks.TaskDef;
 import com.netflix.conductor.sdk.workflow.executor.WorkflowExecutor;
+
 import io.orkes.conductor.client.MetadataClient;
 import io.orkes.conductor.client.OrkesClients;
 import io.orkes.conductor.client.TaskClient;
 import io.orkes.conductor.client.WorkflowClient;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeoutException;
-
 
 public class TaskConfigure {
 
@@ -49,4 +62,3 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
 
     }
 }
-

examples/java/io/orkes/conductor/sdk/TaskDomainWorker.java → examples/java/io/orkes/conductor/sdk/examples/TaskDomainWorker.java

@@ -10,7 +10,7 @@
  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package io.orkes.conductor.sdk;
+package io.orkes.conductor.sdk.examples;
 
 import java.io.IOException;
 import java.util.Arrays;

examples/java/io/orkes/conductor/sdk/TaskRunner.java → examples/java/io/orkes/conductor/sdk/examples/TaskRunner.java

@@ -10,9 +10,12 @@
  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package io.orkes.conductor.sdk;
+package io.orkes.conductor.sdk.examples;
 
-import java.util.*;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 import com.netflix.conductor.client.worker.Worker;
 import com.netflix.conductor.common.metadata.tasks.Task;

examples/java/io/orkes/conductor/sdk/WorkflowManagement.java → examples/java/io/orkes/conductor/sdk/examples/WorkflowManagement.java

@@ -10,7 +10,7 @@
  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package io.orkes.conductor.sdk;
+package io.orkes.conductor.sdk.examples;
 
 import java.util.Arrays;
 
@@ -19,7 +19,7 @@
 import io.orkes.conductor.client.OrkesClients;
 import io.orkes.conductor.client.WorkflowClient;
 
-import static io.orkes.conductor.sdk.MetadataManagement.workflowDef;
+import static io.orkes.conductor.sdk.examples.MetadataManagement.workflowDef;
 
 /**
  * Examples for managing Workflow operations in Conductor