cancel_tasks_in_groups.js

import taskcluster from 'taskcluster-client';

let taskGroupId = 'cfMDvTzETHagYx-uSPCOxQ';

async () => {
  let queue = new taskcluster.Queue();
  let continuationToken;

  let cancellations = [];
  do {
    let result = await queue.listTaskGroup(taskGroupId, continuationToken? {continuationToken} : {});
    continuationToken = result.continuationToken;
    for (let task of result.tasks) {
      if (["pending", "running"].includes(task.status.state)) {
        console.log(`cancelling ${task.status.taskId}`);
        cancellations.push(queue.cancelTask(task.status.taskId));
      }
    }
  } while(continuationToken)

  console.log(`waiting for ${cancellations.length} to finish`);
  await Promise.all(cancellations);
}().catch(e => {console.log(e)});