From 3316c94c3953a3ea7e276a8594a8fe8c03805e7c Mon Sep 17 00:00:00 2001 From: Future-Outlier Date: Wed, 27 Nov 2024 00:19:34 +0800 Subject: [PATCH] This work by debugging with Kevin Signed-off-by: Future-Outlier --- flytepropeller/pkg/controller/nodes/task/handler.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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(), }) }