pendingJobsChan := w.pendingJobs(ctx, queue) // process overdue jobs *at startup*
// process all future jobs and retries
// TODO consider performance implications of `scheduleFutureJobs` in PgBackend
go func() { w.scheduleFutureJobs(ctx, queue) }()
for i := 0; i < handler.concurrency; i++ {
https://github.com/acaloiaro/neoq/blob/a024be6a3953a1512a1accee11bd296e6869c338/postgres_backend.go#L539