From 79243f660a56b3baa599445c66bb52ba69b9b356 Mon Sep 17 00:00:00 2001 From: Thomas Gelf Date: Sun, 29 Sep 2019 08:53:04 +0200 Subject: [PATCH] JobRunner: unify log messages --- library/Director/Daemon/JobRunner.php | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/library/Director/Daemon/JobRunner.php b/library/Director/Daemon/JobRunner.php index 82f72235..e93d52ca 100644 --- a/library/Director/Daemon/JobRunner.php +++ b/library/Director/Daemon/JobRunner.php @@ -172,7 +172,7 @@ class JobRunner implements DbBasedComponent { $id = $job->get('id'); $jobName = $job->get('job_name'); - Logger::debug("Job starting: $jobName"); + Logger::debug("Job ($jobName) starting"); $arguments = [ 'director', 'job', @@ -199,11 +199,11 @@ class JobRunner implements DbBasedComponent } unset($this->scheduledIds[$id]); $this->runningIds[$id] = $cli->run($this->loop)->then(function () use ($id, $jobName) { - Logger::debug("Job finished: $jobName"); + Logger::debug("Job ($jobName) finished"); })->otherwise(function (\Exception $e) use ($id, $jobName) { - Logger::error('Job failed: ' . $e->getMessage()); - })->otherwise(function (FinishedProcessState $state) { - Logger::error($state->getReason()); + Logger::error("Job ($jobName) failed: " . $e->getMessage()); + })->otherwise(function (FinishedProcessState $state) use ($jobName) { + Logger::error("Job ($jobName) failed: " . $state->getReason()); })->always(function () use ($id) { unset($this->runningIds[$id]); $this->loop->futureTick(function () {