Skip to content
This repository has been archived by the owner on May 26, 2020. It is now read-only.

Commit

Permalink
Merge 5e8e242 into 43ca149
Browse files Browse the repository at this point in the history
  • Loading branch information
benouaer committed Sep 7, 2018
2 parents 43ca149 + 5e8e242 commit 2a79c57
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ public void fetchUnassignedJobs() {

final UUID workerId = randomUUID();

logger.info("Retrieving new work from jobstore for WorkerID [{}]", workerId);
logger.debug("Retrieving new work from jobstore for WorkerID [{}]", workerId);

Stream<Job> unassignedJobs = null;

Expand Down Expand Up @@ -146,11 +146,11 @@ public void fetchUnassignedJobs() {
}

private void execute(Stream<Job> jobsToDo) {
logger.info("Trigger task execution:");
jobsToDo.forEach(job -> {
logger.trace("Trigger task execution:");
final JobExecutor task = new JobExecutor(job, taskRegistry, jobService, userTransaction);
executorService.submit(task);
logger.trace("Invocation of Task complete");
});
logger.info("Invocation of Task complete");
}
}

0 comments on commit 2a79c57

Please sign in to comment.