You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oodt.apache.org by lu...@apache.org on 2015/07/27 22:56:13 UTC
svn commit: r1692948 -
/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java
Author: luca
Date: Mon Jul 27 20:56:13 2015
New Revision: 1692948
URL: http://svn.apache.org/r1692948
Log:
Printing out the workflow task ids (OODT-861), also when querying the workflows by event.
Modified:
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java
Modified: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java?rev=1692948&r1=1692947&r2=1692948&view=diff
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java (original)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java Mon Jul 27 20:56:13 2015
@@ -22,6 +22,7 @@ import java.util.List;
//OODT imports
import org.apache.oodt.cas.cli.exception.CmdLineActionException;
import org.apache.oodt.cas.workflow.structs.Workflow;
+import org.apache.oodt.cas.workflow.structs.WorkflowTask;
/**
* A {@link CmdLineAction} which get the current list of workflows by
@@ -34,20 +35,29 @@ public class GetWorkflowsByEventCliActio
private String eventName;
@Override
- public void execute(ActionMessagePrinter printer)
- throws CmdLineActionException {
- try {
+ public void execute(ActionMessagePrinter printer) throws CmdLineActionException {
+
+ try {
@SuppressWarnings("unchecked")
List<Workflow> workflows = getClient().getWorkflowsByEvent(eventName);
if (workflows == null) {
throw new Exception("WorkflowManager returned null workflow list");
}
+
for (Workflow workflow : workflows) {
+
+ String taskIds = "";
+ for (WorkflowTask wt : workflow.getTasks()) {
+ if (taskIds.length()>0) taskIds += ", ";
+ taskIds += wt.getTaskId();
+ }
+
printer.println("Workflow: [id=" + workflow.getId() + ", name="
+ workflow.getName() + ", numTasks="
- + workflow.getTasks().size() + "]");
+ + workflow.getTasks().size() + ", taskIds="+taskIds + "]");
}
+
} catch (Exception e) {
throw new CmdLineActionException(
"Failed to get workflows by event name '" + eventName + "' : "
@@ -58,4 +68,5 @@ public class GetWorkflowsByEventCliActio
public void setEventName(String eventName) {
this.eventName = eventName;
}
+
}