From d59a5f4c62eed2673ec1b1b9c129b7a191083322 Mon Sep 17 00:00:00 2001 From: Pranav Shridhar Date: Sun, 12 May 2024 16:59:02 +0530 Subject: [PATCH] populate id and deadline to dead queue --- backends/sqlite/sqlite_backend.go | 6 +++--- backends/sqlite/sqlite_backend_test.go | 3 +++ 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/backends/sqlite/sqlite_backend.go b/backends/sqlite/sqlite_backend.go index fb06401..146edbd 100644 --- a/backends/sqlite/sqlite_backend.go +++ b/backends/sqlite/sqlite_backend.go @@ -564,9 +564,9 @@ func (s *SqliteBackend) moveToDeadQueue(ctx context.Context, j *jobs.Job, jobErr return } - _, err = s.db.ExecContext(ctx, `INSERT INTO neoq_dead_jobs(queue, fingerprint, payload, retries, max_retries, error) - VALUES ($1, $2, $3, $4, $5, $6)`, - j.Queue, j.Fingerprint, j.Payload2, j.Retries, j.MaxRetries, jobErr) + _, err = s.db.ExecContext(ctx, `INSERT INTO neoq_dead_jobs(queue, fingerprint, payload, retries, max_retries, error, deadline) + VALUES ($1, $2, $3, $4, $5, $6, $7)`, + j.ID, j.Queue, j.Fingerprint, j.Payload2, j.Retries, j.MaxRetries, jobErr, j.Deadline) return } diff --git a/backends/sqlite/sqlite_backend_test.go b/backends/sqlite/sqlite_backend_test.go index 9f114ba..07782fc 100644 --- a/backends/sqlite/sqlite_backend_test.go +++ b/backends/sqlite/sqlite_backend_test.go @@ -67,6 +67,9 @@ func prepareAndCleanupDB(t *testing.T) (dbURL string, db *sql.DB) { // Delete everything in the neoq_jobs table if it exists _, _ = db.Exec("DELETE FROM neoq_jobs") + // Delete everything in the neoq_dead_jobs table if it exists + _, _ = db.Exec("DELETE FROM neoq_dead_jobs") + return dbURL, db }