fix(Job-Engine): Fixed a bug on the timeout of deployment stop (#99)

nuvlaedge · Nov 11, 2024 · 2784b5c · 2784b5c
1 parent 42127d1
commit 2784b5c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/common/constants/timeouts.go b/common/constants/timeouts.go
@@ -1,5 +1,6 @@
 package constants
 
 const (
-	DefaultJobTimeout = 300
+	DefaultJobTimeout  = 300
+	DefaultPullTimeout = 1200
 )
diff --git a/workers/job_processor/actions/deployment_stop.go b/workers/job_processor/actions/deployment_stop.go
@@ -5,7 +5,9 @@ import (
 	"fmt"
 	"github.com/nuvla/api-client-go/clients/resources"
 	log "github.com/sirupsen/logrus"
+	"nuvlaedge-go/common/constants"
 	"nuvlaedge-go/workers/job_processor/executors"
+	"time"
 )
 
 type DeploymentStop struct {
@@ -16,7 +18,7 @@ func (d *DeploymentStop) ExecuteAction(ctx context.Context) error {
 	defer CloseDeploymentClientWithLog(d.client)
 	defer d.executor.Close()
 
-	ctxTimed, cancel := context.WithTimeout(ctx, 60)
+	ctxTimed, cancel := context.WithTimeout(ctx, constants.DefaultJobTimeout*time.Second)
 	defer cancel()
 
 	if err := d.client.SetState(ctxTimed, resources.StateStopping); err != nil {