Skip to content

Commit

Permalink
Added missing search operations to OrkesWorkflowClient
Browse files Browse the repository at this point in the history
  • Loading branch information
jmigueprieto committed Sep 6, 2024
1 parent 030fb78 commit 64b6ece
Showing 1 changed file with 11 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,8 @@
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

import com.netflix.conductor.common.run.SearchResult;
import com.netflix.conductor.common.run.WorkflowSummary;
import org.apache.commons.lang3.Validate;
import org.apache.commons.lang3.concurrent.BasicThreadFactory;

Expand All @@ -40,7 +42,7 @@
import io.orkes.conductor.client.model.WorkflowStateUpdate;
import io.orkes.conductor.client.model.WorkflowStatus;

//TODO reset workflow?
//TODO should this extend or not WorkflowClient?
public class OrkesWorkflowClient implements AutoCloseable {

private final WorkflowResource workflowResource;
Expand Down Expand Up @@ -218,6 +220,14 @@ public void skipTaskFromWorkflow(String workflowId, String taskReferenceName) {
workflowClient.skipTaskFromWorkflow(workflowId, taskReferenceName);
}

public SearchResult<WorkflowSummary> search(String query) {
return workflowClient.search(query);
}

public SearchResult<WorkflowSummary> search(Integer start, Integer size, String sort, String freeText, String query) {
return workflowClient.search(start, size, sort, freeText, query);
}

@Override
public void close() {
if (executorService != null) {
Expand Down

0 comments on commit 64b6ece

Please sign in to comment.