Add a debug log when worker fails to start a job (#47)

Author: raphael

pool/node_test.go

@@ -163,8 +163,6 @@ func TestJobPayload(t *testing.T) {
 			// Check if job payload is correct
 			assert.Eventually(t, func() bool {
 				payload, ok := node.JobPayload(tt.key)
-				fmt.Println(payload, ok)
-				fmt.Println(tt.payload)
 				return ok && assert.Equal(t, tt.payload, payload)
 			}, max, delay, fmt.Sprintf("Failed to get correct payload for job %s", tt.key))
 		})

pool/worker.go

@@ -256,6 +256,7 @@ func (w *Worker) startJob(ctx context.Context, job *Job) error {
 	}
 	job.Worker = w
 	if err := w.handler.Start(job); err != nil {
+		w.logger.Debug("handler failed to start job", "job", job.Key, "error", err)
 		if _, _, err := w.jobsMap.RemoveValues(ctx, w.ID, job.Key); err != nil {
 			w.logger.Error(fmt.Errorf("start failure handling: failed to remove job %q from jobs map: %w", job.Key, err))
 		}