8000 fix(worker): take timeout (#3454) · ovh/cds@3e16490 · GitHub
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

Commit 3e16490

Browse files
yesnaultfsamin
yesnault
authored and
fsamin
committed
fix(worker): take timeout (#3454)
Signed-off-by: Yvonnick Esnault <yvonnick.esnault@corp.ovh.com>
1 parent e66d70c commit 3e16490

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

‎engine/worker/take_workflow_node_run_job.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ import (
1919
// If Take is not possible (as Job already booked for example)
2020
// it will return true (-> can work on another job), false, otherwise
2121
func (w *currentWorker) takeWorkflowJob(ctx context.Context, job sdk.WorkflowNodeJobRun) (bool, error) {
22-
ctxQueueTakeJob, cancelQueueTakeJob := context.WithTimeout(ctx, 5*time.Second)
22+
ctxQueueTakeJob, cancelQueueTakeJob := context.WithTimeout(ctx, 20*time.Second)
2323
defer cancelQueueTakeJob()
2424
info, err := w.client.QueueTakeJob(ctxQueueTakeJob, job, w.bookedWJobID == job.ID)
2525
if err != nil {

0 commit comments

Comments
 (0)
0