test: trigger

src/charm.py

@@ -931,6 +931,7 @@ def _on_debug_ssh_relation_changed(self, _: ops.RelationChangedEvent) -> None:
         """Handle debug ssh relation changed event."""
         runner_manager = self._get_runner_manager()
         runner_manager.flush(flush_busy=False)
+        self._reconcile_runners(runner_manager)
 
 
 if __name__ == "__main__":

tests/integration/conftest.py

@@ -27,6 +27,7 @@
     reconcile,
     wait_for,
 )
+from tests.status_name import ACTIVE
 
 
 @pytest.fixture(scope="module")
@@ -250,12 +251,34 @@ async def app_runner(
 
 @pytest_asyncio.fixture(scope="module", name="tmate_ssh_server_app")
 async def tmate_ssh_server_app_fixture(
-    model: Model, app: Application
+    model: Model,
+    charm_file: str,
+    app_name: str,
+    path: str,
+    token: str,
+    http_proxy: str,
+    https_proxy: str,
+    no_proxy: str,
 ) -> AsyncIterator[Application]:
     """tmate-ssh-server charm application related to GitHub-Runner app charm."""
+    # 5 min reconcile period to register flushed runners after relation data changed event.
+    app: Application = await deploy_github_runner_charm(
+        model=model,
+        charm_file=charm_file,
+        app_name=app_name,
+        path=path,
+        token=token,
+        runner_storage="memory",
+        http_proxy=http_proxy,
+        https_proxy=https_proxy,
+        no_proxy=no_proxy,
+        reconcile_interval=60,
+        wait_idle=False,
+    )
+    await app.set_config({"virtual-machines": "1"})
     tmate_app: Application = await model.deploy("tmate-ssh-server", channel="edge")
     await app.relate("debug-ssh", f"{tmate_app.name}:debug-ssh")
-    await model.wait_for_idle(raise_on_error=False, timeout=60 * 30)
+    await model.wait_for_idle(status=ACTIVE, timeout=60 * 30)
 
     return tmate_app
 

tests/integration/helpers.py

@@ -307,6 +307,7 @@ async def deploy_github_runner_charm(
     https_proxy: str,
     no_proxy: str,
     reconcile_interval: int,
+    wait_idle: bool = True,
 ) -> Application:
     """Deploy github-runner charm.
 
@@ -320,6 +321,7 @@ async def deploy_github_runner_charm(
         https_proxy: HTTPS proxy for the application to use.
         no_proxy: No proxy configuration for the application.
         reconcile_interval: Time between reconcile for the application.
+        wait_idle: wait for model to become idle.
     """
     subprocess.run(["sudo", "modprobe", "br_netfilter"])
 
@@ -353,7 +355,9 @@ async def deploy_github_runner_charm(
         storage=storage,
     )
 
-    await model.wait_for_idle(status=ACTIVE, timeout=60 * 30)
+    if wait_idle:
+        await model.wait_for_idle(status=ACTIVE, timeout=60 * 30)
+
     return application
 
 

tests/integration/test_debug_ssh.py

@@ -2,6 +2,7 @@
 # See LICENSE file for licensing details.
 
 """Integration tests for github-runner charm with ssh-debug integration."""
+import logging
 import typing
 import zipfile
 from io import BytesIO
@@ -14,6 +15,8 @@
 
 from tests.integration.helpers import wait_for
 
+logger = logging.getLogger(__name__)
+
 
 async def test_ssh_debug(
     github_repository: Repository,
@@ -28,6 +31,7 @@ async def test_ssh_debug(
     assert: the ssh connection info from action-log and tmate-ssh-server matches.
     """
     # trigger tmate action
+    logger.info("Dispatching workflow_dispatch_ssh_debug.yaml workflow.")
     workflow: Workflow = github_repository.get_workflow("workflow_dispatch_ssh_debug.yaml")
     assert workflow.create_dispatch(
         test_github_branch, inputs={"runner": app_name}
@@ -37,6 +41,7 @@ async def test_ssh_debug(
     def latest_workflow_run() -> typing.Optional[WorkflowRun]:
         """Get latest workflow run."""
         try:
+            logger.info("Fetching latest workflow run on branch %s.", test_github_branch.name)
             # The test branch is unique per test, hence there can only be one run per branch.
             last_run: WorkflowRun = workflow.get_runs(branch=test_github_branch)[0]
         except IndexError:
@@ -49,6 +54,7 @@ def latest_workflow_run() -> typing.Optional[WorkflowRun]:
     def is_workflow_complete():
         """Return if the workflow is complete."""
         lastest_run.update()
+        logger.info("Fetched latest workflow status %s.", lastest_run.status)
         return lastest_run.status == "completed"
 
     await wait_for(is_workflow_complete, timeout=60 * 45, check_interval=60)