diff --git a/docs/METADATA.md b/docs/METADATA.md index e7df1527..60504606 100644 --- a/docs/METADATA.md +++ b/docs/METADATA.md @@ -1 +1,59 @@ -# Metadata Management APIs \ No newline at end of file +# Metadata Management APIs + +### Create instance of MetadataClient +``` +MetadataClient metadataClient = orkesClients.getMetadataClient(); +``` +### Create task definition +``` +TaskDef taskDef = new TaskDef("testing", "sample task"); +taskDef.setRetryCount(3); // Task will be executed 4 times assuming each attempt failed. +taskDef.setRetryLogic(TaskDef.RetryLogic.FIXED); // FIXED, EXPONENTIAL_BACKOFF, LINEAR_BACKOFF +taskDef.setRetryDelaySeconds(1); // Delay between each retry +taskDef.setTimeoutPolicy(TaskDef.TimeoutPolicy.TIME_OUT_WF); // RETRY, TIME_OUT_WF, ALERT_ONLY +taskDef.setTimeoutSeconds(10); // Task timeout +taskDef.setResponseTimeoutSeconds(5); // Response timeout for worker tasks. +taskDef.setOwnerEmail("test@orkes.io"); // Owner email +``` +### Register task definition +``` +metadataClient.registerTaskDefs(Arrays.asList(taskDef)); +``` + +### Create workflow definition +``` +WorkflowDef workflowDef = new WorkflowDef(); +workflowDef.setName("example"); +workflowDef.setVersion(1); // Workflow version +workflowDef.setOwnerEmail("test@orkes.io"); +workflowDef.setFailureWorkflow("failure_workflow"); // Failure workflow to be executed on failure of current workflow. +workflowDef.setTimeoutSeconds(10); // Workflow timeout. +workflowDef.setVariables(Map.of("value", 2)); // Workflow variables +workflowDef.setInputParameters(List.of("input_value")); +``` + +### Create workflow task +``` +WorkflowTask testing = new WorkflowTask(); +testing.setTaskReferenceName("testing"); +testing.setName("testing"); +testing.setType("SIMPLE"); +testing.setInputParameters(Map.of("value", "${workflow.variables.workflow_input_value}", + "order", "${workflow.input.order_id}")); +testing.setWorkflowTaskType(SIMPLE); +``` + +### Register workflow definition +``` +workflowDef.setTasks(Arrays.asList(testing)); // Add task to workflow +metadataClient.registerWorkflowDef(workflowDef); // Register workflow definition +``` + +### Unregister task definition +``` +metadataClient.unregisterTaskDef("SIMPLE"); +``` +### Unregister workflow definition +``` +metadataClient.unregisterWorkflowDef("example", 1); // Unregister workflow example with version 1 +``` diff --git a/src/main/java/io/orkes/conductor/client/ApiClient.java b/src/main/java/io/orkes/conductor/client/ApiClient.java index 0750d1e9..cb3f3905 100644 --- a/src/main/java/io/orkes/conductor/client/ApiClient.java +++ b/src/main/java/io/orkes/conductor/client/ApiClient.java @@ -823,50 +823,6 @@ public ApiResponse execute(Call call, Type returnType) throws ApiExceptio } } - /** - * {@link #executeAsync(Call, Type, ApiCallback)} - * - * @param Type - * @param call An instance of the Call object - * @param callback ApiCallback<T> - */ - public void executeAsync(Call call, ApiCallback callback) { - executeAsync(call, null, callback); - } - - /** - * Execute HTTP call asynchronously. - * - * @see #execute(Call, Type) - * @param Type - * @param call The callback to be executed when the API call finishes - * @param returnType Return type - * @param callback ApiCallback - */ - @SuppressWarnings("unchecked") - public void executeAsync(Call call, final Type returnType, final ApiCallback callback) { - call.enqueue( - new Callback() { - @Override - public void onFailure(Request request, IOException e) { - callback.onFailure(new ApiException(e), 0, null); - } - - @Override - public void onResponse(Response response) throws IOException { - T result; - try { - result = (T) handleResponse(response, returnType); - } catch (ApiException e) { - callback.onFailure(e, response.code(), response.headers().toMultimap()); - return; - } - callback.onSuccess( - result, response.code(), response.headers().toMultimap()); - } - }); - } - /** * Handle the given response, return the deserialized object when the response is successful. * diff --git a/src/main/java/io/orkes/conductor/client/AuthorizationClient.java b/src/main/java/io/orkes/conductor/client/AuthorizationClient.java index 9b98d520..9bac1eb9 100644 --- a/src/main/java/io/orkes/conductor/client/AuthorizationClient.java +++ b/src/main/java/io/orkes/conductor/client/AuthorizationClient.java @@ -23,9 +23,9 @@ public interface AuthorizationClient { Map> getPermissions(String type, String id); - void grantPermissions(AuthorizationRequest body); + void grantPermissions(AuthorizationRequest authorizationRequest); - void removePermissions(AuthorizationRequest body); + void removePermissions(AuthorizationRequest authorizationRequest); // Users void deleteUser(String id); @@ -36,9 +36,9 @@ public interface AuthorizationClient { List listUsers(Boolean apps); - void sendInviteEmail(String id, ConductorUser body); + void sendInviteEmail(String id, ConductorUser conductorUser); - ConductorUser upsertUser(UpsertUserRequest body, String id); + ConductorUser upsertUser(UpsertUserRequest upsertUserRequest, String id); // Groups void addUserToGroup(String groupId, String userId); @@ -55,14 +55,14 @@ public interface AuthorizationClient { void removeUserFromGroup(String groupId, String userId); - Group upsertGroup(UpsertGroupRequest body, String id); + Group upsertGroup(UpsertGroupRequest upsertGroupRequest, String id); // Applications void addRoleToApplicationUser(String applicationId, String role); CreateAccessKeyResponse createAccessKey(String id); - ConductorApplication createApplication(CreateOrUpdateApplicationRequest body); + ConductorApplication createApplication(CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest); void deleteAccessKey(String applicationId, String keyId); @@ -78,5 +78,6 @@ public interface AuthorizationClient { AccessKeyResponse toggleAccessKeyStatus(String applicationId, String keyId); - ConductorApplication updateApplication(CreateOrUpdateApplicationRequest body, String id); + ConductorApplication updateApplication( + CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest, String id); } diff --git a/src/main/java/io/orkes/conductor/client/MetadataClient.java b/src/main/java/io/orkes/conductor/client/MetadataClient.java index 4062fb40..9c14b013 100644 --- a/src/main/java/io/orkes/conductor/client/MetadataClient.java +++ b/src/main/java/io/orkes/conductor/client/MetadataClient.java @@ -17,6 +17,10 @@ import com.netflix.conductor.common.metadata.tasks.TaskDef; import com.netflix.conductor.common.metadata.workflow.WorkflowDef; +import io.orkes.conductor.client.http.ApiException; +import io.orkes.conductor.client.model.TagObject; +import io.orkes.conductor.client.model.TagString; + public interface MetadataClient { void registerWorkflowDef(WorkflowDef workflowDef); @@ -33,4 +37,22 @@ public interface MetadataClient { TaskDef getTaskDef(String taskType); void unregisterTaskDef(String taskType); + + void addTaskTag(TagObject tagObject, String taskName) throws ApiException; + + void addWorkflowTag(TagObject tagObject, String name) throws ApiException; + + void deleteTaskTag(TagString tagString, String taskName) throws ApiException; + + void deleteWorkflowTag(TagObject tagObject, String name) throws ApiException; + + List getTags() throws ApiException; + + List getTaskTags(String taskName) throws ApiException; + + List getWorkflowTags(String name) throws ApiException; + + void setTaskTags(List tagObjects, String taskName) throws ApiException; + + void setWorkflowTags(List tagObjects, String name) throws ApiException; } diff --git a/src/main/java/io/orkes/conductor/client/SchedulerClient.java b/src/main/java/io/orkes/conductor/client/SchedulerClient.java index c1a8333b..2419c395 100644 --- a/src/main/java/io/orkes/conductor/client/SchedulerClient.java +++ b/src/main/java/io/orkes/conductor/client/SchedulerClient.java @@ -38,7 +38,7 @@ List getNextFewSchedules( void resumeSchedule(String name); - void saveSchedule(SaveScheduleRequest body); + void saveSchedule(SaveScheduleRequest saveScheduleRequest); SearchResultWorkflowScheduleExecutionModel searchV22( Integer start, Integer size, String sort, String freeText, String query); diff --git a/src/main/java/io/orkes/conductor/client/SecretClient.java b/src/main/java/io/orkes/conductor/client/SecretClient.java index 2a0f46ce..ca2f58b3 100644 --- a/src/main/java/io/orkes/conductor/client/SecretClient.java +++ b/src/main/java/io/orkes/conductor/client/SecretClient.java @@ -24,7 +24,7 @@ public interface SecretClient { List listSecretsThatUserCanGrantAccessTo(); - void putSecret(String body, String key); + void putSecret(String name, String key); boolean secretExists(String key); } diff --git a/src/main/java/io/orkes/conductor/client/WorkflowClient.java b/src/main/java/io/orkes/conductor/client/WorkflowClient.java index b2dfdca0..7401f87f 100644 --- a/src/main/java/io/orkes/conductor/client/WorkflowClient.java +++ b/src/main/java/io/orkes/conductor/client/WorkflowClient.java @@ -21,11 +21,8 @@ import com.netflix.conductor.common.run.Workflow; import com.netflix.conductor.common.run.WorkflowSummary; -import io.orkes.conductor.client.http.ApiCallback; import io.orkes.conductor.client.model.WorkflowStatus; -import com.squareup.okhttp.Call; - public interface WorkflowClient { String startWorkflow(StartWorkflowRequest startWorkflowRequest); @@ -74,27 +71,15 @@ SearchResult searchV2( Integer start, Integer size, String sort, String freeText, String query); // Bulk operations - BulkResponse pauseWorkflow(List body); - - Call pauseWorkflowAsync(List body, ApiCallback callback); - - BulkResponse restartWorkflow(List body, Boolean useLatestDefinitions); - - Call restartWorkflowAsync( - List body, Boolean useLatestDefinitions, ApiCallback callback); - - BulkResponse resumeWorkflow(List body); - - Call resumeWorkflowAsync(List body, ApiCallback callback); + BulkResponse pauseWorkflow(List workflowIds); - BulkResponse retryWorkflow(List body); + BulkResponse restartWorkflow(List workflowIds, Boolean useLatestDefinitions); - Call retryWorkflowAsync(List body, ApiCallback callback); + BulkResponse resumeWorkflow(List workflowIds); - BulkResponse terminateWorkflow(List body, String reason); + BulkResponse retryWorkflow(List workflowIds); - Call terminateWorkflowAsync( - List body, String reason, ApiCallback callback); + BulkResponse terminateWorkflow(List workflowIds, String reason); WorkflowStatus getWorkflowStatusSummary( String workflowId, Boolean includeOutput, Boolean includeVariables); diff --git a/src/main/java/io/orkes/conductor/client/http/OrkesAuthorizationClient.java b/src/main/java/io/orkes/conductor/client/http/OrkesAuthorizationClient.java index 9b2a61a1..724ef442 100644 --- a/src/main/java/io/orkes/conductor/client/http/OrkesAuthorizationClient.java +++ b/src/main/java/io/orkes/conductor/client/http/OrkesAuthorizationClient.java @@ -44,13 +44,13 @@ public Map> getPermissions(String type, String id) throws } @Override - public void grantPermissions(AuthorizationRequest body) throws ApiException { - authorizationResourceApi.grantPermissions(body); + public void grantPermissions(AuthorizationRequest authorizationRequest) throws ApiException { + authorizationResourceApi.grantPermissions(authorizationRequest); } @Override - public void removePermissions(AuthorizationRequest body) throws ApiException { - authorizationResourceApi.removePermissions(body); + public void removePermissions(AuthorizationRequest authorizationRequest) throws ApiException { + authorizationResourceApi.removePermissions(authorizationRequest); } @Override @@ -89,8 +89,8 @@ public void removeUserFromGroup(String groupId, String userId) throws ApiExcepti } @Override - public Group upsertGroup(UpsertGroupRequest body, String id) throws ApiException { - return groupResourceApi.upsertGroup(body, id); + public Group upsertGroup(UpsertGroupRequest upsertGroupRequest, String id) throws ApiException { + return groupResourceApi.upsertGroup(upsertGroupRequest, id); } @Override @@ -114,13 +114,14 @@ public List listUsers(Boolean apps) throws ApiException { } @Override - public void sendInviteEmail(String id, ConductorUser body) throws ApiException { - userResourceApi.sendInviteEmail(id, body); + public void sendInviteEmail(String id, ConductorUser conductorUser) throws ApiException { + userResourceApi.sendInviteEmail(id, conductorUser); } @Override - public ConductorUser upsertUser(UpsertUserRequest body, String id) throws ApiException { - return userResourceApi.upsertUser(body, id); + public ConductorUser upsertUser(UpsertUserRequest upsertUserRequest, String id) + throws ApiException { + return userResourceApi.upsertUser(upsertUserRequest, id); } @Override @@ -134,9 +135,9 @@ public CreateAccessKeyResponse createAccessKey(String id) throws ApiException { } @Override - public ConductorApplication createApplication(CreateOrUpdateApplicationRequest body) + public ConductorApplication createApplication(CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest) throws ApiException { - return applicationResourceApi.createApplication(body); + return applicationResourceApi.createApplication(createOrUpdateApplicationRequest); } @Override @@ -177,8 +178,9 @@ public AccessKeyResponse toggleAccessKeyStatus(String applicationId, String keyI } @Override - public ConductorApplication updateApplication(CreateOrUpdateApplicationRequest body, String id) + public ConductorApplication updateApplication( + CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest, String id) throws ApiException { - return applicationResourceApi.updateApplication(body, id); + return applicationResourceApi.updateApplication(createOrUpdateApplicationRequest, id); } } diff --git a/src/main/java/io/orkes/conductor/client/http/OrkesMetadataClient.java b/src/main/java/io/orkes/conductor/client/http/OrkesMetadataClient.java index 474a34f1..c89d55a5 100644 --- a/src/main/java/io/orkes/conductor/client/http/OrkesMetadataClient.java +++ b/src/main/java/io/orkes/conductor/client/http/OrkesMetadataClient.java @@ -87,40 +87,48 @@ public void unregisterTaskDef(String taskType) { metadataResourceApi.unregisterTaskDef(taskType); } - // Tags APIs - public void addTaskTag(TagObject body, String taskName) { - tagsApi.addTaskTag(body, taskName); + @Override + public void addTaskTag(TagObject tagObject, String taskName) { + tagsApi.addTaskTag(tagObject, taskName); } - public void addWorkflowTag(TagObject body, String name) { - tagsApi.addWorkflowTag(body, name); + @Override + public void addWorkflowTag(TagObject tagObject, String name) { + tagsApi.addWorkflowTag(tagObject, name); } - public void deleteTaskTag(TagString body, String taskName) { - tagsApi.deleteTaskTag(body, taskName); + @Override + public void deleteTaskTag(TagString tagString, String taskName) { + tagsApi.deleteTaskTag(tagString, taskName); } - public void deleteWorkflowTag(TagObject body, String name) { - tagsApi.deleteWorkflowTag(body, name); + @Override + public void deleteWorkflowTag(TagObject tagObject, String name) { + tagsApi.deleteWorkflowTag(tagObject, name); } + @Override public List getTags() { return tagsApi.getTags(); } + @Override public List getTaskTags(String taskName) { return tagsApi.getTaskTags(taskName); } + @Override public List getWorkflowTags(String name) { return tagsApi.getWorkflowTags(name); } - public void setTaskTags(List body, String taskName) { - tagsApi.setTaskTags(body, taskName); + @Override + public void setTaskTags(List tagObjects, String taskName) { + tagsApi.setTaskTags(tagObjects, taskName); } - public void setWorkflowTags(List body, String name) { - tagsApi.setWorkflowTags(body, name); + @Override + public void setWorkflowTags(List tagObjects, String name) { + tagsApi.setWorkflowTags(tagObjects, name); } } diff --git a/src/main/java/io/orkes/conductor/client/http/OrkesSchedulerClient.java b/src/main/java/io/orkes/conductor/client/http/OrkesSchedulerClient.java index 18b7025a..6feeb23d 100644 --- a/src/main/java/io/orkes/conductor/client/http/OrkesSchedulerClient.java +++ b/src/main/java/io/orkes/conductor/client/http/OrkesSchedulerClient.java @@ -79,8 +79,8 @@ public void resumeSchedule(String name) throws ApiException { } @Override - public void saveSchedule(SaveScheduleRequest body) throws ApiException { - schedulerResourceApi.saveSchedule(body); + public void saveSchedule(SaveScheduleRequest saveScheduleRequest) throws ApiException { + schedulerResourceApi.saveSchedule(saveScheduleRequest); } @Override diff --git a/src/main/java/io/orkes/conductor/client/http/OrkesWorkflowClient.java b/src/main/java/io/orkes/conductor/client/http/OrkesWorkflowClient.java index 8216e8a2..2d803bc1 100644 --- a/src/main/java/io/orkes/conductor/client/http/OrkesWorkflowClient.java +++ b/src/main/java/io/orkes/conductor/client/http/OrkesWorkflowClient.java @@ -31,7 +31,6 @@ import io.orkes.conductor.client.model.WorkflowStatus; import com.google.common.base.Preconditions; -import com.squareup.okhttp.Call; public class OrkesWorkflowClient extends OrkesClient implements WorkflowClient { @@ -162,61 +161,30 @@ public SearchResult searchV2( } @Override - public BulkResponse pauseWorkflow(List body) throws ApiException { - return bulkResourceApi.pauseWorkflow1(body); + public BulkResponse pauseWorkflow(List workflowIds) throws ApiException { + return bulkResourceApi.pauseWorkflow1(workflowIds); } @Override - public Call pauseWorkflowAsync(List body, ApiCallback callback) + public BulkResponse restartWorkflow(List workflowIds, Boolean useLatestDefinitions) throws ApiException { - return bulkResourceApi.pauseWorkflow1Async(body, callback); + return bulkResourceApi.restart1(workflowIds, useLatestDefinitions); } @Override - public BulkResponse restartWorkflow(List body, Boolean useLatestDefinitions) - throws ApiException { - return bulkResourceApi.restart1(body, useLatestDefinitions); - } - - @Override - public Call restartWorkflowAsync( - List body, Boolean useLatestDefinitions, ApiCallback callback) - throws ApiException { - return bulkResourceApi.restart1Async(body, useLatestDefinitions, callback); - } - - @Override - public BulkResponse resumeWorkflow(List body) throws ApiException { - return bulkResourceApi.resumeWorkflow1(body); - } - - @Override - public Call resumeWorkflowAsync(List body, ApiCallback callback) - throws ApiException { - return bulkResourceApi.resumeWorkflow1Async(body, callback); - } - - @Override - public BulkResponse retryWorkflow(List body) throws ApiException { - return bulkResourceApi.retry1(body); + public BulkResponse resumeWorkflow(List workflowIds) throws ApiException { + return bulkResourceApi.resumeWorkflow1(workflowIds); } @Override - public Call retryWorkflowAsync(List body, ApiCallback callback) - throws ApiException { - return bulkResourceApi.retry1Async(body, callback); + public BulkResponse retryWorkflow(List workflowIds) throws ApiException { + return bulkResourceApi.retry1(workflowIds); } @Override - public BulkResponse terminateWorkflow(List body, String reason) throws ApiException { - return bulkResourceApi.terminate(body, reason); - } - - @Override - public Call terminateWorkflowAsync( - List body, String reason, ApiCallback callback) + public BulkResponse terminateWorkflow(List workflowIds, String reason) throws ApiException { - return bulkResourceApi.terminateAsync(body, reason, callback); + return bulkResourceApi.terminate(workflowIds, reason); } @Override diff --git a/src/main/java/io/orkes/conductor/client/http/api/ApplicationResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/ApplicationResourceApi.java index fe2e5e8a..ffb9631e 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/ApplicationResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/ApplicationResourceApi.java @@ -292,18 +292,18 @@ private ApiResponse createAccessKeyWithHttpInfo(String /** * Build call for createApplication * - * @param body (required) + * @param createOrUpdateApplicationRequest (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call createApplicationCall( - CreateOrUpdateApplicationRequest body, + CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = createOrUpdateApplicationRequest; // create path and map variables String localVarPath = "/applications"; @@ -361,46 +361,49 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call createApplicationValidateBeforeCall( - CreateOrUpdateApplicationRequest body, + CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (createOrUpdateApplicationRequest == null) { throw new ApiException( - "Missing the required parameter 'body' when calling createApplication(Async)"); + "Missing the required parameter 'createOrUpdateApplicationRequest' when calling createApplication(Async)"); } com.squareup.okhttp.Call call = - createApplicationCall(body, progressListener, progressRequestListener); + createApplicationCall( + createOrUpdateApplicationRequest, + progressListener, + progressRequestListener); return call; } /** * Create an application * - * @param body (required) + * @param createOrUpdateApplicationRequest (required) * @return Object * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public ConductorApplication createApplication(CreateOrUpdateApplicationRequest body) + public ConductorApplication createApplication(CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest) throws ApiException { - ApiResponse resp = createApplicationWithHttpInfo(body); + ApiResponse resp = createApplicationWithHttpInfo(createOrUpdateApplicationRequest); return resp.getData(); } /** * Create an application * - * @param body (required) + * @param createOrUpdateApplicationRequest (required) * @return ApiResponse<Object> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ private ApiResponse createApplicationWithHttpInfo( - CreateOrUpdateApplicationRequest body) throws ApiException { - com.squareup.okhttp.Call call = createApplicationValidateBeforeCall(body, null, null); + CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest) throws ApiException { + com.squareup.okhttp.Call call = createApplicationValidateBeforeCall(createOrUpdateApplicationRequest, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } @@ -1262,7 +1265,7 @@ private ApiResponse toggleAccessKeyStatusWithHttpInfo( /** * Build call for updateApplication * - * @param body (required) + * @param createOrUpdateApplicationRequest (required) * @param id (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -1270,12 +1273,12 @@ private ApiResponse toggleAccessKeyStatusWithHttpInfo( * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call updateApplicationCall( - CreateOrUpdateApplicationRequest body, + CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest, String id, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = createOrUpdateApplicationRequest; // create path and map variables String localVarPath = @@ -1335,15 +1338,15 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call updateApplicationValidateBeforeCall( - CreateOrUpdateApplicationRequest body, + CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest, String id, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (createOrUpdateApplicationRequest == null) { throw new ApiException( - "Missing the required parameter 'body' when calling updateApplication(Async)"); + "Missing the required parameter 'createOrUpdateApplicationRequest' when calling updateApplication(Async)"); } // verify the required parameter 'id' is set if (id == null) { @@ -1352,37 +1355,46 @@ private com.squareup.okhttp.Call updateApplicationValidateBeforeCall( } com.squareup.okhttp.Call call = - updateApplicationCall(body, id, progressListener, progressRequestListener); + updateApplicationCall( + createOrUpdateApplicationRequest, + id, + progressListener, + progressRequestListener); return call; } /** * Update an application * - * @param body (required) + * @param createOrUpdateApplicationRequest (required) * @param id (required) * @return Object * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public ConductorApplication updateApplication(CreateOrUpdateApplicationRequest body, String id) + public ConductorApplication updateApplication( + CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest, String id) throws ApiException { - ApiResponse resp = updateApplicationWithHttpInfo(body, id); + ApiResponse resp = + updateApplicationWithHttpInfo(createOrUpdateApplicationRequest, id); return resp.getData(); } /** * Update an application * - * @param body (required) + * @param createOrUpdateApplicationRequest (required) * @param id (required) * @return ApiResponse<Object> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ private ApiResponse updateApplicationWithHttpInfo( - CreateOrUpdateApplicationRequest body, String id) throws ApiException { - com.squareup.okhttp.Call call = updateApplicationValidateBeforeCall(body, id, null, null); + CreateOrUpdateApplicationRequest createOrUpdateApplicationRequest, String id) + throws ApiException { + com.squareup.okhttp.Call call = + updateApplicationValidateBeforeCall( + createOrUpdateApplicationRequest, id, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } diff --git a/src/main/java/io/orkes/conductor/client/http/api/AuthorizationResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/AuthorizationResourceApi.java index c2e92ea5..d2e5c894 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/AuthorizationResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/AuthorizationResourceApi.java @@ -178,18 +178,18 @@ private ApiResponse>> getPermissionsWithHttpInfo( /** * Build call for grantPermissions * - * @param body (required) + * @param authorizationRequest (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call grantPermissionsCall( - AuthorizationRequest body, + AuthorizationRequest authorizationRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = authorizationRequest; // create path and map variables String localVarPath = "/auth/authorization"; @@ -248,61 +248,62 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call grantPermissionsValidateBeforeCall( - AuthorizationRequest body, + AuthorizationRequest authorizationRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (authorizationRequest == null) { throw new ApiException( - "Missing the required parameter 'body' when calling grantPermissions(Async)"); + "Missing the required parameter 'authorizationRequest' when calling grantPermissions(Async)"); } com.squareup.okhttp.Call call = - grantPermissionsCall(body, progressListener, progressRequestListener); + grantPermissionsCall( + authorizationRequest, progressListener, progressRequestListener); return call; } /** * Grant access to a user over the target * - * @param body (required) + * @param authorizationRequest (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void grantPermissions(AuthorizationRequest body) throws ApiException { - grantPermissionsWithHttpInfo(body); + public void grantPermissions(AuthorizationRequest authorizationRequest) throws ApiException { + grantPermissionsWithHttpInfo(authorizationRequest); } /** * Grant access to a user over the target * - * @param body (required) + * @param authorizationRequest (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse grantPermissionsWithHttpInfo(AuthorizationRequest body) + private ApiResponse grantPermissionsWithHttpInfo(AuthorizationRequest authorizationRequest) throws ApiException { - com.squareup.okhttp.Call call = grantPermissionsValidateBeforeCall(body, null, null); + com.squareup.okhttp.Call call = grantPermissionsValidateBeforeCall(authorizationRequest, null, null); return apiClient.execute(call); } /** * Build call for removePermissions * - * @param body (required) + * @param authorizationRequest (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call removePermissionsCall( - AuthorizationRequest body, + AuthorizationRequest authorizationRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = authorizationRequest; // create path and map variables String localVarPath = "/auth/authorization"; @@ -361,43 +362,44 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call removePermissionsValidateBeforeCall( - AuthorizationRequest body, + AuthorizationRequest authorizationRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (authorizationRequest == null) { throw new ApiException( - "Missing the required parameter 'body' when calling removePermissions(Async)"); + "Missing the required parameter 'authorizationRequest' when calling removePermissions(Async)"); } com.squareup.okhttp.Call call = - removePermissionsCall(body, progressListener, progressRequestListener); + removePermissionsCall( + authorizationRequest, progressListener, progressRequestListener); return call; } /** * Remove user's access over the target * - * @param body (required) + * @param authorizationRequest (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void removePermissions(AuthorizationRequest body) throws ApiException { - removePermissionsWithHttpInfo(body); + public void removePermissions(AuthorizationRequest authorizationRequest) throws ApiException { + removePermissionsWithHttpInfo(authorizationRequest); } /** * Remove user's access over the target * - * @param body (required) + * @param authorizationRequest (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse removePermissionsWithHttpInfo(AuthorizationRequest body) + private ApiResponse removePermissionsWithHttpInfo(AuthorizationRequest authorizationRequest) throws ApiException { - com.squareup.okhttp.Call call = removePermissionsValidateBeforeCall(body, null, null); + com.squareup.okhttp.Call call = removePermissionsValidateBeforeCall(authorizationRequest, null, null); return apiClient.execute(call); } } diff --git a/src/main/java/io/orkes/conductor/client/http/api/EventResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/EventResourceApi.java index a31b63ef..699c3693 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/EventResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/EventResourceApi.java @@ -48,18 +48,18 @@ public void setApiClient(ApiClient apiClient) { /** * Build call for addEventHandler * - * @param body (required) + * @param eventHandler (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call addEventHandlerCall( - EventHandler body, + EventHandler eventHandler, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = eventHandler; // create path and map variables String localVarPath = "/event"; @@ -118,42 +118,43 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call addEventHandlerValidateBeforeCall( - EventHandler body, + EventHandler eventHandler, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (eventHandler == null) { throw new ApiException( - "Missing the required parameter 'body' when calling addEventHandler(Async)"); + "Missing the required parameter 'eventHandler' when calling addEventHandler(Async)"); } com.squareup.okhttp.Call call = - addEventHandlerCall(body, progressListener, progressRequestListener); + addEventHandlerCall(eventHandler, progressListener, progressRequestListener); return call; } /** * Add a new event handler. * - * @param body (required) + * @param eventHandler (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void addEventHandler(EventHandler body) throws ApiException { - addEventHandlerWithHttpInfo(body); + public void addEventHandler(EventHandler eventHandler) throws ApiException { + addEventHandlerWithHttpInfo(eventHandler); } /** * Add a new event handler. * - * @param body (required) + * @param eventHandler (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse addEventHandlerWithHttpInfo(EventHandler body) throws ApiException { - com.squareup.okhttp.Call call = addEventHandlerValidateBeforeCall(body, null, null); + private ApiResponse addEventHandlerWithHttpInfo(EventHandler eventHandler) + throws ApiException { + com.squareup.okhttp.Call call = addEventHandlerValidateBeforeCall(eventHandler, null, null); return apiClient.execute(call); } @@ -1032,18 +1033,18 @@ private ApiResponse removeEventHandlerStatusWithHttpInfo(String name) /** * Build call for updateEventHandler * - * @param body (required) + * @param eventHandler (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call updateEventHandlerCall( - EventHandler body, + EventHandler eventHandler, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = eventHandler; // create path and map variables String localVarPath = "/event"; @@ -1102,43 +1103,43 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call updateEventHandlerValidateBeforeCall( - EventHandler body, + EventHandler eventHandler, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (eventHandler == null) { throw new ApiException( - "Missing the required parameter 'body' when calling updateEventHandler(Async)"); + "Missing the required parameter 'eventHandler' when calling updateEventHandler(Async)"); } com.squareup.okhttp.Call call = - updateEventHandlerCall(body, progressListener, progressRequestListener); + updateEventHandlerCall(eventHandler, progressListener, progressRequestListener); return call; } /** * Update an existing event handler. * - * @param body (required) + * @param eventHandler (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void updateEventHandler(EventHandler body) throws ApiException { - updateEventHandlerWithHttpInfo(body); + public void updateEventHandler(EventHandler eventHandler) throws ApiException { + updateEventHandlerWithHttpInfo(eventHandler); } /** * Update an existing event handler. * - * @param body (required) + * @param eventHandler (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse updateEventHandlerWithHttpInfo(EventHandler body) + private ApiResponse updateEventHandlerWithHttpInfo(EventHandler eventHandler) throws ApiException { - com.squareup.okhttp.Call call = updateEventHandlerValidateBeforeCall(body, null, null); + com.squareup.okhttp.Call call = updateEventHandlerValidateBeforeCall(eventHandler, null, null); return apiClient.execute(call); } } diff --git a/src/main/java/io/orkes/conductor/client/http/api/GroupResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/GroupResourceApi.java index 5e3a02b0..a3a3e97c 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/GroupResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/GroupResourceApi.java @@ -888,7 +888,7 @@ private ApiResponse removeUserFromGroupWithHttpInfo(String groupId, String /** * Build call for upsertGroup * - * @param body (required) + * @param upsertGroupRequest (required) * @param id (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -896,12 +896,12 @@ private ApiResponse removeUserFromGroupWithHttpInfo(String groupId, String * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call upsertGroupCall( - UpsertGroupRequest body, + UpsertGroupRequest upsertGroupRequest, String id, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = upsertGroupRequest; // create path and map variables String localVarPath = @@ -961,15 +961,15 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call upsertGroupValidateBeforeCall( - UpsertGroupRequest body, + UpsertGroupRequest upsertGroupRequest, String id, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (upsertGroupRequest == null) { throw new ApiException( - "Missing the required parameter 'body' when calling upsertGroup(Async)"); + "Missing the required parameter 'upsertGroupRequest' when calling upsertGroup(Async)"); } // verify the required parameter 'id' is set if (id == null) { @@ -978,36 +978,37 @@ private com.squareup.okhttp.Call upsertGroupValidateBeforeCall( } com.squareup.okhttp.Call call = - upsertGroupCall(body, id, progressListener, progressRequestListener); + upsertGroupCall(upsertGroupRequest, id, progressListener, progressRequestListener); return call; } /** * Create or update a group * - * @param body (required) + * @param upsertGroupRequest (required) * @param id (required) * @return Group * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public Group upsertGroup(UpsertGroupRequest body, String id) throws ApiException { - ApiResponse resp = upsertGroupWithHttpInfo(body, id); + public Group upsertGroup(UpsertGroupRequest upsertGroupRequest, String id) throws ApiException { + ApiResponse resp = upsertGroupWithHttpInfo(upsertGroupRequest, id); return resp.getData(); } /** * Create or update a group * - * @param body (required) + * @param upsertGroupRequest (required) * @param id (required) * @return ApiResponse<Group> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse upsertGroupWithHttpInfo(UpsertGroupRequest body, String id) - throws ApiException { - com.squareup.okhttp.Call call = upsertGroupValidateBeforeCall(body, id, null, null); + private ApiResponse upsertGroupWithHttpInfo( + UpsertGroupRequest upsertGroupRequest, String id) throws ApiException { + com.squareup.okhttp.Call call = + upsertGroupValidateBeforeCall(upsertGroupRequest, id, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } diff --git a/src/main/java/io/orkes/conductor/client/http/api/MetadataResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/MetadataResourceApi.java index 708ee54a..e5774a2d 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/MetadataResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/MetadataResourceApi.java @@ -49,7 +49,7 @@ public void setApiClient(ApiClient apiClient) { /** * Build call for create * - * @param body (required) + * @param workflowDef (required) * @param overwrite (optional, default to false) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -57,12 +57,12 @@ public void setApiClient(ApiClient apiClient) { * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call createCall( - WorkflowDef body, + WorkflowDef workflowDef, Boolean overwrite, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = workflowDef; // create path and map variables String localVarPath = "/metadata/workflow"; @@ -123,46 +123,47 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call createValidateBeforeCall( - WorkflowDef body, + WorkflowDef workflowDef, Boolean overwrite, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (workflowDef == null) { throw new ApiException( - "Missing the required parameter 'body' when calling create(Async)"); + "Missing the required parameter 'workflowDef' when calling create(Async)"); } com.squareup.okhttp.Call call = - createCall(body, overwrite, progressListener, progressRequestListener); + createCall(workflowDef, overwrite, progressListener, progressRequestListener); return call; } /** * Create a new workflow definition * - * @param body (required) + * @param workflowDef (required) * @param overwrite (optional, default to false) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void create(WorkflowDef body, Boolean overwrite) throws ApiException { - createWithHttpInfo(body, overwrite); + public void create(WorkflowDef workflowDef, Boolean overwrite) throws ApiException { + createWithHttpInfo(workflowDef, overwrite); } /** * Create a new workflow definition * - * @param body (required) + * @param workflowDef (required) * @param overwrite (optional, default to false) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse createWithHttpInfo(WorkflowDef body, Boolean overwrite) + private ApiResponse createWithHttpInfo(WorkflowDef workflowDef, Boolean overwrite) throws ApiException { - com.squareup.okhttp.Call call = createValidateBeforeCall(body, overwrite, null, null); + com.squareup.okhttp.Call call = + createValidateBeforeCall(workflowDef, overwrite, null, null); return apiClient.execute(call); } @@ -711,18 +712,18 @@ private ApiResponse> getTaskDefsWithHttpInfo( /** * Build call for registerTaskDef * - * @param body (required) + * @param taskDefs (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call registerTaskDefCall( - List body, + List taskDefs, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = taskDefs; // create path and map variables String localVarPath = "/metadata/taskdefs"; @@ -781,42 +782,43 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call registerTaskDefValidateBeforeCall( - List body, + List taskDefs, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (taskDefs == null) { throw new ApiException( - "Missing the required parameter 'body' when calling registerTaskDef(Async)"); + "Missing the required parameter 'taskDefs' when calling registerTaskDef(Async)"); } com.squareup.okhttp.Call call = - registerTaskDefCall(body, progressListener, progressRequestListener); + registerTaskDefCall(taskDefs, progressListener, progressRequestListener); return call; } /** * Create or update task definition(s) * - * @param body (required) + * @param taskDefs (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void registerTaskDef(List body) throws ApiException { - registerTaskDefWithHttpInfo(body); + public void registerTaskDef(List taskDefs) throws ApiException { + registerTaskDefWithHttpInfo(taskDefs); } /** * Create or update task definition(s) * - * @param body (required) + * @param taskDefs (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse registerTaskDefWithHttpInfo(List body) throws ApiException { - com.squareup.okhttp.Call call = registerTaskDefValidateBeforeCall(body, null, null); + private ApiResponse registerTaskDefWithHttpInfo(List taskDefs) + throws ApiException { + com.squareup.okhttp.Call call = registerTaskDefValidateBeforeCall(taskDefs, null, null); return apiClient.execute(call); } @@ -1070,7 +1072,7 @@ private ApiResponse unregisterWorkflowDefWithHttpInfo(String name, Integer /** * Build call for update * - * @param body (required) + * @param workflowDefs (required) * @param overwrite (optional, default to true) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -1078,12 +1080,12 @@ private ApiResponse unregisterWorkflowDefWithHttpInfo(String name, Integer * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call updateCall( - List body, + List workflowDefs, Boolean overwrite, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = workflowDefs; // create path and map variables String localVarPath = "/metadata/workflow"; @@ -1144,64 +1146,65 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call updateValidateBeforeCall( - List body, + List workflowDefs, Boolean overwrite, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (workflowDefs == null) { throw new ApiException( - "Missing the required parameter 'body' when calling update(Async)"); + "Missing the required parameter 'workflowDefs' when calling update(Async)"); } com.squareup.okhttp.Call call = - updateCall(body, overwrite, progressListener, progressRequestListener); + updateCall(workflowDefs, overwrite, progressListener, progressRequestListener); return call; } /** * Create or update workflow definition(s) * - * @param body (required) + * @param workflowDefs (required) * @param overwrite (optional, default to true) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void update(List body, Boolean overwrite) throws ApiException { - updateWithHttpInfo(body, overwrite); + public void update(List workflowDefs, Boolean overwrite) throws ApiException { + updateWithHttpInfo(workflowDefs, overwrite); } /** * Create or update workflow definition(s) * - * @param body (required) + * @param workflowDefs (required) * @param overwrite (optional, default to true) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse updateWithHttpInfo(List body, Boolean overwrite) + private ApiResponse updateWithHttpInfo(List workflowDefs, Boolean overwrite) throws ApiException { - com.squareup.okhttp.Call call = updateValidateBeforeCall(body, overwrite, null, null); + com.squareup.okhttp.Call call = + updateValidateBeforeCall(workflowDefs, overwrite, null, null); return apiClient.execute(call); } /** * Build call for updateTaskDef * - * @param body (required) + * @param taskDef (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call updateTaskDefCall( - TaskDef body, + TaskDef taskDef, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = taskDef; // create path and map variables String localVarPath = "/metadata/taskdefs"; @@ -1260,42 +1263,42 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call updateTaskDefValidateBeforeCall( - TaskDef body, + TaskDef taskDef, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (taskDef == null) { throw new ApiException( - "Missing the required parameter 'body' when calling updateTaskDef(Async)"); + "Missing the required parameter 'taskDef' when calling updateTaskDef(Async)"); } com.squareup.okhttp.Call call = - updateTaskDefCall(body, progressListener, progressRequestListener); + updateTaskDefCall(taskDef, progressListener, progressRequestListener); return call; } /** * Update an existing task * - * @param body (required) + * @param taskDef (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void updateTaskDef(TaskDef body) throws ApiException { - updateTaskDefWithHttpInfo(body); + public void updateTaskDef(TaskDef taskDef) throws ApiException { + updateTaskDefWithHttpInfo(taskDef); } /** * Update an existing task * - * @param body (required) + * @param taskDef (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse updateTaskDefWithHttpInfo(TaskDef body) throws ApiException { - com.squareup.okhttp.Call call = updateTaskDefValidateBeforeCall(body, null, null); + private ApiResponse updateTaskDefWithHttpInfo(TaskDef taskDef) throws ApiException { + com.squareup.okhttp.Call call = updateTaskDefValidateBeforeCall(taskDef, null, null); return apiClient.execute(call); } } diff --git a/src/main/java/io/orkes/conductor/client/http/api/SchedulerResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/SchedulerResourceApi.java index c65bfda4..420e6f9d 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/SchedulerResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/SchedulerResourceApi.java @@ -1097,18 +1097,18 @@ private ApiResponse resumeScheduleWithHttpInfo(String name) throws ApiExce /** * Build call for saveSchedule * - * @param body (required) + * @param saveScheduleRequest (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call saveScheduleCall( - SaveScheduleRequest body, + SaveScheduleRequest saveScheduleRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = saveScheduleRequest; // create path and map variables String localVarPath = "/scheduler/schedules"; @@ -1167,18 +1167,18 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call saveScheduleValidateBeforeCall( - SaveScheduleRequest body, + SaveScheduleRequest saveScheduleRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (saveScheduleRequest == null) { throw new ApiException( - "Missing the required parameter 'body' when calling saveSchedule(Async)"); + "Missing the required parameter 'saveScheduleRequest' when calling saveSchedule(Async)"); } com.squareup.okhttp.Call call = - saveScheduleCall(body, progressListener, progressRequestListener); + saveScheduleCall(saveScheduleRequest, progressListener, progressRequestListener); return call; } @@ -1186,26 +1186,26 @@ private com.squareup.okhttp.Call saveScheduleValidateBeforeCall( * Create or update a schedule for a specified workflow with a corresponding start workflow * request * - * @param body (required) + * @param saveScheduleRequest (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void saveSchedule(SaveScheduleRequest body) throws ApiException { - saveScheduleWithHttpInfo(body); + public void saveSchedule(SaveScheduleRequest saveScheduleRequest) throws ApiException { + saveScheduleWithHttpInfo(saveScheduleRequest); } /** * Create or update a schedule for a specified workflow with a corresponding start workflow * request * - * @param body (required) + * @param saveScheduleRequest (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse saveScheduleWithHttpInfo(SaveScheduleRequest body) + private ApiResponse saveScheduleWithHttpInfo(SaveScheduleRequest saveScheduleRequest) throws ApiException { - com.squareup.okhttp.Call call = saveScheduleValidateBeforeCall(body, null, null); + com.squareup.okhttp.Call call = saveScheduleValidateBeforeCall(saveScheduleRequest, null, null); return apiClient.execute(call); } diff --git a/src/main/java/io/orkes/conductor/client/http/api/TagsApi.java b/src/main/java/io/orkes/conductor/client/http/api/TagsApi.java index de02c609..faffe69e 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/TagsApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/TagsApi.java @@ -48,7 +48,7 @@ public void setApiClient(ApiClient apiClient) { /** * Build call for addTaskTag * - * @param body (required) + * @param tagObject (required) * @param taskName (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -56,12 +56,12 @@ public void setApiClient(ApiClient apiClient) { * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call addTaskTagCall( - TagObject body, + TagObject tagObject, String taskName, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = tagObject; // create path and map variables String localVarPath = @@ -124,15 +124,15 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call addTaskTagValidateBeforeCall( - TagObject body, + TagObject tagObject, String taskName, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (tagObject == null) { throw new ApiException( - "Missing the required parameter 'body' when calling addTaskTag(Async)"); + "Missing the required parameter 'tagObject' when calling addTaskTag(Async)"); } // verify the required parameter 'taskName' is set if (taskName == null) { @@ -141,41 +141,42 @@ private com.squareup.okhttp.Call addTaskTagValidateBeforeCall( } com.squareup.okhttp.Call call = - addTaskTagCall(body, taskName, progressListener, progressRequestListener); + addTaskTagCall(tagObject, taskName, progressListener, progressRequestListener); return call; } /** * Adds the tag to the task * - * @param body (required) + * @param tagObject (required) * @param taskName (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void addTaskTag(TagObject body, String taskName) throws ApiException { - addTaskTagWithHttpInfo(body, taskName); + public void addTaskTag(TagObject tagObject, String taskName) throws ApiException { + addTaskTagWithHttpInfo(tagObject, taskName); } /** * Adds the tag to the task * - * @param body (required) + * @param tagObject (required) * @param taskName (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse addTaskTagWithHttpInfo(TagObject body, String taskName) + private ApiResponse addTaskTagWithHttpInfo(TagObject tagObject, String taskName) throws ApiException { - com.squareup.okhttp.Call call = addTaskTagValidateBeforeCall(body, taskName, null, null); + com.squareup.okhttp.Call call = + addTaskTagValidateBeforeCall(tagObject, taskName, null, null); return apiClient.execute(call); } /** * Build call for addWorkflowTag * - * @param body (required) + * @param tagObject (required) * @param name (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -183,12 +184,12 @@ private ApiResponse addTaskTagWithHttpInfo(TagObject body, String taskName * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call addWorkflowTagCall( - TagObject body, + TagObject tagObject, String name, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = tagObject; // create path and map variables String localVarPath = @@ -250,15 +251,15 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call addWorkflowTagValidateBeforeCall( - TagObject body, + TagObject tagObject, String name, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (tagObject == null) { throw new ApiException( - "Missing the required parameter 'body' when calling addWorkflowTag(Async)"); + "Missing the required parameter 'tagObject' when calling addWorkflowTag(Async)"); } // verify the required parameter 'name' is set if (name == null) { @@ -267,41 +268,42 @@ private com.squareup.okhttp.Call addWorkflowTagValidateBeforeCall( } com.squareup.okhttp.Call call = - addWorkflowTagCall(body, name, progressListener, progressRequestListener); + addWorkflowTagCall(tagObject, name, progressListener, progressRequestListener); return call; } /** * Adds the tag to the workflow * - * @param body (required) + * @param tagObject (required) * @param name (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void addWorkflowTag(TagObject body, String name) throws ApiException { - addWorkflowTagWithHttpInfo(body, name); + public void addWorkflowTag(TagObject tagObject, String name) throws ApiException { + addWorkflowTagWithHttpInfo(tagObject, name); } /** * Adds the tag to the workflow * - * @param body (required) + * @param tagObject (required) * @param name (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse addWorkflowTagWithHttpInfo(TagObject body, String name) + private ApiResponse addWorkflowTagWithHttpInfo(TagObject tagObject, String name) throws ApiException { - com.squareup.okhttp.Call call = addWorkflowTagValidateBeforeCall(body, name, null, null); + com.squareup.okhttp.Call call = + addWorkflowTagValidateBeforeCall(tagObject, name, null, null); return apiClient.execute(call); } /** * Build call for deleteTaskTag * - * @param body (required) + * @param tagString (required) * @param taskName (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -309,12 +311,12 @@ private ApiResponse addWorkflowTagWithHttpInfo(TagObject body, String name * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call deleteTaskTagCall( - TagString body, + TagString tagString, String taskName, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = tagString; // create path and map variables String localVarPath = @@ -377,15 +379,15 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call deleteTaskTagValidateBeforeCall( - TagString body, + TagString tagString, String taskName, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (tagString == null) { throw new ApiException( - "Missing the required parameter 'body' when calling deleteTaskTag(Async)"); + "Missing the required parameter 'tagString' when calling deleteTaskTag(Async)"); } // verify the required parameter 'taskName' is set if (taskName == null) { @@ -394,41 +396,42 @@ private com.squareup.okhttp.Call deleteTaskTagValidateBeforeCall( } com.squareup.okhttp.Call call = - deleteTaskTagCall(body, taskName, progressListener, progressRequestListener); + deleteTaskTagCall(tagString, taskName, progressListener, progressRequestListener); return call; } /** * Removes the tag of the task * - * @param body (required) + * @param tagString (required) * @param taskName (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void deleteTaskTag(TagString body, String taskName) throws ApiException { - deleteTaskTagWithHttpInfo(body, taskName); + public void deleteTaskTag(TagString tagString, String taskName) throws ApiException { + deleteTaskTagWithHttpInfo(tagString, taskName); } /** * Removes the tag of the task * - * @param body (required) + * @param tagString (required) * @param taskName (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse deleteTaskTagWithHttpInfo(TagString body, String taskName) + private ApiResponse deleteTaskTagWithHttpInfo(TagString tagString, String taskName) throws ApiException { - com.squareup.okhttp.Call call = deleteTaskTagValidateBeforeCall(body, taskName, null, null); + com.squareup.okhttp.Call call = + deleteTaskTagValidateBeforeCall(tagString, taskName, null, null); return apiClient.execute(call); } /** * Build call for deleteWorkflowTag * - * @param body (required) + * @param tagObject (required) * @param name (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -436,12 +439,12 @@ private ApiResponse deleteTaskTagWithHttpInfo(TagString body, String taskN * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call deleteWorkflowTagCall( - TagObject body, + TagObject tagObject, String name, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = tagObject; // create path and map variables String localVarPath = @@ -503,15 +506,15 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call deleteWorkflowTagValidateBeforeCall( - TagObject body, + TagObject tagObject, String name, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (tagObject == null) { throw new ApiException( - "Missing the required parameter 'body' when calling deleteWorkflowTag(Async)"); + "Missing the required parameter 'tagObject' when calling deleteWorkflowTag(Async)"); } // verify the required parameter 'name' is set if (name == null) { @@ -520,34 +523,35 @@ private com.squareup.okhttp.Call deleteWorkflowTagValidateBeforeCall( } com.squareup.okhttp.Call call = - deleteWorkflowTagCall(body, name, progressListener, progressRequestListener); + deleteWorkflowTagCall(tagObject, name, progressListener, progressRequestListener); return call; } /** * Removes the tag of the workflow * - * @param body (required) + * @param tagObject (required) * @param name (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void deleteWorkflowTag(TagObject body, String name) throws ApiException { - deleteWorkflowTagWithHttpInfo(body, name); + public void deleteWorkflowTag(TagObject tagObject, String name) throws ApiException { + deleteWorkflowTagWithHttpInfo(tagObject, name); } /** * Removes the tag of the workflow * - * @param body (required) + * @param tagObject (required) * @param name (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse deleteWorkflowTagWithHttpInfo(TagObject body, String name) + private ApiResponse deleteWorkflowTagWithHttpInfo(TagObject tagObject, String name) throws ApiException { - com.squareup.okhttp.Call call = deleteWorkflowTagValidateBeforeCall(body, name, null, null); + com.squareup.okhttp.Call call = + deleteWorkflowTagValidateBeforeCall(tagObject, name, null, null); return apiClient.execute(call); } @@ -897,7 +901,7 @@ private ApiResponse> getWorkflowTagsWithHttpInfo(String name) /** * Build call for setTaskTags * - * @param body (required) + * @param tagObjects (required) * @param taskName (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -905,12 +909,12 @@ private ApiResponse> getWorkflowTagsWithHttpInfo(String name) * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call setTaskTagsCall( - List body, + List tagObjects, String taskName, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = tagObjects; // create path and map variables String localVarPath = @@ -973,15 +977,15 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call setTaskTagsValidateBeforeCall( - List body, + List tagObjects, String taskName, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (tagObjects == null) { throw new ApiException( - "Missing the required parameter 'body' when calling setTaskTags(Async)"); + "Missing the required parameter 'tagObjects' when calling setTaskTags(Async)"); } // verify the required parameter 'taskName' is set if (taskName == null) { @@ -990,41 +994,42 @@ private com.squareup.okhttp.Call setTaskTagsValidateBeforeCall( } com.squareup.okhttp.Call call = - setTaskTagsCall(body, taskName, progressListener, progressRequestListener); + setTaskTagsCall(tagObjects, taskName, progressListener, progressRequestListener); return call; } /** * Adds the tag to the task * - * @param body (required) + * @param tagObjects (required) * @param taskName (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void setTaskTags(List body, String taskName) throws ApiException { - setTaskTagsWithHttpInfo(body, taskName); + public void setTaskTags(List tagObjects, String taskName) throws ApiException { + setTaskTagsWithHttpInfo(tagObjects, taskName); } /** * Adds the tag to the task * - * @param body (required) + * @param tagObjects (required) * @param taskName (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse setTaskTagsWithHttpInfo(List body, String taskName) + private ApiResponse setTaskTagsWithHttpInfo(List tagObjects, String taskName) throws ApiException { - com.squareup.okhttp.Call call = setTaskTagsValidateBeforeCall(body, taskName, null, null); + com.squareup.okhttp.Call call = + setTaskTagsValidateBeforeCall(tagObjects, taskName, null, null); return apiClient.execute(call); } /** * Build call for setWorkflowTags * - * @param body (required) + * @param tagObjects (required) * @param name (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -1032,12 +1037,12 @@ private ApiResponse setTaskTagsWithHttpInfo(List body, String t * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call setWorkflowTagsCall( - List body, + List tagObjects, String name, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = tagObjects; // create path and map variables String localVarPath = @@ -1099,15 +1104,15 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call setWorkflowTagsValidateBeforeCall( - List body, + List tagObjects, String name, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (tagObjects == null) { throw new ApiException( - "Missing the required parameter 'body' when calling setWorkflowTags(Async)"); + "Missing the required parameter 'tagObjects' when calling setWorkflowTags(Async)"); } // verify the required parameter 'name' is set if (name == null) { @@ -1116,34 +1121,35 @@ private com.squareup.okhttp.Call setWorkflowTagsValidateBeforeCall( } com.squareup.okhttp.Call call = - setWorkflowTagsCall(body, name, progressListener, progressRequestListener); + setWorkflowTagsCall(tagObjects, name, progressListener, progressRequestListener); return call; } /** * Set the tags of the workflow * - * @param body (required) + * @param tagObjects (required) * @param name (required) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void setWorkflowTags(List body, String name) throws ApiException { - setWorkflowTagsWithHttpInfo(body, name); + public void setWorkflowTags(List tagObjects, String name) throws ApiException { + setWorkflowTagsWithHttpInfo(tagObjects, name); } /** * Set the tags of the workflow * - * @param body (required) + * @param tagObjects (required) * @param name (required) * @return ApiResponse<Void> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse setWorkflowTagsWithHttpInfo(List body, String name) + private ApiResponse setWorkflowTagsWithHttpInfo(List tagObjects, String name) throws ApiException { - com.squareup.okhttp.Call call = setWorkflowTagsValidateBeforeCall(body, name, null, null); + com.squareup.okhttp.Call call = + setWorkflowTagsValidateBeforeCall(tagObjects, name, null, null); return apiClient.execute(call); } } diff --git a/src/main/java/io/orkes/conductor/client/http/api/TaskResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/TaskResourceApi.java index a31b16cb..99d2c2bf 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/TaskResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/TaskResourceApi.java @@ -1829,18 +1829,18 @@ private ApiResponse> sizeWithHttpInfo(List taskType /** * Build call for updateTask * - * @param body (required) + * @param taskResult (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call updateTaskCall( - TaskResult body, + TaskResult taskResult, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = taskResult; // create path and map variables String localVarPath = "/tasks"; @@ -1898,44 +1898,44 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call updateTaskValidateBeforeCall( - TaskResult body, + TaskResult taskResult, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (taskResult == null) { throw new ApiException( - "Missing the required parameter 'body' when calling updateTask(Async)"); + "Missing the required parameter 'taskResult' when calling updateTask(Async)"); } com.squareup.okhttp.Call call = - updateTaskCall(body, progressListener, progressRequestListener); + updateTaskCall(taskResult, progressListener, progressRequestListener); return call; } /** * Update a task * - * @param body (required) + * @param taskResult (required) * @return String * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public String updateTask(TaskResult body) throws ApiException { - ApiResponse resp = updateTaskWithHttpInfo(body); + public String updateTask(TaskResult taskResult) throws ApiException { + ApiResponse resp = updateTaskWithHttpInfo(taskResult); return resp.getData(); } /** * Update a task * - * @param body (required) + * @param taskResult (required) * @return ApiResponse<String> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse updateTaskWithHttpInfo(TaskResult body) throws ApiException { - com.squareup.okhttp.Call call = updateTaskValidateBeforeCall(body, null, null); + private ApiResponse updateTaskWithHttpInfo(TaskResult taskResult) throws ApiException { + com.squareup.okhttp.Call call = updateTaskValidateBeforeCall(taskResult, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } diff --git a/src/main/java/io/orkes/conductor/client/http/api/TokenResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/TokenResourceApi.java index 3dff6e68..124fa668 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/TokenResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/TokenResourceApi.java @@ -30,7 +30,7 @@ public class TokenResourceApi { * Build call for generateToken * * @param apiClient ApiClient (required) - * @param body (required) + * @param generateTokenRequest (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute @@ -38,11 +38,11 @@ public class TokenResourceApi { */ public static com.squareup.okhttp.Call generateTokenCall( ApiClient apiClient, - GenerateTokenRequest body, + GenerateTokenRequest generateTokenRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = generateTokenRequest; // create path and map variables String localVarPath = "/token"; @@ -101,18 +101,19 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private static com.squareup.okhttp.Call generateTokenValidateBeforeCall( ApiClient apiClient, - GenerateTokenRequest body, + GenerateTokenRequest generateTokenRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (generateTokenRequest == null) { throw new ApiException( - "Missing the required parameter 'body' when calling generateToken(Async)"); + "Missing the required parameter 'generateTokenRequest' when calling generateToken(Async)"); } com.squareup.okhttp.Call call = - generateTokenCall(apiClient, body, progressListener, progressRequestListener); + generateTokenCall( + apiClient, generateTokenRequest, progressListener, progressRequestListener); return call; } @@ -120,15 +121,15 @@ private static com.squareup.okhttp.Call generateTokenValidateBeforeCall( * Generate JWT with the given access key * * @param apiClient ApiClient (required) - * @param body (required) + * @param generateTokenRequest (required) * @return ApiResponse<Response> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ public static ApiResponse> generateTokenWithHttpInfo( - ApiClient apiClient, GenerateTokenRequest body) throws ApiException { + ApiClient apiClient, GenerateTokenRequest generateTokenRequest) throws ApiException { com.squareup.okhttp.Call call = - generateTokenValidateBeforeCall(apiClient, body, null, null); + generateTokenValidateBeforeCall(apiClient, generateTokenRequest, null, null); Type localVarReturnType = new TypeToken>() {}.getType(); return apiClient.execute(call, localVarReturnType); } diff --git a/src/main/java/io/orkes/conductor/client/http/api/UserResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/UserResourceApi.java index 23d8d2fc..2eabfd07 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/UserResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/UserResourceApi.java @@ -514,7 +514,7 @@ private ApiResponse> listUsersWithHttpInfo(Boolean apps) * Build call for sendInviteEmail * * @param id (required) - * @param body (optional) + * @param conductorUser (optional) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute @@ -522,11 +522,11 @@ private ApiResponse> listUsersWithHttpInfo(Boolean apps) */ public com.squareup.okhttp.Call sendInviteEmailCall( String id, - ConductorUser body, + ConductorUser conductorUser, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = conductorUser; // create path and map variables String localVarPath = @@ -587,7 +587,7 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call sendInviteEmailValidateBeforeCall( String id, - ConductorUser body, + ConductorUser conductorUser, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { @@ -598,7 +598,7 @@ private com.squareup.okhttp.Call sendInviteEmailValidateBeforeCall( } com.squareup.okhttp.Call call = - sendInviteEmailCall(id, body, progressListener, progressRequestListener); + sendInviteEmailCall(id, conductorUser, progressListener, progressRequestListener); return call; } @@ -606,26 +606,27 @@ private com.squareup.okhttp.Call sendInviteEmailValidateBeforeCall( * Send an email with a link to this cluster * * @param id (required) - * @param body (optional) + * @param conductorUser (optional) * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public void sendInviteEmail(String id, ConductorUser body) throws ApiException { - sendInviteEmailWithHttpInfo(id, body); + public void sendInviteEmail(String id, ConductorUser conductorUser) throws ApiException { + sendInviteEmailWithHttpInfo(id, conductorUser); } /** * Send an email with a link to this cluster * * @param id (required) - * @param body (optional) + * @param conductorUser (optional) * @return ApiResponse<Object> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse sendInviteEmailWithHttpInfo(String id, ConductorUser body) + private ApiResponse sendInviteEmailWithHttpInfo(String id, ConductorUser conductorUser) throws ApiException { - com.squareup.okhttp.Call call = sendInviteEmailValidateBeforeCall(id, body, null, null); + com.squareup.okhttp.Call call = + sendInviteEmailValidateBeforeCall(id, conductorUser, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } @@ -633,7 +634,7 @@ private ApiResponse sendInviteEmailWithHttpInfo(String id, ConductorUser /** * Build call for upsertUser * - * @param body (required) + * @param upsertUserRequest (required) * @param id (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -641,12 +642,12 @@ private ApiResponse sendInviteEmailWithHttpInfo(String id, ConductorUser * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call upsertUserCall( - UpsertUserRequest body, + UpsertUserRequest upsertUserRequest, String id, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = upsertUserRequest; // create path and map variables String localVarPath = @@ -706,15 +707,15 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call upsertUserValidateBeforeCall( - UpsertUserRequest body, + UpsertUserRequest upsertUserRequest, String id, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (upsertUserRequest == null) { throw new ApiException( - "Missing the required parameter 'body' when calling upsertUser(Async)"); + "Missing the required parameter 'upsertUserRequest' when calling upsertUser(Async)"); } // verify the required parameter 'id' is set if (id == null) { @@ -723,36 +724,38 @@ private com.squareup.okhttp.Call upsertUserValidateBeforeCall( } com.squareup.okhttp.Call call = - upsertUserCall(body, id, progressListener, progressRequestListener); + upsertUserCall(upsertUserRequest, id, progressListener, progressRequestListener); return call; } /** * Create or update a user * - * @param body (required) + * @param upsertUserRequest (required) * @param id (required) * @return Object * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public ConductorUser upsertUser(UpsertUserRequest body, String id) throws ApiException { - ApiResponse resp = upsertUserWithHttpInfo(body, id); + public ConductorUser upsertUser(UpsertUserRequest upsertUserRequest, String id) + throws ApiException { + ApiResponse resp = upsertUserWithHttpInfo(upsertUserRequest, id); return resp.getData(); } /** * Create or update a user * - * @param body (required) + * @param upsertUserRequest (required) * @param id (required) * @return ApiResponse<Object> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse upsertUserWithHttpInfo(UpsertUserRequest body, String id) - throws ApiException { - com.squareup.okhttp.Call call = upsertUserValidateBeforeCall(body, id, null, null); + private ApiResponse upsertUserWithHttpInfo( + UpsertUserRequest upsertUserRequest, String id) throws ApiException { + com.squareup.okhttp.Call call = + upsertUserValidateBeforeCall(upsertUserRequest, id, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } diff --git a/src/main/java/io/orkes/conductor/client/http/api/WorkflowBulkResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/WorkflowBulkResourceApi.java index ab203bc8..57b4f99d 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/WorkflowBulkResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/WorkflowBulkResourceApi.java @@ -48,18 +48,18 @@ public void setApiClient(ApiClient apiClient) { /** * Build call for pauseWorkflow1 * - * @param body (required) + * @param workflowIds (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call pauseWorkflow1Call( - List body, + List workflowIds, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = workflowIds; // create path and map variables String localVarPath = "/workflow/bulk/pause"; @@ -117,93 +117,52 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call pauseWorkflow1ValidateBeforeCall( - List body, + List workflowIds, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (workflowIds == null) { throw new ApiException( "Missing the required parameter 'body' when calling pauseWorkflow1(Async)"); } com.squareup.okhttp.Call call = - pauseWorkflow1Call(body, progressListener, progressRequestListener); + pauseWorkflow1Call(workflowIds, progressListener, progressRequestListener); return call; } /** * Pause the list of workflows * - * @param body (required) + * @param workflowIds (required) * @return BulkResponse * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public BulkResponse pauseWorkflow1(List body) throws ApiException { - ApiResponse resp = pauseWorkflow1WithHttpInfo(body); + public BulkResponse pauseWorkflow1(List workflowIds) throws ApiException { + ApiResponse resp = pauseWorkflow1WithHttpInfo(workflowIds); return resp.getData(); } /** * Pause the list of workflows * - * @param body (required) + * @param workflowIds (required) * @return ApiResponse<BulkResponse> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse pauseWorkflow1WithHttpInfo(List body) + private ApiResponse pauseWorkflow1WithHttpInfo(List workflowIds) throws ApiException { - com.squareup.okhttp.Call call = pauseWorkflow1ValidateBeforeCall(body, null, null); + com.squareup.okhttp.Call call = pauseWorkflow1ValidateBeforeCall(workflowIds, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } - - /** - * Pause the list of workflows (asynchronously) - * - * @param body (required) - * @param callback The callback to be executed when the API call finishes - * @return The request call - * @throws ApiException If fail to process the API call, e.g. serializing the request body - * object - */ - public com.squareup.okhttp.Call pauseWorkflow1Async( - List body, final ApiCallback callback) throws ApiException { - - ProgressResponseBody.ProgressListener progressListener = null; - ProgressRequestBody.ProgressRequestListener progressRequestListener = null; - - if (callback != null) { - progressListener = - new ProgressResponseBody.ProgressListener() { - @Override - public void update(long bytesRead, long contentLength, boolean done) { - callback.onDownloadProgress(bytesRead, contentLength, done); - } - }; - - progressRequestListener = - new ProgressRequestBody.ProgressRequestListener() { - @Override - public void onRequestProgress( - long bytesWritten, long contentLength, boolean done) { - callback.onUploadProgress(bytesWritten, contentLength, done); - } - }; - } - - com.squareup.okhttp.Call call = - pauseWorkflow1ValidateBeforeCall(body, progressListener, progressRequestListener); - Type localVarReturnType = new TypeToken() {}.getType(); - apiClient.executeAsync(call, localVarReturnType, callback); - return call; - } /** * Build call for restart1 * - * @param body (required) + * @param workflowIds (required) * @param useLatestDefinitions (optional, default to false) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -211,12 +170,12 @@ public void onRequestProgress( * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call restart1Call( - List body, + List workflowIds, Boolean useLatestDefinitions, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = workflowIds; // create path and map variables String localVarPath = "/workflow/bulk/restart"; @@ -277,114 +236,69 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call restart1ValidateBeforeCall( - List body, + List workflowIds, Boolean useLatestDefinitions, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (workflowIds == null) { throw new ApiException( "Missing the required parameter 'body' when calling restart1(Async)"); } com.squareup.okhttp.Call call = - restart1Call(body, useLatestDefinitions, progressListener, progressRequestListener); + restart1Call(workflowIds, useLatestDefinitions, progressListener, progressRequestListener); return call; } /** * Restart the list of completed workflow * - * @param body (required) + * @param workflowIds (required) * @param useLatestDefinitions (optional, default to false) * @return BulkResponse * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public BulkResponse restart1(List body, Boolean useLatestDefinitions) + public BulkResponse restart1(List workflowIds, Boolean useLatestDefinitions) throws ApiException { - ApiResponse resp = restart1WithHttpInfo(body, useLatestDefinitions); + ApiResponse resp = restart1WithHttpInfo(workflowIds, useLatestDefinitions); return resp.getData(); } /** * Restart the list of completed workflow * - * @param body (required) + * @param workflowIds (required) * @param useLatestDefinitions (optional, default to false) * @return ApiResponse<BulkResponse> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ private ApiResponse restart1WithHttpInfo( - List body, Boolean useLatestDefinitions) throws ApiException { + List workflowIds, Boolean useLatestDefinitions) throws ApiException { com.squareup.okhttp.Call call = - restart1ValidateBeforeCall(body, useLatestDefinitions, null, null); + restart1ValidateBeforeCall(workflowIds, useLatestDefinitions, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } - /** - * Restart the list of completed workflow (asynchronously) - * - * @param body (required) - * @param useLatestDefinitions (optional, default to false) - * @param callback The callback to be executed when the API call finishes - * @return The request call - * @throws ApiException If fail to process the API call, e.g. serializing the request body - * object - */ - public com.squareup.okhttp.Call restart1Async( - List body, - Boolean useLatestDefinitions, - final ApiCallback callback) - throws ApiException { - - ProgressResponseBody.ProgressListener progressListener = null; - ProgressRequestBody.ProgressRequestListener progressRequestListener = null; - - if (callback != null) { - progressListener = - new ProgressResponseBody.ProgressListener() { - @Override - public void update(long bytesRead, long contentLength, boolean done) { - callback.onDownloadProgress(bytesRead, contentLength, done); - } - }; - - progressRequestListener = - new ProgressRequestBody.ProgressRequestListener() { - @Override - public void onRequestProgress( - long bytesWritten, long contentLength, boolean done) { - callback.onUploadProgress(bytesWritten, contentLength, done); - } - }; - } - - com.squareup.okhttp.Call call = - restart1ValidateBeforeCall( - body, useLatestDefinitions, progressListener, progressRequestListener); - Type localVarReturnType = new TypeToken() {}.getType(); - apiClient.executeAsync(call, localVarReturnType, callback); - return call; - } /** * Build call for resumeWorkflow1 * - * @param body (required) + * @param workflowIds (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call resumeWorkflow1Call( - List body, + List workflowIds, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = workflowIds; // create path and map variables String localVarPath = "/workflow/bulk/resume"; @@ -442,104 +356,64 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call resumeWorkflow1ValidateBeforeCall( - List body, + List workflowIds, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (workflowIds == null) { throw new ApiException( "Missing the required parameter 'body' when calling resumeWorkflow1(Async)"); } com.squareup.okhttp.Call call = - resumeWorkflow1Call(body, progressListener, progressRequestListener); + resumeWorkflow1Call(workflowIds, progressListener, progressRequestListener); return call; } /** * Resume the list of workflows * - * @param body (required) + * @param workflowIds (required) * @return BulkResponse * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public BulkResponse resumeWorkflow1(List body) throws ApiException { - ApiResponse resp = resumeWorkflow1WithHttpInfo(body); + public BulkResponse resumeWorkflow1(List workflowIds) throws ApiException { + ApiResponse resp = resumeWorkflow1WithHttpInfo(workflowIds); return resp.getData(); } /** * Resume the list of workflows * - * @param body (required) + * @param workflowIds (required) * @return ApiResponse<BulkResponse> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse resumeWorkflow1WithHttpInfo(List body) + private ApiResponse resumeWorkflow1WithHttpInfo(List workflowIds) throws ApiException { - com.squareup.okhttp.Call call = resumeWorkflow1ValidateBeforeCall(body, null, null); + com.squareup.okhttp.Call call = resumeWorkflow1ValidateBeforeCall(workflowIds, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } - /** - * Resume the list of workflows (asynchronously) - * - * @param body (required) - * @param callback The callback to be executed when the API call finishes - * @return The request call - * @throws ApiException If fail to process the API call, e.g. serializing the request body - * object - */ - public com.squareup.okhttp.Call resumeWorkflow1Async( - List body, final ApiCallback callback) throws ApiException { - - ProgressResponseBody.ProgressListener progressListener = null; - ProgressRequestBody.ProgressRequestListener progressRequestListener = null; - - if (callback != null) { - progressListener = - new ProgressResponseBody.ProgressListener() { - @Override - public void update(long bytesRead, long contentLength, boolean done) { - callback.onDownloadProgress(bytesRead, contentLength, done); - } - }; - - progressRequestListener = - new ProgressRequestBody.ProgressRequestListener() { - @Override - public void onRequestProgress( - long bytesWritten, long contentLength, boolean done) { - callback.onUploadProgress(bytesWritten, contentLength, done); - } - }; - } - - com.squareup.okhttp.Call call = - resumeWorkflow1ValidateBeforeCall(body, progressListener, progressRequestListener); - Type localVarReturnType = new TypeToken() {}.getType(); - apiClient.executeAsync(call, localVarReturnType, callback); - return call; - } /** * Build call for retry1 * - * @param body (required) + * @param workflowIds (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call retry1Call( - List body, + List workflowIds, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = workflowIds; // create path and map variables String localVarPath = "/workflow/bulk/retry"; @@ -597,91 +471,51 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call retry1ValidateBeforeCall( - List body, + List workflowIds, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (workflowIds == null) { throw new ApiException( "Missing the required parameter 'body' when calling retry1(Async)"); } - com.squareup.okhttp.Call call = retry1Call(body, progressListener, progressRequestListener); + com.squareup.okhttp.Call call = retry1Call(workflowIds, progressListener, progressRequestListener); return call; } /** * Retry the last failed task for each workflow from the list * - * @param body (required) + * @param workflowIds (required) * @return BulkResponse * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public BulkResponse retry1(List body) throws ApiException { - ApiResponse resp = retry1WithHttpInfo(body); + public BulkResponse retry1(List workflowIds) throws ApiException { + ApiResponse resp = retry1WithHttpInfo(workflowIds); return resp.getData(); } /** * Retry the last failed task for each workflow from the list * - * @param body (required) + * @param workflowIds (required) * @return ApiResponse<BulkResponse> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse retry1WithHttpInfo(List body) throws ApiException { - com.squareup.okhttp.Call call = retry1ValidateBeforeCall(body, null, null); + private ApiResponse retry1WithHttpInfo(List workflowIds) throws ApiException { + com.squareup.okhttp.Call call = retry1ValidateBeforeCall(workflowIds, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } - /** - * Retry the last failed task for each workflow from the list (asynchronously) - * - * @param body (required) - * @param callback The callback to be executed when the API call finishes - * @return The request call - * @throws ApiException If fail to process the API call, e.g. serializing the request body - * object - */ - public com.squareup.okhttp.Call retry1Async( - List body, final ApiCallback callback) throws ApiException { - - ProgressResponseBody.ProgressListener progressListener = null; - ProgressRequestBody.ProgressRequestListener progressRequestListener = null; - - if (callback != null) { - progressListener = - new ProgressResponseBody.ProgressListener() { - @Override - public void update(long bytesRead, long contentLength, boolean done) { - callback.onDownloadProgress(bytesRead, contentLength, done); - } - }; - - progressRequestListener = - new ProgressRequestBody.ProgressRequestListener() { - @Override - public void onRequestProgress( - long bytesWritten, long contentLength, boolean done) { - callback.onUploadProgress(bytesWritten, contentLength, done); - } - }; - } - - com.squareup.okhttp.Call call = - retry1ValidateBeforeCall(body, progressListener, progressRequestListener); - Type localVarReturnType = new TypeToken() {}.getType(); - apiClient.executeAsync(call, localVarReturnType, callback); - return call; - } /** * Build call for terminate * - * @param body (required) + * @param workflowIds (required) * @param reason (optional) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -689,12 +523,12 @@ public void onRequestProgress( * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call terminateCall( - List body, + List workflowIds, String reason, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = workflowIds; // create path and map variables String localVarPath = "/workflow/bulk/terminate"; @@ -753,93 +587,50 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call terminateValidateBeforeCall( - List body, + List workflowIds, String reason, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (workflowIds == null) { throw new ApiException( "Missing the required parameter 'body' when calling terminate(Async)"); } com.squareup.okhttp.Call call = - terminateCall(body, reason, progressListener, progressRequestListener); + terminateCall(workflowIds, reason, progressListener, progressRequestListener); return call; } /** * Terminate workflows execution * - * @param body (required) + * @param workflowIds (required) * @param reason (optional) * @return BulkResponse * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public BulkResponse terminate(List body, String reason) throws ApiException { - ApiResponse resp = terminateWithHttpInfo(body, reason); + public BulkResponse terminate(List workflowIds, String reason) throws ApiException { + ApiResponse resp = terminateWithHttpInfo(workflowIds, reason); return resp.getData(); } /** * Terminate workflows execution * - * @param body (required) + * @param workflowIds (required) * @param reason (optional) * @return ApiResponse<BulkResponse> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse terminateWithHttpInfo(List body, String reason) + private ApiResponse terminateWithHttpInfo(List workflowIds, String reason) throws ApiException { - com.squareup.okhttp.Call call = terminateValidateBeforeCall(body, reason, null, null); + com.squareup.okhttp.Call call = terminateValidateBeforeCall(workflowIds, reason, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } - /** - * Terminate workflows execution (asynchronously) - * - * @param body (required) - * @param reason (optional) - * @param callback The callback to be executed when the API call finishes - * @return The request call - * @throws ApiException If fail to process the API call, e.g. serializing the request body - * object - */ - public com.squareup.okhttp.Call terminateAsync( - List body, String reason, final ApiCallback callback) - throws ApiException { - - ProgressResponseBody.ProgressListener progressListener = null; - ProgressRequestBody.ProgressRequestListener progressRequestListener = null; - - if (callback != null) { - progressListener = - new ProgressResponseBody.ProgressListener() { - @Override - public void update(long bytesRead, long contentLength, boolean done) { - callback.onDownloadProgress(bytesRead, contentLength, done); - } - }; - - progressRequestListener = - new ProgressRequestBody.ProgressRequestListener() { - @Override - public void onRequestProgress( - long bytesWritten, long contentLength, boolean done) { - callback.onUploadProgress(bytesWritten, contentLength, done); - } - }; - } - - com.squareup.okhttp.Call call = - terminateValidateBeforeCall( - body, reason, progressListener, progressRequestListener); - Type localVarReturnType = new TypeToken() {}.getType(); - apiClient.executeAsync(call, localVarReturnType, callback); - return call; - } } diff --git a/src/main/java/io/orkes/conductor/client/http/api/WorkflowResourceApi.java b/src/main/java/io/orkes/conductor/client/http/api/WorkflowResourceApi.java index 5b33afcb..aa83e6b9 100644 --- a/src/main/java/io/orkes/conductor/client/http/api/WorkflowResourceApi.java +++ b/src/main/java/io/orkes/conductor/client/http/api/WorkflowResourceApi.java @@ -1294,7 +1294,7 @@ private ApiResponse pauseWorkflowWithHttpInfo(String workflowId) throws Ap /** * Build call for rerun * - * @param body (required) + * @param rerunWorkflowRequest (required) * @param workflowId (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener @@ -1302,12 +1302,12 @@ private ApiResponse pauseWorkflowWithHttpInfo(String workflowId) throws Ap * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call rerunCall( - RerunWorkflowRequest body, + RerunWorkflowRequest rerunWorkflowRequest, String workflowId, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = rerunWorkflowRequest; // create path and map variables String localVarPath = @@ -1369,15 +1369,15 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call rerunValidateBeforeCall( - RerunWorkflowRequest body, + RerunWorkflowRequest rerunWorkflowRequest, String workflowId, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (rerunWorkflowRequest == null) { throw new ApiException( - "Missing the required parameter 'body' when calling rerun(Async)"); + "Missing the required parameter 'rerunWorkflowRequest' when calling rerun(Async)"); } // verify the required parameter 'workflowId' is set if (workflowId == null) { @@ -1386,36 +1386,42 @@ private com.squareup.okhttp.Call rerunValidateBeforeCall( } com.squareup.okhttp.Call call = - rerunCall(body, workflowId, progressListener, progressRequestListener); + rerunCall( + rerunWorkflowRequest, + workflowId, + progressListener, + progressRequestListener); return call; } /** * Reruns the workflow from a specific task * - * @param body (required) + * @param rerunWorkflowRequest (required) * @param workflowId (required) * @return String * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public String rerun(RerunWorkflowRequest body, String workflowId) throws ApiException { - ApiResponse resp = rerunWithHttpInfo(body, workflowId); + public String rerun(RerunWorkflowRequest rerunWorkflowRequest, String workflowId) + throws ApiException { + ApiResponse resp = rerunWithHttpInfo(rerunWorkflowRequest, workflowId); return resp.getData(); } /** * Reruns the workflow from a specific task * - * @param body (required) + * @param rerunWorkflowRequest (required) * @param workflowId (required) * @return ApiResponse<String> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse rerunWithHttpInfo(RerunWorkflowRequest body, String workflowId) - throws ApiException { - com.squareup.okhttp.Call call = rerunValidateBeforeCall(body, workflowId, null, null); + private ApiResponse rerunWithHttpInfo( + RerunWorkflowRequest rerunWorkflowRequest, String workflowId) throws ApiException { + com.squareup.okhttp.Call call = + rerunValidateBeforeCall(rerunWorkflowRequest, workflowId, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } @@ -2717,18 +2723,18 @@ private ApiResponse skipTaskFromWorkflowWithHttpInfo( /** * Build call for startWorkflow * - * @param body (required) + * @param startWorkflowRequest (required) * @param progressListener Progress listener * @param progressRequestListener Progress request listener * @return Call to execute * @throws ApiException If fail to serialize the request body object */ public com.squareup.okhttp.Call startWorkflowCall( - StartWorkflowRequest body, + StartWorkflowRequest startWorkflowRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { - Object localVarPostBody = body; + Object localVarPostBody = startWorkflowRequest; // create path and map variables String localVarPath = "/workflow"; @@ -2786,45 +2792,46 @@ public com.squareup.okhttp.Response intercept( @SuppressWarnings("rawtypes") private com.squareup.okhttp.Call startWorkflowValidateBeforeCall( - StartWorkflowRequest body, + StartWorkflowRequest startWorkflowRequest, final ProgressResponseBody.ProgressListener progressListener, final ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException { // verify the required parameter 'body' is set - if (body == null) { + if (startWorkflowRequest == null) { throw new ApiException( - "Missing the required parameter 'body' when calling startWorkflow(Async)"); + "Missing the required parameter 'startWorkflowRequest' when calling startWorkflow(Async)"); } com.squareup.okhttp.Call call = - startWorkflowCall(body, progressListener, progressRequestListener); + startWorkflowCall(startWorkflowRequest, progressListener, progressRequestListener); return call; } /** * Start a new workflow with StartWorkflowRequest, which allows task to be executed in a domain * - * @param body (required) + * @param startWorkflowRequest (required) * @return String * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - public String startWorkflow(StartWorkflowRequest body) throws ApiException { - ApiResponse resp = startWorkflowWithHttpInfo(body); + public String startWorkflow(StartWorkflowRequest startWorkflowRequest) throws ApiException { + ApiResponse resp = startWorkflowWithHttpInfo(startWorkflowRequest); return resp.getData(); } /** * Start a new workflow with StartWorkflowRequest, which allows task to be executed in a domain * - * @param body (required) + * @param startWorkflowRequest (required) * @return ApiResponse<String> * @throws ApiException If fail to call the API, e.g. server error or cannot deserialize the * response body */ - private ApiResponse startWorkflowWithHttpInfo(StartWorkflowRequest body) + private ApiResponse startWorkflowWithHttpInfo(StartWorkflowRequest startWorkflowRequest) throws ApiException { - com.squareup.okhttp.Call call = startWorkflowValidateBeforeCall(body, null, null); + com.squareup.okhttp.Call call = + startWorkflowValidateBeforeCall(startWorkflowRequest, null, null); Type localVarReturnType = new TypeToken() {}.getType(); return apiClient.execute(call, localVarReturnType); } diff --git a/src/test/java/io/orkes/conductor/client/MetadataFromFiles.java b/src/test/java/io/orkes/conductor/client/MetadataFromFiles.java new file mode 100644 index 00000000..2d47d043 --- /dev/null +++ b/src/test/java/io/orkes/conductor/client/MetadataFromFiles.java @@ -0,0 +1,65 @@ +/* + * Copyright 2022 Orkes, Inc. + *

