Skip to content

Commit 093274f

Browse files
committed
chore(bug): Allowed pending jobs to run on start if pendingJobsInitialization is set to rerun
1 parent 8b5a16e commit 093274f

File tree

2 files changed

+15
-2
lines changed

2 files changed

+15
-2
lines changed

Sources/JobsPostgres/PostgresJobsQueue.swift

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -315,8 +315,6 @@ public final class PostgresJobQueue: JobQueueDriver {
315315
)
316316

317317
case .rerun:
318-
guard status != .pending else { return }
319-
320318
let jobs = try await getJobs(withStatus: status)
321319
self.logger.info("Moving \(jobs.count) jobs with status: \(status) to job queue")
322320
for jobId in jobs {

docker-compose.yaml

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
2+
services:
3+
postgres:
4+
image: postgres:17.1-alpine
5+
ports:
6+
- 5432:5432
7+
volumes:
8+
- db:/var/lib/postgresql/hummingbird
9+
environment:
10+
- POSTGRES_PASSWORD=test_password
11+
- POSTGRES_USER=test_user
12+
- POSTGRES_DB=test_db
13+
volumes:
14+
db:
15+
driver: local

0 commit comments

Comments
 (0)