fix: failed pins cron (#1100)

nftstorage · Jan 17, 2022 · eab0411 · eab0411
1 parent 06a99f5
commit eab0411
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/packages/cron/src/bin/pins-failed.js b/packages/cron/src/bin/pins-failed.js
@@ -5,7 +5,12 @@ import { fileURLToPath } from 'url'
 import dotenv from 'dotenv'
 import fetch from 'node-fetch'
 import { checkFailedPinStatuses } from '../jobs/pins.js'
-import { getDBClient, getCluster1, getCluster2 } from '../lib/utils.js'
+import {
+  getDBClient,
+  getCluster1,
+  getCluster2,
+  getCluster3,
+} from '../lib/utils.js'
 
 const __dirname = path.dirname(fileURLToPath(import.meta.url))
 /** @ts-ignore */
@@ -18,9 +23,10 @@ async function main() {
   const db = getDBClient(process.env)
   const cluster1 = getCluster1(process.env)
   const cluster2 = getCluster2(process.env)
+  const cluster3 = getCluster3(process.env)
   const after = process.env.AFTER ? new Date(process.env.AFTER) : oneMonthAgo()
 
-  await checkFailedPinStatuses({ db, cluster1, cluster2, after })
+  await checkFailedPinStatuses({ db, cluster1, cluster2, cluster3, after })
 }
 
 dotenv.config({ path: path.join(__dirname, '../../../../.env') })