diff --git a/scripts/ingest.py b/scripts/ingest.py index 2d5a726..487ba90 100644 --- a/scripts/ingest.py +++ b/scripts/ingest.py @@ -143,7 +143,9 @@ def ingest_file(filepath): print(f" Indexed {len(chunks)} chunks: {path.name}") # Enqueue for Stage 2 → Stage 3 (Graphiti pipeline) - enqueue_stage2(path.name, text) + # SKIP_STAGE2_ENQUEUE env var set by migration scripts to prevent bulk enqueue + if not os.getenv("SKIP_STAGE2_ENQUEUE"): + enqueue_stage2(path.name, text) return len(chunks)