inc/managers/queue/Processor.php
@@ -14,6 +14,10 @@ public function run(): void { if (get_transient(BASE.'queue_running')) { return; } set_transient(BASE.'queue_running', true, 60); if (!$this->hasAdequateResources()) { error_log('[Processor] Insufficient resources to start processing'); return; @@ -42,6 +46,10 @@ private function processOne(Operation $op): void { if (get_transient(BASE.$op->id)) { return; } set_transient(BASE.$op->id, true, 500); $progress = new Progress($op); $executor = $this->registry->getExecutor($op->type) ?? $this->defaultExecutor;