Fixed Jobs not being removed if persisted (#369)

lucas34 · Dec 20, 2020 · 5bfce4f · 5bfce4f
1 parent 0c681c3
commit 5bfce4f
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/Sources/SwiftQueue/SqOperationQueue.swift b/Sources/SwiftQueue/SqOperationQueue.swift
@@ -64,12 +64,11 @@ public final class SqOperationQueue: OperationQueue {
     private func loadSerializedTasks(name: String) {
         persister.restore(queueName: name).compactMap { string -> SqOperation? in
             do {
-                let info = try serializer.deserialize(json: string)
+                var info = try serializer.deserialize(json: string)
                 let job = creator.create(type: info.type, params: info.params)
-                var constraints = info.constraints
-                constraints.append(PersisterConstraint(serializer: serializer, persister: persister))
+                info.constraints.append(PersisterConstraint(serializer: serializer, persister: persister))
 
-                return SqOperation(job, info, logger, listener, dispatchQueue, constraints)
+                return SqOperation(job, info, logger, listener, dispatchQueue, info.constraints)
             } catch let error {
                 logger.log(.error, jobId: "UNKNOWN", message: "Unable to deserialize job error=\(error.localizedDescription)")
                 return nil