fix: handle enqueue failure in retry to prevent job loss

Only delete job record after successful re-enqueue. If enqueue fails,
re-add PID to failed queue so the job can be retried later.

Author: ChiragAgg5k

src/Queue/Broker/Redis.php

@@ -149,14 +149,20 @@ public function retry(Queue $queue, ?int $limit = null): void
                 break;
             }
 
-            $this->enqueue($queue, $job->getPayload());
+            $enqueued = $this->enqueue($queue, $job->getPayload());
 
-            /**
-             * Remove old job record after re-enqueueing to prevent memory leak.
-             */
-            $this->connection->remove("{$queue->namespace}.jobs.{$queue->name}.{$pid}");
-
-            $processed++;
+            if ($enqueued) {
+                /**
+                 * Remove old job record after successful re-enqueue to prevent memory leak.
+                 */
+                $this->connection->remove("{$queue->namespace}.jobs.{$queue->name}.{$pid}");
+                $processed++;
+            } else {
+                /**
+                 * Re-add PID to failed queue if enqueue failed so job isn't lost.
+                 */
+                $this->connection->leftPush("{$queue->namespace}.failed.{$queue->name}", $pid);
+            }
         }
     }
 

src/Queue/Queue.php

@@ -7,7 +7,7 @@
     public function __construct(
         public string $name,
         public string $namespace = 'utopia-queue',
-        public int $jobTtl = 86400,
+        public int $jobTtl = 0,
     ) {
         if (empty($this->name)) {
             throw new \InvalidArgumentException('Cannot create queue with empty name.');