Remove context deadline

jpalawaga · jpalawaga · commit 414947a7f3a4 · 2022-11-10T11:46:57.000-05:00
Quick fix. We use the heartbeat middlewear which allows long-running
jobs to work. However, the context is also ending up canceled which is
causing other issues.
diff --git a/worker.go b/worker.go
@@ -157,8 +157,8 @@ func (w *Worker) RunOnce(ctx context.Context, queueID string, h ContextHandleFun
 	}
 
 	handle := func(job *Job, o *DequeueOptions) error {
-		ctx, cancel := context.WithTimeout(ctx, opt.MaxExecutionTime)
-		defer cancel()
+		//ctx, cancel := context.WithTimeout(ctx, opt.MaxExecutionTime)
+		//defer cancel()
 		return h(ctx, job, o)
 	}
 	for _, mw := range opt.HandleMiddleware {

Original file line number	Diff line number	Diff line change
`@@ -157,8 +157,8 @@ func (w *Worker) RunOnce(ctx context.Context, queueID string, h ContextHandleFun`
`157`	`157`	`}`
`158`	`158`
`159`	`159`	`handle := func(job Job, o DequeueOptions) error {`
`160`		`- ctx, cancel := context.WithTimeout(ctx, opt.MaxExecutionTime)`
`161`		`- defer cancel()`
	`160`	`+ //ctx, cancel := context.WithTimeout(ctx, opt.MaxExecutionTime)`
	`161`	`+ //defer cancel()`
`162`	`162`	`return h(ctx, job, o)`
`163`	`163`	`}`
`164`	`164`	`for _, mw := range opt.HandleMiddleware {`