Merge pull request #811 from rcordovano/develop

Add ingest job start/finish log messages
This commit is contained in:
Richard Cordovano 2014-07-10 11:23:05 -04:00
commit 657a987d60

View File

@ -112,6 +112,7 @@ final class IngestScheduler {
ingestJobsById.put(jobId, job); ingestJobsById.put(jobId, job);
IngestManager.getInstance().fireIngestJobStarted(jobId); IngestManager.getInstance().fireIngestJobStarted(jobId);
scheduleIngestTasks(job); scheduleIngestTasks(job);
logger.log(Level.INFO, "Ingest job {0} started", jobId);
} }
} }
return errors; return errors;
@ -435,10 +436,13 @@ final class IngestScheduler {
private void finishIngestJob(IngestJob job) { private void finishIngestJob(IngestJob job) {
job.finish(); job.finish();
ingestJobsById.remove(job.getId()); long jobId = job.getId();
ingestJobsById.remove(jobId);
if (!job.isCancelled()) { if (!job.isCancelled()) {
logger.log(Level.INFO, "Ingest job {0} completed", jobId);
IngestManager.getInstance().fireIngestJobCompleted(job.getId()); IngestManager.getInstance().fireIngestJobCompleted(job.getId());
} else { } else {
logger.log(Level.INFO, "Ingest job {0} cancelled", jobId);
IngestManager.getInstance().fireIngestJobCancelled(job.getId()); IngestManager.getInstance().fireIngestJobCancelled(job.getId());
} }
} }