Revert forcing non-interruptibility on kfoperator masters

Signed-off-by: Jeev B <[email protected]>
flyteorg · Nov 30, 2023 · 2116ec2 · 2116ec2
1 parent 307bead
commit 2116ec2
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/flyteplugins/go/tasks/plugins/k8s/kfoperators/common/common_operator.go b/flyteplugins/go/tasks/plugins/k8s/kfoperators/common/common_operator.go
@@ -302,10 +302,6 @@ type allowsCommandOverride interface {
 
 func ToReplicaSpecWithOverrides(ctx context.Context, taskCtx pluginsCore.TaskExecutionContext, rs kfDistributedReplicaSpec, primaryContainerName string, isMaster bool) (*commonOp.ReplicaSpec, error) {
 	taskCtxOptions := []flytek8s.PluginTaskExecutionContextOption{}
-	// Master should always run as non-interruptible
-	if isMaster {
-		taskCtxOptions = append(taskCtxOptions, flytek8s.WithInterruptible(false))
-	}
 	if rs != nil && rs.GetResources() != nil {
 		resources, err := flytek8s.ToK8sResourceRequirements(rs.GetResources())
 		if err != nil {