Fail dispatch early

Author: kraenhansen

packages/compass-smoke-tests/src/dispatch.ts

@@ -1,3 +1,4 @@
+import assert from 'node:assert/strict';
 import crypto from 'node:crypto';
 
 import * as github from '@actions/github';
@@ -76,6 +77,7 @@ type DispatchOptions = {
   bucketName: string;
   bucketKeyPrefix: string;
   devVersion?: string;
+  evergreenTaskUrl?: string;
 
   /**
    * Delay in milliseconds to wait between requests when polling while watching the run.
@@ -89,6 +91,7 @@ export async function dispatchAndWait({
   devVersion,
   bucketName,
   bucketKeyPrefix,
+  evergreenTaskUrl,
   watchPollDelayMs = 5000,
 }: DispatchOptions) {
   const octokit = github.getOctokit(githubToken);
@@ -103,6 +106,7 @@ export async function dispatchAndWait({
       dev_version: devVersion,
       bucket_name: bucketName,
       bucket_key_prefix: bucketKeyPrefix,
+      evergreen_task_url: evergreenTaskUrl,
       nonce,
     },
   });
@@ -114,25 +118,27 @@ export async function dispatchAndWait({
   );
 
   console.log(`Dispatched run #${run.run_number} (${run.html_url})`);
-  for (
-    const start = new Date();
-    new Date().getTime() - start.getTime() < WATCH_POLL_TIMEOUT_MS;
+  try {
+    for (
+      const start = new Date();
+      new Date().getTime() - start.getTime() < WATCH_POLL_TIMEOUT_MS;
 
-  ) {
-    const {
-      data: { status, conclusion },
-    } = await octokit.rest.actions.getWorkflowRun({
-      owner: GITHUB_OWNER,
-      repo: GITHUB_REPO,
-      run_id: run.id,
-    });
-    console.log(
-      `Status = ${status || 'null'}, conclusion = ${conclusion || 'null'}`
-    );
-    if (status === 'completed' && conclusion === 'success') {
-      return;
+    ) {
+      const {
+        data: { status, conclusion },
+      } = await octokit.rest.actions.getWorkflowRun({
+        owner: GITHUB_OWNER,
+        repo: GITHUB_REPO,
+        run_id: run.id,
+      });
+      console.log(`Status: ${status || 'null'}`);
+      if (status === 'completed') {
+        assert.equal(conclusion, 'success');
+      }
+      await new Promise((resolve) => setTimeout(resolve, watchPollDelayMs));
     }
-    await new Promise((resolve) => setTimeout(resolve, watchPollDelayMs));
+  } finally {
+    console.log(`Run completed: ${run.html_url}`);
   }
   throw new Error(
     `Run did not complete successfully within ${WATCH_POLL_TIMEOUT_MS}ms: See ${run.html_url} for details.`