Merge ~lloydwaltersj/maas-ci/+git/system-tests:temporal-workflow-candidate-tester into ~maas-committers/maas-ci/+git/system-tests:master

[Jack Lloyd-Walters]

temporal workflow to check status of image tester job

[MAAS Lander (maas-lander)]

UNIT TESTS
-b temporal-workflow-candidate-tester lp:~lloydwaltersj/maas-ci/+git/system-tests into -b master lp:~maas-committers/maas-ci/+git/system-tests

STATUS: SUCCESS
COMMIT: 18a2e3a4ff82b7bcd90408788b4f33a881e295f5

review: Approve

diff --git a/temporal/candidate_tester_worker.py b/temporal/candidate_tester_worker.py
new file mode 100644
index 0000000..808801f
--- /dev/null
+++ b/temporal/candidate_tester_worker.py
@@ -0,0 +1,10 @@
+from .candidate_tester_workflow import activities as candidate_tester_activites
+from .candidate_tester_workflow import workflows as candidate_tester_workflows
+from .common_tasks import start_worker
+
+if __name__ == "__main__":
+    start_worker(
+        task_queue="candidate_image_tester",
+        workflows=candidate_tester_workflows,
+        activities=candidate_tester_activites,
+    )
diff --git a/temporal/candidate_tester_workflow.py b/temporal/candidate_tester_workflow.py
new file mode 100644
index 0000000..4a60ccd
--- /dev/null
+++ b/temporal/candidate_tester_workflow.py
@@ -0,0 +1,70 @@
+""" Request an image test from candidate,
+    returning the build number of the testing job."""
+
+from dataclasses import dataclass
+
+from temporalio import workflow
+from temporalio.common import RetryPolicy
+
+from .common_tasks import (
+    await_build_complete,
+    await_build_exists,
+    check_jenkins_reachable,
+    fetch_build_status,
+    workflow_parameters,
+)
+
+
+@dataclass
+class candidate_tester_params(workflow_parameters):
+    job_name: str = "maas-system-tests-executor"
+    build_num: int | None = None
+
+
[e-mail]
+class candidate_tester_workflow:
+    @workflow.run
+    async def run(self, params: candidate_tester_params) -> bool:
+        await workflow.execute_activity(
+            check_jenkins_reachable,
+            params,
+            start_to_close_timeout=params.gettimeout("jenkins_login_timeout"),
+            retry_policy=RetryPolicy(maximum_attempts=params.max_retry_attempts),
+        )
+        # XXX: This assumes the most recent executor job after the
+        # config generator completes is the correct one. Ideally this
+        # would fetch the downstream job directly from the config
+        # generator, but that doesn't seem to be working at current.
+        await workflow.execute_activity(
+            await_build_exists,
+            params,
+            start_to_close_timeout=params.gettimeout("request_build_timeout"),
+            retry_policy=RetryPolicy(maximum_attempts=params.max_retry_attempts),
+        )
+
+        # wait for the job to complete
+        await workflow.execute_activity(
+            await_build_complete,
+            params,
+            start_to_close_timeout=params.gettimeout("build_complete_timeout"),
+            retry_policy=RetryPolicy(maximum_attempts=params.max_retry_attempts),
+        )
+
+        # return a default failure state if the build was aborted
+        build_status = await workflow.execute_activity(
+            fetch_build_status,
+            params,
+            start_to_close_timeout=params.gettimeout("return_status_timeout"),
+            retry_policy=RetryPolicy(maximum_attempts=params.max_retry_attempts),
+        )
+
+        return build_status.lower() == "success"
+
+
+activities = [
+    check_jenkins_reachable,
+    await_build_exists,
+    await_build_complete,
+    fetch_build_status,
+]
+workflows = [candidate_tester_workflow]