alirezazamani commented on a change in pull request #410: Fix the execution 
delay for the jobs (409)

 File path: 
 @@ -165,7 +165,9 @@ public void updateWorkflowStatus(String workflow, 
WorkflowConfig workflowCfg,
     RuntimeJobDag runtimeJobDag = 
     if (runtimeJobDag != null) {
       for (String inflightJob : runtimeJobDag.getInflightJobList()) {
-        processJob(inflightJob, currentStateOutput, bestPossibleOutput, 
+        if (System.currentTimeMillis() >= 
workflowCtx.getJobStartTime(inflightJob)) {
 Review comment:
   Thank you for your comments.
   1- Based on same logic that is added few lines below (which calculates the 
start time and store these information and process the job if possible), this 
is the place that this check should happen. (same as the scheduleJobs method in 
   2- About the comprehensive change, I agree with you. This is just a quick 
fix. We will need to revisit several concepts such as inflight jobs and retry 
delay. I am working on the retry delay and will create new issue for that as 
well. After that we can think on a comprehensive changes to the Task Framework.

This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:

With regards,
Apache Git Services

To unsubscribe, e-mail:
For additional commands, e-mail:

Reply via email to