Honor task specific cleanupTimeout

Author: Philo Hamel

src/Model/Table/QueuedTasksTable.php

@@ -452,17 +452,45 @@ public function rerun($taskName): int
     /**
      * Cleanup/Delete Completed Tasks.
      *
+     * @param array $capabilities Available QueueWorkerTasks.
      * @return void
      */
-    public function cleanOldJobs(): void
+    public function cleanOldJobs(array $capabilities): void
     {
-        if (!Configure::read('Queue.cleanuptimeout')) {
-            return;
+        $conditions = [];
+
+        // Generate the job specific conditions
+        foreach ($capabilities as $task) {
+            list ($plugin, $name) = pluginSplit($task['name']);
+            $conditions['OR'][] = [
+                'task' => $name,
+                'completed <' => date('Y-m-d H:i:s', time() - $task['cleanupTimeout'])
+            ];
+        }
+
+        $this->deleteAll($conditions, false);
+    }
+
+    /**
+     * Cleanups / delete failed jobs with given capabilities after maximum retries.
+     *
+     * @param array $capabilities Available QueueWorkerTasks.
+     * @return void
+     */
+    public function cleanFailedJobs(array $capabilities): void
+    {
+        $conditions = [];
+
+        // Generate the job specific conditions.
+        foreach ($capabilities as $task) {
+            list ($plugin, $name) = pluginSplit($task['name']);
+            $conditions['OR'][] = [
+                'task' => $name,
+                'failed_count >' => $task['retries']
+            ];
         }
 
-        $this->deleteAll([
-            'completed <' => time() - (int)Configure::read('Queue.cleanuptimeout')
-        ]);
+        $this->deleteAll($conditions, false);
     }
 
     /**

src/Shell/QueueShell.php

@@ -208,7 +208,7 @@ public function runworker(): void
             }
             if ($this->_exit || mt_rand(0, 100) > (100 - Config::gcprob())) {
                 $this->out(__d('queue', 'Performing old job cleanup.'));
-                $this->QueuedTasks->cleanOldJobs();
+                $this->QueuedTasks->cleanOldJobs($this->_getTaskConf());
             }
             $this->hr();
         }
@@ -276,12 +276,18 @@ protected function runJob(QueuedTask $queuedTask): void
      */
     public function clean(): void
     {
-        if (!Configure::read('Queue.cleanupTimeout')) {
-            $this->abort('You disabled cleanuptimout in config. Aborting.');
-        }
+        $this->out(__d('queue', 'Deleting old completed jobs, that have had cleanup timeout.'));
+        $this->QueuedTasks->cleanOldJobs($this->_getTaskConf());
+    }
 
-        $this->out('Deleting old jobs, that have finished before ' . date('Y-m-d H:i:s', time() - (int)Configure::read('Queue.cleanupTimeout')));
-        $this->QueuedTasks->cleanOldJobs();
+    /**
+     * Manually trigger a Failed job cleanup.
+     *
+     * @return void
+     */
+    public function clean_failed() {
+        $this->out(__d('queue', 'Deleting failed jobs, that have had maximum worker retries.'));
+        $this->QueuedTasks->cleanFailedJobs($this->_getTaskConf());
     }
 
     /**
@@ -363,6 +369,10 @@ public function getOptionParser(): ConsoleOptionParser
                 'help' => 'Remove old jobs (cleanup)',
                 'parser' => $subcommandParser
             ])
+            ->addSubcommand('clean_failed', [
+                'help' => 'Remove old failed jobs (cleanup)',
+                'parser' => $subcommandParser
+            ])
             ->addSubcommand('add', [
                 'help' => 'Add Job',
                 'parser' => $subcommandParser