diff --git a/conductor-clients/java/conductor-java-sdk/orkes-client/src/main/java/io/orkes/conductor/client/http/OrkesWorkflowClient.java b/conductor-clients/java/conductor-java-sdk/orkes-client/src/main/java/io/orkes/conductor/client/http/OrkesWorkflowClient.java index 22b3a99fa..78d2b35eb 100644 --- a/conductor-clients/java/conductor-java-sdk/orkes-client/src/main/java/io/orkes/conductor/client/http/OrkesWorkflowClient.java +++ b/conductor-clients/java/conductor-java-sdk/orkes-client/src/main/java/io/orkes/conductor/client/http/OrkesWorkflowClient.java @@ -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; @@ -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; @@ -218,6 +220,14 @@ public void skipTaskFromWorkflow(String workflowId, String taskReferenceName) { workflowClient.skipTaskFromWorkflow(workflowId, taskReferenceName); } + public SearchResult search(String query) { + return workflowClient.search(query); + } + + public SearchResult 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) {