Changeset 1160 for DCWoRMS/branches/coolemall/src/simulator

Timestamp:

08/01/13 11:00:19 (12 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/simulator/DCWormsUsers.java (modified) (2 diffs)

DCWoRMS/branches/coolemall/src/simulator/DCWormsUsers.java

@@ -22 +22 @@
 import org.apache.commons.logging.LogFactory;
 import org.joda.time.DateTime;
+import org.qcg.broker.schemas.jobdesc.ParentType;
+import org.qcg.broker.schemas.jobdesc.Workflow;
+import org.qcg.broker.schemas.jobdesc.types.TaskStatesName;
 
 import qcg.shared.constants.BrokerConstants;
@@ -320 +323 @@
                         //              newTask.setSubmissionTime(taskDescription.getSubmissionTime());
                                         
+                                        //ENABLES MERGING PRECEDING CONSTRAINST COMING BOTH FROM SWF AND XML FILES
+                                        /*if(taskDescription.getDescription().getWorkflow() != null){
+                                                String precTaskId = taskDescription.getDescription().getWorkflow().getParent(0).getContent();
+                                                if(     newTask.getDescription().getWorkflow() == null){
+                                                        org.qcg.broker.schemas.resreqs.Workflow workflow = new org.qcg.broker.schemas.resreqs.Workflow();
+                                                        org.qcg.broker.schemas.resreqs.ParentType parent = new org.qcg.broker.schemas.resreqs.ParentType();
+                                                        parent.setTriggerState(org.qcg.broker.schemas.resreqs.types.TaskStatesName.FINISHED);
+                                                        parent.setContent(precTaskId);
+                                                        workflow.addParent(parent);
+                                                        newTask.getDescription().setWorkflow(workflow);
+                                                }
+                                        }*/
                                         newJob.add(newTask);
                                 }
-
+                                newJob.setStatus((int)BrokerConstants.JOB_STATUS_UNSUBMITTED);
                                 jobDescription.discardUnused();