me/neoq
1
0
Fork 0
mirror of https://github.com/acaloiaro/neoq synced 2026-07-21 18:29:08 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Flip logic

Browse source
This commit is contained in:
Phil Constantinou 2024-06-26 15:55:52 +02:00
parent d05bf4edf8
commit f7da9f3903
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
backends/postgres/postgres_backend.go
View file

@ -943,7 +943,7 @@ func (p *PgBackend) handleJob(ctx context.Context, jobID string) (err error) {
ctx = jobs.WithJobContext(ctx, job)
ctx = context.WithValue(ctx, txCtxVarKey, tx)
if job.RunAfter.After(time.Now()) {
if job.RunAfter.Before(time.Now()) {
p.logger.Error("Running a job too early.",
slog.String("queue", job.Queue),
slog.Int64("job_id", job.ID),