fix(scale-down): Clearing cache between runs (#1164)

* fix(scale-down): Clearing cache between runs * Removing debug statement
philips-labs · Sep 14, 2021 · e72227b · e72227b
1 parent ba2536b
commit e72227b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/modules/runners/lambdas/runners/src/scale-runners/cache.ts b/modules/runners/lambdas/runners/src/scale-runners/cache.ts
@@ -7,4 +7,9 @@ export type GhRunners = UnboxPromise<ReturnType<Octokit['actions']['listSelfHost
 export class githubCache {
   static clients: Map<string, Octokit> = new Map();
   static runners: Map<string, GhRunners> = new Map();
+
+  public static reset(): void {
+    githubCache.clients.clear();
+    githubCache.runners.clear();
+  }
 }
diff --git a/modules/runners/lambdas/runners/src/scale-runners/scale-down.ts b/modules/runners/lambdas/runners/src/scale-runners/scale-down.ts
@@ -57,10 +57,12 @@ async function listGitHubRunners(runner: RunnerInfo): Promise<GhRunners> {
     runner.type === 'Org'
       ? await client.paginate(client.actions.listSelfHostedRunnersForOrg, {
           org: runner.owner,
+          per_page: 100,
         })
       : await client.paginate(client.actions.listSelfHostedRunnersForRepo, {
           owner: runner.owner.split('/')[0],
           repo: runner.owner.split('/')[1],
+          per_page: 100,
         });
   githubCache.runners.set(key, runners);
 
@@ -182,6 +184,7 @@ function filterRunners(ec2runners: RunnerList[]): RunnerInfo[] {
 }
 
 export async function scaleDown(): Promise<void> {
+  githubCache.reset();
   const scaleDownConfigs = JSON.parse(process.env.SCALE_DOWN_CONFIG) as [ScalingDownConfig];
   const environment = process.env.ENVIRONMENT;