From 4b4f6bd95a5b4ca3cd55db4a605df651d07ccacb Mon Sep 17 00:00:00 2001 From: Future-Outlier Date: Wed, 27 Nov 2024 23:47:44 +0800 Subject: [PATCH] lint Signed-off-by: Future-Outlier --- .../pkg/controller/nodes/task/handler.go | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/flytepropeller/pkg/controller/nodes/task/handler.go b/flytepropeller/pkg/controller/nodes/task/handler.go index f291189f9f..10b6bd029a 100644 --- a/flytepropeller/pkg/controller/nodes/task/handler.go +++ b/flytepropeller/pkg/controller/nodes/task/handler.go @@ -552,22 +552,6 @@ func (t Handler) invokePlugin(ctx context.Context, p pluginCore.Plugin, tCtx *ta &event.TaskNodeMetadata{ CheckpointUri: tCtx.ow.GetCheckpointPrefix().String(), }) - - ////var deckURI *storage.DataReference - //if tCtx.ow.GetReader() != nil { - // exists, err := tCtx.ow.GetReader().DeckExists(ctx) - // if err != nil { - // logger.Errorf(ctx, "Failed to check deck file existence. Error: %v", err) - // return pluginTrns, regErrors.Wrapf(err, "failed to check existence of deck file") - // } else if exists { - // deckURIValue := tCtx.ow.GetDeckPath() - // deckURI = &deckURIValue - // } - //} - //pluginTrns.ObserveSuccess(tCtx.ow.GetOutputPath(), - // &event.TaskNodeMetadata{ - // CheckpointUri: tCtx.ow.GetCheckpointPrefix().String(), - // }) } case pluginCore.PhaseRetryableFailure: fallthrough