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

Remove safety check for running too soon

Browse source
This commit is contained in:
Phil Constantinou 2024-06-26 16:05:54 +02:00
parent f7da9f3903
commit bcc39d1cd2
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
backends/postgres/postgres_backend.go
View file

@ -943,14 +943,14 @@ 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.Before(time.Now()) {
p.logger.Error("Running a job too early.",
slog.String("queue", job.Queue),
slog.Int64("job_id", job.ID),
slog.String("duration", (-time.Since(job.RunAfter)).String()))
err = p.updateJob(ctx, fmt.Errorf("run to soon"))
return
}
// 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),
// slog.String("duration", (-time.Since(job.RunAfter)).String()))
// err = p.updateJob(ctx, fmt.Errorf("run to soon"))
// return
// }
if job.Deadline != nil && job.Deadline.Before(time.Now().UTC()) {
err = jobs.ErrJobExceededDeadline