fix: maak KubectlConnector veilig instantieerbaar zonder event loop

Het backup-overhaul (bbaff65) liet *BackupManager-instanties direct in
test-init draaien. Die kwam langs KubectlConnector.__init__ waar
asyncio.create_task(self._connection_retry()) onvoorwaardelijk werd
aangeroepen. In een synchrone test-context (geen running loop) gaf dat
RuntimeError: no running event loop — 7 backup-pod-template tests
crashten op init, voor ze ook maar één regel test-logica draaiden.

Fix: vang de RuntimeError af en laat het retry-task gewoon uit; de eerste
async aanroep werkt zonder retry-task en de connector instantieert
voortaan veilig in elke context.

Plus: test_full_flow_yaml_to_task_creation gemarkeerd als requires_infra.
Die test roept scheduler._check_and_schedule() aan zonder Kopia/kubectl
te mocken, dus hij heeft een echte kubectl-verbinding nodig (de scheduler
leest de AGE secret om de Kopia-password af te leiden). Tot iemand de
mocks afmaakt hoort hij niet in de pre-push unit-test gate.

Author: uittenbroekrobbert

operations-manager/python/opi/connectors/kubectl.py

@@ -74,9 +74,16 @@ def __init__(self):
             logger.error(f"Error testing kubectl connection: {e}")
             KubectlConnector.isConnected = False
 
-        # Start async retry task if connection failed
+        # Start async retry task if connection failed. If no event loop is
+        # running yet (e.g. instantiated from a synchronous test fixture or
+        # at import time) skip the retry-task scheduling; first async call
+        # will keep working without it and tests no longer crash on init.
         if not KubectlConnector.isConnected:
-            self._retry_task = asyncio.create_task(self._connection_retry())
+            try:
+                self._retry_task = asyncio.create_task(self._connection_retry())
+            except RuntimeError:
+                logger.debug("No running event loop; skipping kubectl connection-retry task")
+                self._retry_task = None
 
         self._initialized = True
         logger.debug("KubectlConnector initialized successfully")

operations-manager/python/tests/test_backup_pipeline.py

@@ -731,8 +731,17 @@ def test_scheduler_payload_matches_handler_expectations(self) -> None:
         assert isinstance(payload["resource_types"], list)
         assert set(payload["resource_types"]) == {"pvc", "database", "minio"}
 
+    @pytest.mark.requires_infra
     def test_full_flow_yaml_to_task_creation(self) -> None:
-        """Realistic YAML → scheduler check → task created with correct payload."""
+        """Realistic YAML → scheduler check → task created with correct payload.
+
+        Marked requires_infra: the scheduler path calls
+        ``_get_namespace_snapshots`` which needs a real kubectl connection to
+        read the AGE secret for the Kopia password. Without a cluster the
+        snapshot lookup raises and the scheduler skips this tick, so the
+        assertions about task creation never get hit. TODO: mock the kopia /
+        kubectl dependency so this can run as a true unit test.
+        """
         scheduler = _make_scheduler()
         scheduler._task_service.get_last_completed_task = AsyncMock(return_value=None)
         scheduler._task_service.create_task = AsyncMock()