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