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

Timestamp:

07/31/13 11:51:18 (12 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/simulator/workload/reader/archive/QcgWAJobReader.java (modified) (3 diffs)

DCWoRMS/branches/coolemall/src/simulator/workload/reader/archive/QcgWAJobReader.java

@@ -17 +17 @@
 import org.qcg.broker.schemas.jobdesc.ResourceConsumptionProfileType;
 import org.qcg.broker.schemas.jobdesc.Task;
+import org.qcg.broker.schemas.jobdesc.Workflow;
 
 import dcworms.schedframe.scheduling.utils.JobDescription;
@@ -76 +77 @@
                         
                         task = createTask(taskData);
-                        if(task != null)
+                        if(task != null){
+                                Workflow workflow = task.getWorkflow();
+                                if(workflow != null){
+                                        String precTaskId = workflow.getParent(0).getContent();
+                                        workflow.getParent(0).setContent(waParser.getIDMapping(precTaskId)[0] + "_" + waParser.getIDMapping(precTaskId)[1]);
+                                }
                                 job.addTask(task);
+                        }
                         taskData = waParser.readTask();
                         if(taskData != null)
@@ -124 +131 @@
                 
                 for(int i = 0; i < job.getTaskCount(); i++){
-                        
-                        JobDescription xmlJobDescription = jobProfilesMap.get(job.getTask(i).getExecution().getExecutable().getApplication().getAppProperty(0).getContent());
-                        if(xmlJobDescription != null){
-                                for(int j = 0; j < xmlJobDescription.size(); j++){
-                                        Task patternTask = xmlJobDescription.getDescription().getTask(j);
-                                        if(patternTask != null){
-                                                ResourceConsumptionProfileType rcp = patternTask.getExecution().getResourceConsumptionProfile();
-                                                job.getTask(j).getExecution().setResourceConsumptionProfile(rcp);
+                        try {
+                                JobDescription xmlJobDescription = jobProfilesMap.get(job.getTask(i).getExecution().getExecutable().getApplication().getAppProperty(0).getContent());
+                                if(xmlJobDescription != null){
+                                        for(int j = 0; j < xmlJobDescription.size(); j++){
+                                                Task patternTask = xmlJobDescription.getDescription().getTask(j);
+                                                if(patternTask != null){
+                                                        ResourceConsumptionProfileType rcp = patternTask.getExecution().getResourceConsumptionProfile();
+                                                        job.getTask(j).getExecution().setResourceConsumptionProfile(rcp);
+                                                }
                                         }
-                                }
+                                }       
+                        } catch (Exception e){
+                                continue;
                         }
                 }