diff --git a/nerve/cli.py b/nerve/cli.py
index c34b4796..ea251e91 100644
--- a/nerve/cli.py
+++ b/nerve/cli.py
@@ -644,7 +644,7 @@ async def _run():
             engine = AgentEngine(config, db)
             await engine.initialize()
 
-            runners = build_source_runners(config, db, engine)
+            runners = build_source_runners(config, db)
             if not runners:
                 click.echo("No sources configured.")
                 return
@@ -665,15 +665,14 @@ async def _run():
                 status = "OK" if result.error is None else "ERROR"
                 click.echo(
                     f" [{status}] "
-                    f"{result.records_processed} processed, "
-                    f"{result.records_skipped} skipped"
+                    f"{result.records_ingested} ingested"
                     + (f" — {result.error}" if result.error else "")
                 )
                 # Log to source_run_log
                 await db.log_source_run(
                     source=runner.source.source_name,
-                    records_fetched=result.records_processed + result.records_skipped,
-                    records_processed=result.records_processed,
+                    records_fetched=result.records_ingested,
+                    records_processed=result.records_ingested,
                     error=result.error,
                 )
         finally: