Log execution delay #75

tarosky · May 12, 2024 · 2a903fe · 2a903fe
1 parent 09aacd0
commit 2a903fe
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/inc/class-job.php b/inc/class-job.php
@@ -25,6 +25,8 @@ class Job
     public $finished_at;
     public $deleted_at;
 
+    public $execution_delay;
+
     protected $db;
     protected $table_prefix;
     protected $table;
@@ -115,6 +117,9 @@ public function acquire_lock()
         $started_at = new DateTime('now', new DateTimeZone('UTC'));
         $this->started_at = $started_at->format(MYSQL_DATE_FORMAT);
 
+        $nextrun = DateTime::createFromFormat('Y-m-d H:i:s', $this->nextrun, new DateTimeZone('UTC'));
+        $this->execution_delay = $started_at->getTimestamp() - $nextrun->getTimestamp();
+
         $res = $this->db->prepare_query(
             "UPDATE `$this->table`
              SET `status` = 'running', `started_at` = :started_at

diff --git a/inc/class-runner.php b/inc/class-runner.php
@@ -448,7 +448,7 @@ public function run()
 
         $this->hooks->run('Runner.run.before');
 
-        $prev_cleanup = time();
+        $prev_cleanup = 0;
         try {
             while (true) {
                 pcntl_signal_dispatch();
@@ -621,7 +621,9 @@ protected function run_job($job)
         $worker = new Worker($process, $pipes, $job, $this->log, $error_log_file, $this->max_log_size);
         $this->workers[] = $worker;
 
-        $this->log->debug('worker started', $job->log_values());
+        $this->log->debug('worker started', $job->log_values() + [
+            'execution_delay' => $job->execution_delay,
+        ]);
         $this->hooks->run('Runner.run_job.started', $worker, $job);
     }