Remove sys_ptrace dependency

Signed-off-by: Kevin Su <pingsutw@apache.org>

go/tasks/pluginmachinery/flytek8s/container_helper.go

@@ -209,16 +209,13 @@ func ToK8sContainer(ctx context.Context, taskContainer *core.Container, iFace *c
 	if errs := validation.IsDNS1123Label(containerName); len(errs) > 0 {
 		containerName = rand.String(4)
 	}
-	preStopHook := v1.Handler{Exec: &v1.ExecAction{Command: []string{"/bin/sh", "-c", "touch /var/outputs/_SUCCESS"}}}
-
 	container := &v1.Container{
 		Name:                     containerName,
 		Image:                    taskContainer.GetImage(),
 		Args:                     taskContainer.GetArgs(),
 		Command:                  taskContainer.GetCommand(),
 		Env:                      ToK8sEnvVar(taskContainer.GetEnv()),
 		TerminationMessagePolicy: v1.TerminationMessageFallbackToLogsOnError,
-		Lifecycle:                &v1.Lifecycle{PreStop: &preStopHook},
 	}
 	if err := AddCoPilotToContainer(ctx, config.GetK8sPluginConfig().CoPilot, container, iFace, taskContainer.DataConfig); err != nil {
 		return nil, err

go/tasks/pluginmachinery/flytek8s/copilot.go

@@ -201,8 +201,6 @@ func AddCoPilotToPod(ctx context.Context, cfg config.FlyteCoPilotConfig, coPilot
 	}
 
 	logger.Infof(ctx, "CoPilot Enabled for task [%s]", taskExecMetadata.GetTaskExecutionID().GetID().TaskId.Name)
-	shareProcessNamespaceEnabled := true
-	coPilotPod.ShareProcessNamespace = &shareProcessNamespaceEnabled
 	if iFace != nil {
 		if iFace.Inputs != nil {
 			inPath := cfg.DefaultInputDataPath

go/tasks/plugins/k8s/pod/container.go

@@ -28,5 +28,11 @@ func (containerPodBuilder) buildPodSpec(ctx context.Context, task *core.TaskTemp
 }
 
 func (containerPodBuilder) updatePodMetadata(ctx context.Context, pod *v1.Pod, task *core.TaskTemplate, taskCtx pluginsCore.TaskExecutionContext) error {
+	pilot := task.GetContainer().GetDataConfig()
+	if pilot == nil || !pilot.Enabled || task.Interface.Outputs == nil {
+		return nil
+	}
+	pod.Annotations = make(map[string]string)
+	pod.Annotations[RawContainerName] = pod.Spec.Containers[0].Name
 	return nil
 }

go/tasks/plugins/k8s/pod/plugin.go

@@ -21,6 +21,7 @@ import (
 const (
 	podTaskType         = "pod"
 	PrimaryContainerKey = "primary_container_name"
+	RawContainerName    = "raw_container_name"
 )
 
 var (
@@ -121,6 +122,19 @@ func (plugin) GetTaskPhaseWithLogs(ctx context.Context, pluginContext k8s.Plugin
 		return pluginsCore.PhaseInfoUndefined, nil
 	}
 
+	RawContainerName, exists := r.GetAnnotations()[RawContainerName]
+	if exists {
+		// we'll declare the task as "failure" If raw container fail, but the rawContainer
+		// task requires all containers (raw container and sidecar) to succeed to declare success
+		for _, s := range pod.Status.ContainerStatuses {
+			if s.Name == RawContainerName {
+				if s.State.Terminated != nil && s.State.Terminated.ExitCode != 0 {
+					return pluginsCore.PhaseInfoRetryableFailure(s.State.Terminated.Reason, s.State.Terminated.Message, &info), nil
+				}
+			}
+		}
+	}
+
 	primaryContainerName, exists := r.GetAnnotations()[PrimaryContainerKey]
 	if !exists {
 		// if the primary container annotation dos not exist, then the task requires all containers