Skip to content

Commit

Permalink
Improve job handling
Browse files Browse the repository at this point in the history
  • Loading branch information
seppinho committed Jul 20, 2023
1 parent 181973f commit 9d36649
Showing 1 changed file with 1 addition and 21 deletions.
22 changes: 1 addition & 21 deletions src/main/java/cloudgene/mapred/jobs/WorkflowEngine.java
Original file line number Diff line number Diff line change
Expand Up @@ -231,33 +231,13 @@ public List<AbstractJob> getAllJobsInShortTimeQueue() {

List<AbstractJob> jobs = shortTimeQueue.getAllJobs();

for (AbstractJob job : jobs) {

if (job instanceof CloudgeneJob) {

((CloudgeneJob) job).updateProgress();

}

}

return shortTimeQueue.getAllJobs();
return jobs;
}

public List<AbstractJob> getAllJobsInLongTimeQueue() {

List<AbstractJob> jobs = longTimeQueue.getAllJobs();

for (AbstractJob job : jobs) {

if (job instanceof CloudgeneJob) {

((CloudgeneJob) job).updateProgress();

}

}

return jobs;
}

Expand Down

0 comments on commit 9d36649

Please sign in to comment.