diff --git a/Sources/QueuesFluentDriver/FluentQueue.swift b/Sources/QueuesFluentDriver/FluentQueue.swift
index 0136c12..92cc817 100644
--- a/Sources/QueuesFluentDriver/FluentQueue.swift
+++ b/Sources/QueuesFluentDriver/FluentQueue.swift
@@ -61,6 +61,7 @@ extension FluentQueue: Queue {
             .update(JobModel.schema)
             .set(SQLColumn("\(FieldKey.state)"), to: SQLBind(QueuesFluentJobState.pending))
             .where(SQLColumn("\(FieldKey.jobId)"), .equal, SQLBind(id.string))
+            .where(SQLColumn("\(FieldKey.state)"), .equal, SQLBind(QueuesFluentJobState.initialized))
             .run()
     }
     
diff --git a/Sources/QueuesFluentDriver/JobModel.swift b/Sources/QueuesFluentDriver/JobModel.swift
index a50720c..39d6c3f 100644
--- a/Sources/QueuesFluentDriver/JobModel.swift
+++ b/Sources/QueuesFluentDriver/JobModel.swift
@@ -3,6 +3,7 @@ import Fluent
 import Queues
 
 public enum QueuesFluentJobState: String, Codable, CaseIterable {
+    case initialized
     /// Ready to be picked up for execution
     case pending
     case processing
@@ -60,6 +61,6 @@ class JobModel: Model {
         self.jobId = jobId
         self.queue = queue
         self.data = try JSONEncoder().encode(data)
-        self.state = .pending
+        self.state = .initialized
     }
 }