From 56dabe84560927f59d64eb37a797ac1ae0a46b1b Mon Sep 17 00:00:00 2001
From: Jake Vanderwerf <get@jakevanderwerf.ca>
Date: Tue, 12 May 2026 18:58:21 +0000
Subject: [PATCH] =added state schema.org class
---
inc/managers/queue/Processor.php | 8 ++++++++
1 files changed, 8 insertions(+), 0 deletions(-)
diff --git a/inc/managers/queue/Processor.php b/inc/managers/queue/Processor.php
index e3d7011..ccc4ddb 100644
--- a/inc/managers/queue/Processor.php
+++ b/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;
--
Gitblit v1.10.0