diff --git a/internal/app/analyze_projection.go b/internal/app/analyze_projection.go index 51b9bcf..46658ef 100644 --- a/internal/app/analyze_projection.go +++ b/internal/app/analyze_projection.go @@ -88,15 +88,12 @@ func applyAnalyzeProjection( } } -func analyzeProjectionOutputs(records map[string]manifest.AnalyzeArtifactRecord, producerRunID string) []manifest.ArtifactRecord { +func analyzeProjectionOutputs(records map[string]manifest.AnalyzeArtifactRecord) []manifest.ArtifactRecord { keys := make([]string, 0, len(records)) for key, record := range records { if record.Status != manifest.AnalyzeArtifactCurrent || record.Output == nil { continue } - if producerRunID != "" && record.ProducerRunID != producerRunID { - continue - } keys = append(keys, key) } sort.Strings(keys) diff --git a/internal/app/runner.go b/internal/app/runner.go index ef5718e..e05288c 100644 --- a/internal/app/runner.go +++ b/internal/app/runner.go @@ -364,7 +364,7 @@ func executePlan(ctx context.Context, cfg *config.Config, plan BoundedPlan, opts sessionOutputs := mapResultOutputs(s.Name(), result, runID) if analyzeProjection != nil { - sessionOutputs = analyzeProjectionOutputs(analyzeProjection.session, "") + sessionOutputs = analyzeProjectionOutputs(analyzeProjection.session) } succeededAt := nowUTC() m.MarkStageSucceeded(s.Name(), succeededAt, sessionOutputs) diff --git a/internal/stage/analyze.go b/internal/stage/analyze.go index c28bb3d..4a1e7fb 100644 --- a/internal/stage/analyze.go +++ b/internal/stage/analyze.go @@ -431,11 +431,11 @@ func sameAnalyzeOutputIdentity(left, right manifest.AnalyzeArtifactRecord) bool func staleUnscheduledAnalyzeDependents( configured map[string]config.ScriptoriumArtifactConfig, changed string, - invocationKeys map[string]struct{}, + currentKeys map[string]struct{}, records map[string]manifest.AnalyzeArtifactRecord, ) { staleAnalyzeDependentClosure(configured, changed, records, func(key string) bool { - _, evaluated := invocationKeys[key] + _, evaluated := currentKeys[key] return !evaluated }) }