Jake Vanderwerf
2026-05-11 ac444cba221832c012c0435fdc8339fe9f37febb
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;