wait for completion

testdriverai · Feb 21, 2024 · 17b686e · 17b686e
1 parent 9ad1b80
commit 17b686e
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 26 deletions.
diff --git a/dist/index.js b/dist/index.js
@@ -32477,22 +32477,18 @@ const waitFor = (ms) => new Promise((r) => setTimeout(r, ms));
       }
     );
 
-    console.log(
-      "workflow data",
-      workflow.data.status,
-      workflow.data.conclusion
-    );
+    return workflow.data.status;
   };
 
-  let checkTimes = 0;
-  await checkStatus();
-  const intervalId = setInterval(() => {
-    checkStatus();
-    checkTimes++;
-    if (checkTimes > 10) {
-      clearInterval(intervalId);
+  const waitUntilComplete = async () => {
+    let status = await checkStatus();
+    while (status !== "completed") {
+      await waitFor(1000 * 60 * 1);
+      status = await checkStatus();
     }
-  }, 1000 * 60 * 1);
+  };
+
+  await waitUntilComplete();
 
   // list workflow run artifacts
   const artifacts = await octokit.request(
@@ -32530,6 +32526,8 @@ const waitFor = (ms) => new Promise((r) => setTimeout(r, ms));
   const oiResult = textDecoder.decode(unzippedData["oiResult.txt"]);
 
   console.log(shareLink, oiResult);
+
+  setOutput(shareLink, oiResult);
 })();
 
 })();

diff --git a/src/index.js b/src/index.js
@@ -93,22 +93,18 @@ const waitFor = (ms) => new Promise((r) => setTimeout(r, ms));
       }
     );
 
-    console.log(
-      "workflow data",
-      workflow.data.status,
-      workflow.data.conclusion
-    );
+    return workflow.data.status;
   };
 
-  let checkTimes = 0;
-  await checkStatus();
-  const intervalId = setInterval(() => {
-    checkStatus();
-    checkTimes++;
-    if (checkTimes > 10) {
-      clearInterval(intervalId);
+  const waitUntilComplete = async () => {
+    let status = await checkStatus();
+    while (status !== "completed") {
+      await waitFor(1000 * 60 * 1);
+      status = await checkStatus();
     }
-  }, 1000 * 60 * 1);
+  };
+
+  await waitUntilComplete();
 
   // list workflow run artifacts
   const artifacts = await octokit.request(
@@ -146,4 +142,6 @@ const waitFor = (ms) => new Promise((r) => setTimeout(r, ms));
   const oiResult = textDecoder.decode(unzippedData["oiResult.txt"]);
 
   console.log(shareLink, oiResult);
+
+  setOutput(shareLink, oiResult);
 })();