+ * 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 + *

+ * http://www.apache.org/licenses/LICENSE-2.0 + *

+ * 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.client; + +import java.io.IOException; +import java.io.InputStream; +import java.nio.charset.StandardCharsets; +import java.util.List; + +import org.apache.commons.io.IOUtils; +import org.junit.jupiter.api.Assertions; +import org.junit.jupiter.api.DisplayName; +import org.junit.jupiter.api.Test; + +import com.netflix.conductor.common.metadata.tasks.TaskDef; +import com.netflix.conductor.common.metadata.workflow.WorkflowDef; + +import io.orkes.conductor.client.util.ApiUtil; + +import com.fasterxml.jackson.databind.ObjectMapper; + +public class MetadataFromFiles { + private final MetadataClient metadataClient; + + private final ObjectMapper objectMapper = new ObjectMapper(); + + public MetadataFromFiles() { + OrkesClients orkesClients = ApiUtil.getOrkesClient(); + metadataClient = orkesClients.getMetadataClient(); + } + +// @Test +// @DisplayName("load workflow from file and store definition in conductor") +// public void loadAndStoreWorkflowDefinition() throws IOException { +// InputStream inputStream = +// MetadataFromFiles.class.getResourceAsStream("/sample_workflow.json"); +// String result = IOUtils.toString(inputStream, StandardCharsets.UTF_8); +// WorkflowDef workflowDef = objectMapper.readValue(result, WorkflowDef.class); +// // Unregister workflow in case it exist +// metadataClient.unregisterWorkflowDef(workflowDef.getName(), workflowDef.getVersion()); +// metadataClient.registerWorkflowDef(workflowDef); +// Assertions.assertEquals( +// metadataClient.getWorkflowDef(workflowDef.getName(), workflowDef.getVersion()), +// workflowDef); +// } + + @Test + @DisplayName("load tasks from file and store definition in conductor") + public void loadAndStoreTaskDefinitions() throws IOException { + InputStream inputStream = MetadataFromFiles.class.getResourceAsStream("/sample_tasks.json"); + String result = IOUtils.toString(inputStream, StandardCharsets.UTF_8); + List taskDefs = objectMapper.readValue(result, List.class); + metadataClient.registerTaskDefs(taskDefs); + } +} diff --git a/src/test/java/io/orkes/conductor/client/api/AuthorizationClientTests.java b/src/test/java/io/orkes/conductor/client/api/AuthorizationClientTests.java index 4cfc09d7..e1a0fb5c 100644 --- a/src/test/java/io/orkes/conductor/client/api/AuthorizationClientTests.java +++ b/src/test/java/io/orkes/conductor/client/api/AuthorizationClientTests.java @@ -14,11 +14,11 @@ import java.util.*; -import io.orkes.conductor.client.model.*; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; import io.orkes.conductor.client.AuthorizationClient; +import io.orkes.conductor.client.model.*; import io.orkes.conductor.client.model.UpsertGroupRequest.RolesEnum; import static org.junit.jupiter.api.Assertions.assertEquals; @@ -45,31 +45,32 @@ void testAddUser() { request.setName("Orkes User"); request.setGroups(Arrays.asList("Example Group")); request.setRoles(Arrays.asList(UpsertUserRequest.RolesEnum.USER)); - String userId = "user@orkes.io"; //MUST be the email addressed used to login to Conductor + String userId = "user@orkes.io"; // MUST be the email addressed used to login to Conductor ConductorUser user = authorizationClient.upsertUser(request, userId); assertNotNull(user); - ConductorUser found = authorizationClient.getUser(userId); assertNotNull(found); assertEquals(user.getName(), found.getName()); assertEquals(user.getGroups().get(0).getId(), found.getGroups().get(0).getId()); assertEquals(user.getRoles().get(0).getName(), found.getRoles().get(0).getName()); - } @Test void testAddGroup() { UpsertGroupRequest request = new UpsertGroupRequest(); - //Default Access for the group. When specified, any new workflow or task created by the members of this group - //get this default permission inside the group. + // Default Access for the group. When specified, any new workflow or task created by the + // members of this group + // get this default permission inside the group. Map> defaultAccess = new HashMap<>(); - //Grant READ access to the members of the group for any new workflow created by a member of this group + // Grant READ access to the members of the group for any new workflow created by a member of + // this group defaultAccess.put("WORKFLOW_DEF", List.of("READ")); - //Grant EXECUTE access to the members of the group for any new task created by a member of this group + // Grant EXECUTE access to the members of the group for any new task created by a member of + // this group defaultAccess.put("TASK_DEF", List.of("EXECUTE")); request.setDefaultAccess(defaultAccess); @@ -80,35 +81,37 @@ void testAddGroup() { Group group = authorizationClient.upsertGroup(request, groupId); assertNotNull(group); - Group found = authorizationClient.getGroup(groupId); assertNotNull(found); assertEquals(group.getId(), found.getId()); assertEquals(group.getDefaultAccess().keySet(), found.getDefaultAccess().keySet()); - } - @Test void testAddApplication() { CreateOrUpdateApplicationRequest request = new CreateOrUpdateApplicationRequest(); request.setName("Test Application for the testing"); - //WARNING: Application Name is not a UNIQUE value and if called multiple times, it will create a new application + // WARNING: Application Name is not a UNIQUE value and if called multiple times, it will + // create a new application ConductorApplication application = authorizationClient.createApplication(request); assertNotNull(application); assertNotNull(application.getId()); - - //Get the list of applications + // Get the list of applications List apps = authorizationClient.listApplications(); assertNotNull(apps); - long found = apps.stream().map(ConductorApplication::getId).filter(id -> id.equals(application.getId())).count(); + long found = + apps.stream() + .map(ConductorApplication::getId) + .filter(id -> id.equals(application.getId())) + .count(); assertEquals(1, found); - //Create new access key - CreateAccessKeyResponse accessKey = authorizationClient.createAccessKey(application.getId()); + // Create new access key + CreateAccessKeyResponse accessKey = + authorizationClient.createAccessKey(application.getId()); assertNotNull(accessKey.getId()); assertNotNull(accessKey.getSecret()); System.out.println(accessKey.getId() + ":" + accessKey.getSecret()); @@ -119,7 +122,6 @@ void testAddApplication() { @Test void testGrangPermissionsToGroup() { - AuthorizationRequest request = new AuthorizationRequest(); request.access(Arrays.asList(AuthorizationRequest.AccessEnum.READ)); SubjectRef subject = new SubjectRef(); @@ -131,33 +133,27 @@ void testGrangPermissionsToGroup() { target.setType(TargetRef.TypeEnum.WORKFLOW_DEF); request.setTarget(target); authorizationClient.grantPermissions(request); - - } @Test void testGrantPermissionsToTag() { - AuthorizationRequest request = new AuthorizationRequest(); request.access(Arrays.asList(AuthorizationRequest.AccessEnum.READ)); - SubjectRef subject = new SubjectRef(); subject.setId("Example Group"); subject.setType(SubjectRef.TypeEnum.GROUP); request.setSubject(subject); - //Grant permissions to the tag with accounting org + // Grant permissions to the tag with accounting org TargetRef target = new TargetRef(); target.setId("org:accounting"); target.setType(TargetRef.TypeEnum.TAG); request.setTarget(target); authorizationClient.grantPermissions(request); - - } void giveApplicationPermissions(String applicationId) { diff --git a/src/test/resources/sample_tasks.json b/src/test/resources/sample_tasks.json new file mode 100644 index 00000000..46c54bb3 --- /dev/null +++ b/src/test/resources/sample_tasks.json @@ -0,0 +1,59 @@ +[ + { + "createTime": 1651856131126, + "createdBy": "", + "name": "image_compression", + "description": "Edit or extend this sample task. Set the task name to get started", + "retryCount": 3, + "timeoutSeconds": 600, + "inputKeys": [], + "outputKeys": [], + "timeoutPolicy": "ALERT_ONLY", + "retryLogic": "FIXED", + "retryDelaySeconds": 6, + "responseTimeoutSeconds": 10, + "inputTemplate": {}, + "rateLimitPerFrequency": 0, + "rateLimitFrequencyInSeconds": 1, + "ownerEmail": "test@orkes.io", + "backoffScaleFactor": 1 + }, + { + "createTime": 1651853134126, + "createdBy": "", + "name": "download_file_from_ec2", + "description": "Edit or extend this sample task. Set the task name to get started", + "retryCount": 1, + "timeoutSeconds": 300, + "inputKeys": [], + "outputKeys": [], + "timeoutPolicy": "TIME_OUT_WF", + "retryLogic": "FIXED", + "retryDelaySeconds": 3, + "responseTimeoutSeconds": 50, + "inputTemplate": {}, + "rateLimitPerFrequency": 0, + "rateLimitFrequencyInSeconds": 1, + "ownerEmail": "test@orkes.io", + "backoffScaleFactor": 1 + }, + { + "createTime": 1652856134126, + "createdBy": "", + "name": "update_database", + "description": "Edit or extend this sample task. Set the task name to get started", + "retryCount": 3, + "timeoutSeconds": 900, + "inputKeys": [], + "outputKeys": [], + "timeoutPolicy": "TIME_OUT_WF", + "retryLogic": "FIXED", + "retryDelaySeconds": 10, + "responseTimeoutSeconds": 60, + "inputTemplate": {}, + "rateLimitPerFrequency": 0, + "rateLimitFrequencyInSeconds": 1, + "ownerEmail": "test@orkes.io", + "backoffScaleFactor": 1 + } +] \ No newline at end of file diff --git a/src/test/resources/sample_workflow.json b/src/test/resources/sample_workflow.json new file mode 100644 index 00000000..e6723a3e --- /dev/null +++ b/src/test/resources/sample_workflow.json @@ -0,0 +1,117 @@ +{ + "name": "Do_While_Workflow", + "description": "Do_While_Workflow", + "version": 1, + "tasks": [ + { + "name": "loopTask", + "taskReferenceName": "loopTask", + "inputParameters": { + "value": "${workflow.input.loop}" + }, + "type": "DO_WHILE", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopCondition": "if ($.loopTask['iteration'] < $.value) { true; } else { false;} ", + "loopOver": [ + { + "name": "integration_task_0", + "taskReferenceName": "integration_task_0", + "inputParameters": {}, + "type": "SIMPLE", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [] + }, + { + "name": "fork", + "taskReferenceName": "fork", + "inputParameters": {}, + "type": "FORK_JOIN", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [ + [ + { + "name": "integration_task_1", + "taskReferenceName": "integration_task_1", + "inputParameters": {}, + "type": "SIMPLE", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [] + } + ], + [ + { + "name": "integration_task_2", + "taskReferenceName": "integration_task_2", + "inputParameters": {}, + "type": "SIMPLE", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [] + } + ] + ], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [] + }, + { + "name": "join", + "taskReferenceName": "join", + "inputParameters": {}, + "type": "JOIN", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [ + "integration_task_1", + "integration_task_2" + ], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [] + } + ] + } + ], + "inputParameters": [], + "outputParameters": {}, + "schemaVersion": 2, + "restartable": true, + "workflowStatusListenerEnabled": false, + "timeoutPolicy": "ALERT_ONLY", + "timeoutSeconds": 0, + "ownerEmail": "test@harness.com" +} \ No newline at end of file