Add an "initial" state to jobs to avoid race conditions between the s…

…et() and push() queue operations. Fixes #13
vapor-community · Oct 24, 2024 · d2388b1 · d2388b1
1 parent 4e31dfa
commit d2388b1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/Sources/QueuesFluentDriver/FluentQueue.swift b/Sources/QueuesFluentDriver/FluentQueue.swift
@@ -38,7 +38,7 @@ public struct FluentQueue: AsyncQueue, Sendable {
                 .bind(jobStorage.jobName),
                 .bind(jobStorage.queuedAt),
                 .bind(jobStorage.delayUntil),
-                .literal(StoredJobState.pending),
+                .literal(StoredJobState.initial),
                 .bind(jobStorage.maxRetryCount),
                 .bind(jobStorage.attempts),
                 .bind(Data(jobStorage.payload)),

diff --git a/Sources/QueuesFluentDriver/JobModel.swift b/Sources/QueuesFluentDriver/JobModel.swift
@@ -6,6 +6,9 @@ import struct Queues.QueueName
 
 /// The state of a job currently stored in the database.
 enum StoredJobState: String, Codable, CaseIterable {
+    /// Job has been set up but is not yet ready to execute.
+    case initial
+
     /// Job is ready to be picked up for execution.
     case pending