diff --git a/flytepropeller/pkg/controller/nodes/task/handler.go b/flytepropeller/pkg/controller/nodes/task/handler.go index 5b59bdfe47..7bb58ffd12 100644 --- a/flytepropeller/pkg/controller/nodes/task/handler.go +++ b/flytepropeller/pkg/controller/nodes/task/handler.go @@ -553,8 +553,8 @@ func (t Handler) invokePlugin(ctx context.Context, p pluginCore.Plugin, tCtx *ta } else { pluginTrns.ObserveSuccess(tCtx.ow.GetOutputPath(), &event.TaskNodeMetadata{ - CacheStatus: pluginTrns.execInfo.TaskNodeInfo.TaskNodeMetadata.GetCacheStatus(), - CatalogKey: pluginTrns.execInfo.TaskNodeInfo.TaskNodeMetadata.GetCatalogKey(), + //CacheStatus: pluginTrns.execInfo.TaskNodeInfo.TaskNodeMetadata.GetCacheStatus(), + //CatalogKey: pluginTrns.execInfo.TaskNodeInfo.TaskNodeMetadata.GetCatalogKey(), CheckpointUri: tCtx.ow.GetCheckpointPrefix().String(), }) }