PR comments

Author: thoven87

Sources/JobsPostgres/PostgresJobsQueue.swift

@@ -70,7 +70,7 @@ public final class PostgresJobQueue: JobQueueDriver {
         /// Default initializer for JobOptions
         public init() {
             self.delayUntil = .now
-            self.priority = .lowest
+            self.priority = .normal
         }
 
         ///  Initializer for JobOptions
@@ -87,14 +87,6 @@ public final class PostgresJobQueue: JobQueueDriver {
             self.delayUntil = delayUntil
             self.priority = priority
         }
-
-        ///  Initializer for JobOptions
-        /// - Parameter delayUntil: Whether job execution should be delayed until a later date
-        /// - Parameter priority: The priority for a job
-        public init(delayUntil: Date?, priority: JobPriority = .normal) {
-            self.delayUntil = delayUntil ?? .now
-            self.priority = priority
-        }
     }
 
     /// Errors thrown by PostgresJobQueue

Tests/JobsPostgresTests/JobsTests.swift

@@ -292,13 +292,13 @@ final class JobsTests: XCTestCase {
             try await withThrowingTaskGroup(of: Void.self) { group in
                 let serviceGroup = ServiceGroup(services: [queue], logger: queue.logger)
 
+                let processingJobs = try await jobQueue.queue.getJobs(withStatus: .pending)
+                XCTAssertEqual(processingJobs.count, 2)
+
                 group.addTask {
                     try await serviceGroup.run()
                 }
 
-                let processingJobs = try await jobQueue.queue.getJobs(withStatus: .pending)
-                XCTAssertEqual(processingJobs.count, 2)
-
                 await fulfillment(of: [expectation], timeout: 10)
 
                 let pendingJobs = try await jobQueue.queue.getJobs(withStatus: .pending)
@@ -347,13 +347,13 @@ final class JobsTests: XCTestCase {
             try await withThrowingTaskGroup(of: Void.self) { group in
                 let serviceGroup = ServiceGroup(services: [queue], logger: queue.logger)
 
+                let processingJobs = try await jobQueue.queue.getJobs(withStatus: .pending)
+                XCTAssertEqual(processingJobs.count, 2)
+
                 group.addTask {
                     try await serviceGroup.run()
                 }
 
-                let processingJobs = try await jobQueue.queue.getJobs(withStatus: .pending)
-                XCTAssertEqual(processingJobs.count, 2)
-
                 await fulfillment(of: [expectation], timeout: 10)
 
                 let pendingJobs = try await jobQueue.queue.getJobs(withStatus: .pending)