Filter on jobid.

vapor-community · Jan 9, 2021 · e76fb82 · e76fb82
1 parent 8d98680
commit e76fb82
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/Sources/QueuesMongoDriver/Queues.swift b/Sources/QueuesMongoDriver/Queues.swift
@@ -100,7 +100,8 @@ class MongoQueue: Queue {
     // Mark jobs that can't be finished as ready.
     func push(_ id: JobIdentifier) -> EventLoopFuture<Void> {
         mongodb["vapor_queue"]
-        .findAndModify(where: ["queue": "\(context.queueName.string)",
+        .findAndModify(where: ["jobid": id.string,
+                               "queue": "\(context.queueName.string)",
                                "status": "processing"],
                        update: ["$set": ["status": MongoJobStatus.ready.rawValue]])
         .execute()