diff --git a/internal/jobscheduler/jobs.go b/internal/jobscheduler/jobs.go index 03c45e7..ae821df 100644 --- a/internal/jobscheduler/jobs.go +++ b/internal/jobscheduler/jobs.go @@ -23,7 +23,7 @@ type queueJob struct { run func(ctx context.Context) error } -func (j *queueJob) String() string { return fmt.Sprintf("job-%s-%s", j.queue, j.id) } +func (j *queueJob) String() string { return fmt.Sprintf("job-%s-%s", j.id, j.queue) } func (j *queueJob) Run(ctx context.Context) error { return errors.WithStack(j.run(ctx)) } // Scheduler runs background jobs concurrently across multiple serialised queues.