diff --git a/flytepropeller/pkg/controller/nodes/executor.go b/flytepropeller/pkg/controller/nodes/executor.go index 5e1cbe4f51..8e96ee9645 100644 --- a/flytepropeller/pkg/controller/nodes/executor.go +++ b/flytepropeller/pkg/controller/nodes/executor.go @@ -941,7 +941,7 @@ func (c *nodeExecutor) handleNotYetStartedNode(ctx context.Context, dag executor } var cacheStatus *catalog.Status - if cacheHandler, ok := h.(interfaces.CacheableNodeHandler); ok { + if cacheHandler, ok := h.(interfaces.CacheableNodeHandler); p.GetPhase() != handler.EPhaseSkip && ok { cacheable, _, err := cacheHandler.IsCacheable(ctx, nCtx) if err != nil { logger.Errorf(ctx, "failed to determine if node is cacheable with err '%s'", err.Error())