fix job vs id

bin/cml-runner.js

@@ -226,10 +226,11 @@ const runLocal = async (opts) => {
       RUNNER_TIMEOUT_TIMER = 0;
     } else if (log && log.status === 'job_ended') {
       const { job } = log;
+
       if (!RUNNER_SHUTTING_DOWN) {
         const jobs = job
           ? [job]
-          : (await cml.pipelineJobs({ ids: RUNNER_JOBS_RUNNING }))
+          : (await cml.pipelineJobs({ jobs: RUNNER_JOBS_RUNNING }))
               .filter((job) => job.status === 'completed')
               .map((job) => job.id);
 

src/drivers/github.js

@@ -289,16 +289,16 @@ class Github {
   }
 
   async pipelineJobs(opts = {}) {
-    const { ids } = opts;
+    const { jobs: runnerJobs } = opts;
     const { owner, repo } = ownerRepo({ uri: this.repo });
     const { actions } = octokit(this.token, this.repo);
 
     const jobs = await Promise.all(
-      ids.map(async (id) => {
+      runnerJobs.map(async (job) => {
         const { data } = await actions.getJobForWorkflowRun({
           owner,
           repo,
-          job_id: id
+          job_id: job.id
         });
 
         return data;
@@ -353,23 +353,23 @@ class Github {
   }
 
   async pipelineRestart(opts = {}) {
-    const { jobId: job_id } = opts;
+    const { jobId } = opts;
     const { owner, repo } = ownerRepo({ uri: this.repo });
     const { actions } = octokit(this.token, this.repo);
 
     const {
-      data: { run_id }
+      data: { run_id: runId }
     } = await actions.getJobForWorkflowRun({
       owner,
       repo,
-      job_id
+      job_id: jobId
     });
 
     try {
       await actions.cancelWorkflowRun({
         owner,
         repo,
-        run_id
+        run_id: runId
       });
     } catch (err) {
       // HANDLES: Cannot cancel a workflow run that is completed.
@@ -380,15 +380,15 @@ class Github {
     } = await actions.getWorkflowRun({
       owner,
       repo,
-      run_id
+      run_id: runId
     });
 
     if (status !== 'queued') {
       try {
         await actions.reRunWorkflow({
           owner,
           repo,
-          run_id
+          run_id: runId
         });
       } catch (err) {}
     }