Remove requeued job from job map (#28)

raphael · web-flow · commit f06443cdf5c8 · 2024-10-14T21:58:31.000Z
diff --git a/pool/worker.go b/pool/worker.go
@@ -375,6 +375,9 @@ func (w *Worker) requeueJobs(ctx context.Context) {
 			w.logger.Error(fmt.Errorf("failed to requeue job %q: %w", job.Key, err))
 		}
 		w.Node.pendingJobs[eventID] = nil
+		if _, err := w.jobsMap.RemoveValues(ctx, w.ID, job.Key); err != nil {
+			w.logger.Error(fmt.Errorf("failed to remove requeued job from jobs map: %w", err), "job", job.Key)
+		}
 		w.logger.Info("requeued", "job", job.Key)
 	}
 	w.jobs = nil

Original file line number	Diff line number	Diff line change
`@@ -375,6 +375,9 @@ func (w *Worker) requeueJobs(ctx context.Context) {`
`375`	`375`	`w.logger.Error(fmt.Errorf("failed to requeue job %q: %w", job.Key, err))`
`376`	`376`	`}`
`377`	`377`	`w.Node.pendingJobs[eventID] = nil`
	`378`	`+ if _, err := w.jobsMap.RemoveValues(ctx, w.ID, job.Key); err != nil {`
	`379`	`+ w.logger.Error(fmt.Errorf("failed to remove requeued job from jobs map: %w", err), "job", job.Key)`
	`380`	`+ }`
`378`	`381`	`w.logger.Info("requeued", "job", job.Key)`
`379`	`382`	`}`
`380`	`383`	`w.jobs = nil`