Skip to content

Commit

Permalink
code changes for WorkflowBulkResource
Browse files Browse the repository at this point in the history
  • Loading branch information
Shailesh Jagannath Padave committed Nov 18, 2024
1 parent 9906b15 commit f878d5c
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ class WorkflowBulkResource {
this.client = client;
}

BulkResponse pauseWorkflows(List<String> workflowIds) {
BulkResponse<String> pauseWorkflows(List<String> workflowIds) {
ConductorClientRequest request = ConductorClientRequest.builder()
.method(Method.PUT)
.path("/workflow/bulk/pause")
Expand All @@ -44,7 +44,7 @@ BulkResponse pauseWorkflows(List<String> workflowIds) {
return resp.getData();
}

BulkResponse restartWorkflows(List<String> workflowIds, Boolean useLatestDefinitions) {
BulkResponse<String> restartWorkflows(List<String> workflowIds, Boolean useLatestDefinitions) {
ConductorClientRequest request = ConductorClientRequest.builder()
.method(Method.POST)
.path("/workflow/bulk/restart")
Expand All @@ -58,7 +58,7 @@ BulkResponse restartWorkflows(List<String> workflowIds, Boolean useLatestDefinit
return resp.getData();
}

BulkResponse resumeWorkflows(List<String> workflowIds) {
BulkResponse<String> resumeWorkflows(List<String> workflowIds) {
ConductorClientRequest request = ConductorClientRequest.builder()
.method(Method.PUT)
.path("/workflow/bulk/resume")
Expand All @@ -71,7 +71,7 @@ BulkResponse resumeWorkflows(List<String> workflowIds) {
return resp.getData();
}

BulkResponse retryWorkflows(List<String> workflowIds) {
BulkResponse<String> retryWorkflows(List<String> workflowIds) {
ConductorClientRequest request = ConductorClientRequest.builder()
.method(Method.POST)
.path("/workflow/bulk/retry")
Expand Down

0 comments on commit f878d5c

Please sign in to comment.