fix: correct ingest.py to iterate registry values and call ingest_document

- DOCUMENT_REGISTRY is dict[str, DocumentSpec] — iterate .values() not keys
- Replace await pipeline.run(doc) (non-existent) with pipeline.ingest_document(...)
unpacking all DocumentSpec fields with correct kwarg names
- Replace doc.doc_name with doc.name to match DocumentSpec field name

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

scripts/ingest.py

@@ -23,7 +23,7 @@ log = structlog.get_logger(__name__)
 
 
 async def ingest_all(jurisdiction_filter: str | None = None, dry_run: bool = False):
-    docs = DOCUMENT_REGISTRY
+    docs = list(DOCUMENT_REGISTRY.values())
     if jurisdiction_filter:
         docs = [d for d in docs if d.jurisdiction.value == jurisdiction_filter.upper()]
         if not docs:
@@ -34,7 +34,7 @@ async def ingest_all(jurisdiction_filter: str | None = None, dry_run: bool = Fal
 
     if dry_run:
         for doc in docs:
-            print(f"  [{doc.jurisdiction.value}] {doc.doc_name}")
+            print(f"  [{doc.jurisdiction.value}] {doc.name}")
         return
 
     pipeline = IngestionPipeline()
@@ -42,18 +42,27 @@ async def ingest_all(jurisdiction_filter: str | None = None, dry_run: bool = Fal
 
     for i, doc in enumerate(docs, 1):
         log.info("ingesting_document", index=i, total=len(docs),
-                 jurisdiction=doc.jurisdiction.value, doc_name=doc.doc_name)
+                 jurisdiction=doc.jurisdiction.value, doc_name=doc.name)
         t0 = time.perf_counter()
         try:
-            await pipeline.run(doc)
+            pipeline.ingest_document(
+                source_url=doc.url,
+                doc_name=doc.name,
+                jurisdiction=doc.jurisdiction,
+                doc_type=doc.doc_type,
+                effective_date=doc.effective_date,
+                dest_subdir=doc.dest_subdir,
+                filename=doc.filename,
+                max_pages=doc.max_pages,
+            )
             elapsed = time.perf_counter() - t0
-            log.info("ingestion_complete", doc_name=doc.doc_name, elapsed_s=round(elapsed, 1))
-            results["success"].append(doc.doc_name)
+            log.info("ingestion_complete", doc_name=doc.name, elapsed_s=round(elapsed, 1))
+            results["success"].append(doc.name)
         except Exception as e:
             elapsed = time.perf_counter() - t0
-            log.error("ingestion_failed", doc_name=doc.doc_name,
+            log.error("ingestion_failed", doc_name=doc.name,
                       error=str(e), elapsed_s=round(elapsed, 1))
-            results["failed"].append((doc.doc_name, str(e)))
+            results["failed"].append((doc.name, str(e)))
 
     log.info("seeding_graph_edges")
     try: