From 3e16490ccb913988d7860ca9517905a6598637e1 Mon Sep 17 00:00:00 2001
From: Yvonnick Esnault <yesnault@users.noreply.github.com>
Date: Sat, 13 Oct 2018 10:52:46 +0000
Subject: [PATCH] fix(worker): take timeout (#3454)
Signed-off-by: Yvonnick Esnault <yvonnick.esnault@corp.ovh.com>
---
engine/worker/take_workflow_node_run_job.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/engine/worker/take_workflow_node_run_job.go b/engine/worker/take_workflow_node_run_job.go
index a0020dc449..a04157eb0a 100644
--- a/engine/worker/take_workflow_node_run_job.go
+++ b/engine/worker/take_workflow_node_run_job.go
@@ -19,7 +19,7 @@ import (
// If Take is not possible (as Job already booked for example)
// it will return true (-> can work on another job), false, otherwise
func (w *currentWorker) takeWorkflowJob(ctx context.Context, job sdk.WorkflowNodeJobRun) (bool, error) {
- ctxQueueTakeJob, cancelQueueTakeJob := context.WithTimeout(ctx, 5*time.Second)
+ ctxQueueTakeJob, cancelQueueTakeJob := context.WithTimeout(ctx, 20*time.Second)
defer cancelQueueTakeJob()
info, err := w.client.QueueTakeJob(ctxQueueTakeJob, job, w.bookedWJobID == job.ID)
if err != nil {