Skip to content

Commit 1a7c6ae

Browse files
fix(k8s): add k8s pass to parallel pipeline path
The parallel execution path (used for repos above MIN_FILES_FOR_PARALLEL) was missing the cbm_pipeline_pass_k8s() call. The pass existed only in the sequential fallback path, so any repo large enough to trigger parallel indexing produced zero k8s Resource and kustomize Module nodes. Discovered via live testing against a 954-file gitops repo: the parallel path was taken, k8s pass was silently skipped, and search_graph returned 0 Resource nodes despite 213 kustomize overlays and hundreds of manifests. Add the pass after cbm_parallel_resolve() in the parallel branch, matching the same pattern (fail-open, cancel check, timing log) as the sequential path. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
1 parent 94882c2 commit 1a7c6ae

1 file changed

Lines changed: 10 additions & 0 deletions

File tree

src/pipeline/pipeline.c

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -494,6 +494,16 @@ int cbm_pipeline_run(cbm_pipeline_t *p) {
494494
rc = -1;
495495
goto cleanup;
496496
}
497+
498+
cbm_clock_gettime(CLOCK_MONOTONIC, &t);
499+
rc = cbm_pipeline_pass_k8s(&ctx, files, file_count);
500+
if (rc != 0) { /* log warning, continue */
501+
}
502+
cbm_log_info("pass.timing", "pass", "k8s", "elapsed_ms", itoa_buf((int)elapsed_ms(t)));
503+
if (check_cancel(p)) {
504+
rc = -1;
505+
goto cleanup;
506+
}
497507
} else {
498508
cbm_log_info("pipeline.mode", "mode", "sequential", "files", itoa_buf(file_count));
499509

0 commit comments

Comments
 (0)