diff --git a/backend/src/v2/component/launcher_v2.go b/backend/src/v2/component/launcher_v2.go index 2d9b569b898..2b5297c7b09 100644 --- a/backend/src/v2/component/launcher_v2.go +++ b/backend/src/v2/component/launcher_v2.go @@ -87,7 +87,6 @@ func NewLauncherV2(ctx context.Context, executionID int64, executorInputJSON, co if err != nil { return nil, fmt.Errorf("failed to unmarshal executor input: %w", err) } - glog.Infof("input ComponentSpec:%s\n", prettyPrint(componentSpecJSON)) component := &pipelinespec.ComponentSpec{} err = protojson.Unmarshal([]byte(componentSpecJSON), component) if err != nil { diff --git a/backend/src/v2/driver/driver.go b/backend/src/v2/driver/driver.go index 56fb45b96f4..aeeda9b6a48 100644 --- a/backend/src/v2/driver/driver.go +++ b/backend/src/v2/driver/driver.go @@ -387,9 +387,6 @@ func initPodSpecPatch( userCmdArgs = append(userCmdArgs, container.Command...) userCmdArgs = append(userCmdArgs, container.Args...) launcherCmd := []string{ - // TODO(Bobgy): workaround argo emissary executor bug, after we upgrade to an argo version with the bug fix, we can remove the following line. - // Reference: https://github.com/argoproj/argo-workflows/issues/7406 - "/var/run/argo/argoexec", "emissary", "--", component.KFPLauncherPath, // TODO(Bobgy): no need to pass pipeline_name and run_id, these info can be fetched via pipeline context and pipeline run context which have been created by root DAG driver. "--pipeline_name", pipelineName,