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

fix order of scanned columns in query

Browse source
This commit is contained in:
Pranav Shridhar 2024-04-08 16:40:49 +05:30
parent 82a13d9dc6
commit 00b84295e3
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
backends/sqlite/sqlite_backend.go
View file

@ -28,7 +28,7 @@ var sqliteMigrationsFS embed.FS
type contextKey struct{}
const (
JobQuery = `SELECT id,fingerprint,queue,status,deadline,payload,retries,max_retries,run_after,ran_at,created_at,error
JobQuery = `SELECT id,fingerprint,queue,status,payload,retries,max_retries,run_after,deadline,ran_at,created_at,error
FROM neoq_jobs
WHERE id = $1
AND status != "processed"`
@ -37,7 +37,7 @@ const (
WHERE queue = $1
AND status != "processed"
AND run_after < datetime("now")`
FutureJobQuery = `SELECT id,fingerprint,queue,status,deadline,payload,retries,max_retries,run_after,ran_at,created_at,error
FutureJobQuery = `SELECT id,fingerprint,queue,status,payload,retries,max_retries,run_after,deadline,ran_at,created_at,error
FROM neoq_jobs
WHERE queue = $1
AND status != "processed"
@ -353,7 +353,7 @@ func (s *SqliteBackend) handleJob(ctx context.Context, jobID string) (err error)
err = tx.Commit()
if err != nil {
errMsg := "unable to commit job transaction. retrying this job may dupliate work:"
errMsg := "unable to commit job transaction. retrying this job may duplicate work:"
s.logger.Error(errMsg, slog.String("queue", h.Queue), slog.Any("error", err), slog.Int64("job_id", job.ID))
return fmt.Errorf("%s %w", errMsg, err)
}
@ -366,8 +366,8 @@ func (s *SqliteBackend) getJob(ctx context.Context, tx *sql.Tx, jobID string) (j
row := tx.QueryRowContext(ctx, JobQuery, jobID)
err = row.Scan(
&job.ID, &job.Fingerprint, &job.Queue, &job.Status,
&job.Deadline, &job.Payload2, &job.Retries, &job.MaxRetries,
&job.RunAfter, &job.RanAt, &job.CreatedAt, &job.Error,
&job.Payload2, &job.Retries, &job.MaxRetries,
&job.RunAfter, &job.Deadline, &job.RanAt, &job.CreatedAt, &job.Error,
)
if err != nil {
return
@ -380,8 +380,8 @@ func (s *SqliteBackend) getJobWithoutTx(ctx context.Context, jobID string) (job
row := s.db.QueryRowContext(ctx, JobQuery, jobID)
err = row.Scan(
&job.ID, &job.Fingerprint, &job.Queue, &job.Status,
&job.Deadline, &job.Payload2, &job.Retries, &job.MaxRetries,
&job.RunAfter, &job.RanAt, &job.CreatedAt, &job.Error,
&job.Payload2, &job.Retries, &job.MaxRetries,
&job.RunAfter, &job.Deadline, &job.RanAt, &job.CreatedAt, &job.Error,
)
if err != nil {
return