Skip to content

Commit de0754e

Browse files
thoven87adam-fowler
authored andcommitted
Wait for 200 milliseconds before checking the job count.
1 parent 098d1eb commit de0754e

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

Tests/JobsPostgresTests/JobsTests.swift

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -859,7 +859,7 @@ final class JobsTests: XCTestCase {
859859
}
860860
let expectation = XCTestExpectation(description: "TestJob.execute was called", expectedFulfillmentCount: 3)
861861
try await self.testJobQueue(
862-
numWorkers: 3,
862+
numWorkers: 1,
863863
configuration: .init(
864864
retentionPolicy: .init(
865865
cancelled: .retain(for: -1),
@@ -877,6 +877,7 @@ final class JobsTests: XCTestCase {
877877
try await jobQueue.push(TestParameters(value: 3))
878878

879879
await fulfillment(of: [expectation], timeout: 10)
880+
try await Task.sleep(for: .milliseconds(200))
880881

881882
let completedJobs = try await jobQueue.queue.getJobs(withStatus: .completed)
882883
XCTAssertEqual(completedJobs.count, 3)

0 commit comments

Comments
 (0)