diff --git a/inc/class-logger.php b/inc/class-logger.php
index 888c3d2..7b8d6c6 100644
--- a/inc/class-logger.php
+++ b/inc/class-logger.php
@@ -11,11 +11,11 @@ public function __construct( $db, $table_prefix ) {
 		$this->table_prefix = $table_prefix;
 	}
 
-	public function log_job_completed( Job $job, $message = '' ) {
+	public function log_job_completed( Job $job, $message, Worker $worker ) {
 		$this->log_run( $job->id, 'completed', $message );
 	}
 
-	public function log_job_failed( Job $job, $message = '' ) {
+	public function log_job_failed( Job $job, $message, Worker $worker ) {
 		$this->log_run( $job->id, 'failed', $message );
 	}
 
diff --git a/inc/class-runner.php b/inc/class-runner.php
index 386235c..4d72c32 100644
--- a/inc/class-runner.php
+++ b/inc/class-runner.php
@@ -386,7 +386,7 @@ protected function check_workers() {
 
 			if ( ! $worker->shutdown() ) {
 				$worker->job->mark_failed();
-				$logger->log_job_failed( $worker->job, 'Failed to shutdown worker.' );
+				$logger->log_job_failed( $worker->job, 'Failed to shutdown worker.', $worker );
 
 				/**
 				 * Action after a job has failed.
@@ -398,7 +398,7 @@ protected function check_workers() {
 				$this->hooks->run( 'Runner.check_workers.job_failed', $worker, $worker->job, $logger );
 			} else {
 				$worker->job->mark_completed();
-				$logger->log_job_completed( $worker->job );
+				$logger->log_job_completed( $worker->job, '', $worker );
 
 				/**
 				 * Action after a job has failed.