Add Admin control for fundamentals cutover

tests/unit/test_scheduler.py

@@ -11,6 +11,7 @@ from app.scheduler import (
     _resume_tickers,
     _last_successful,
     _run_shadow_import,
+    collect_fundamentals,
     run_fundamentals_parity_report,
     run_sec_fundamentals_import,
     configure_scheduler,
@@ -169,6 +170,41 @@ class _SessionContext:
         return None
 
 
+class TestFundamentalCollector:
+    @staticmethod
+    def _session_factory():
+        return _SessionContext()
+
+    async def test_skips_legacy_provider_when_cutover_is_active(self, monkeypatch):
+        async def enabled(db, job_name):
+            return True
+
+        async def cutover_enabled(db):
+            return True
+
+        async def unexpected_ticker_lookup(db):
+            raise AssertionError("legacy ticker lookup must not run after cutover")
+
+        monkeypatch.setattr("app.scheduler.async_session_factory", self._session_factory)
+        monkeypatch.setattr("app.scheduler._is_job_enabled", enabled)
+        monkeypatch.setattr(
+            "app.scheduler.fundamental_data_refresh_service.is_enabled",
+            cutover_enabled,
+        )
+        monkeypatch.setattr(
+            "app.scheduler._get_fundamental_priority_tickers",
+            unexpected_ticker_lookup,
+        )
+
+        await collect_fundamentals()
+
+        runtime = get_job_runtime_snapshot("fundamental_collector")
+        assert runtime["status"] == "skipped"
+        assert runtime["processed"] == 0
+        assert runtime["total"] == 0
+        assert runtime["message"] == "SEC + Dolt fundamentals cutover is active"
+
+
 class TestShadowImportJobs:
     @staticmethod
     def _session_factory():