From 062641f9772d81d83b4c9ffa766e5a656b5c54bc Mon Sep 17 00:00:00 2001 From: Dan Rammer Date: Wed, 17 May 2023 07:02:40 -0500 Subject: [PATCH] Remove single task execution default timeout (#564) * removed default timeout Signed-off-by: Daniel Rammer * removed unnecessary dependencies Signed-off-by: Daniel Rammer --------- Signed-off-by: Daniel Rammer --- pkg/manager/impl/util/single_task_execution.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/pkg/manager/impl/util/single_task_execution.go b/pkg/manager/impl/util/single_task_execution.go index 74a53de99..d23f38c98 100644 --- a/pkg/manager/impl/util/single_task_execution.go +++ b/pkg/manager/impl/util/single_task_execution.go @@ -4,7 +4,6 @@ import ( "context" "fmt" "strings" - "time" "unicode" "github.com/flyteorg/flyteadmin/pkg/errors" @@ -17,7 +16,6 @@ import ( "github.com/flyteorg/flyteidl/gen/pb-go/flyteidl/admin" "github.com/flyteorg/flyteidl/gen/pb-go/flyteidl/core" "github.com/flyteorg/flytestdlib/logger" - "github.com/golang/protobuf/ptypes" "google.golang.org/grpc/codes" ) @@ -26,7 +24,6 @@ const maxNodeIDLength = 63 var defaultRetryStrategy = core.RetryStrategy{ Retries: 3, } -var defaultTimeout = ptypes.DurationProto(24 * time.Hour) const systemNamePrefix = ".flytegen.%s" @@ -102,7 +99,6 @@ func CreateOrGetWorkflowModel( Metadata: &core.NodeMetadata{ Name: generateNodeNameFromTask(taskIdentifier.Name), Retries: &defaultRetryStrategy, - Timeout: defaultTimeout, }, Inputs: generateBindings(*task.Closure.CompiledTask.Template.Interface.Inputs, noInputNodeID), Target: &core.Node_TaskNode{