This work by debugging with Kevin

Signed-off-by: Future-Outlier <[email protected]>
flyteorg · Nov 26, 2024 · 3316c94 · 3316c94
1 parent bfd0b64
commit 3316c94
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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(),
 				})
 		}