inc/managers/queue/Storage.php
@@ -168,10 +168,15 @@ public function insert(Operation $op): bool { $result = $this->table->insert([ $existing = $this->find($op->id); if ($existing && in_array($existing->state, ['completed', 'processing'] )) { $op->id = Queue::generateId($op->userId); } $result = $this->table->findOrCreate([ 'id' => $op->id, 'type' => $op->type, 'user_id' => $op->userId, ],[ 'request_data' => json_encode($op->requestData), 'total_items' => $op->totalItems, 'processed_items' => $op->processedItems,