chore: better name for ScheduledJob migration

- also: removed unecessary transform from earlier revision - also: fixed off-by-1 error in move migration
ParabolInc · Mar 3, 2024 · df6024b · df6024b
1 parent 2571c9e
commit df6024b
Showing 1 changed file with 7 additions and 19 deletions.
diff --git a/...rations/1709312768000_scheduledJobMove.ts → ...rations/1709312768000_moveScheduledJob.ts b/...rations/1709312768000_scheduledJobMove.ts → ...rations/1709312768000_moveScheduledJob.ts
@@ -15,26 +15,14 @@ export async function up() {
     {table: 'ScheduledJob'}
   )
 
-  const transformRethinkRow = (row: any) => {
-    const {runAt, type, orgId, meetingId} = row
-    return {
-      runAt,
-      type,
-      orgId,
-      meetingId
-    }
-  }
-
   const getNextData = async (leftBoundCursor: Date | undefined) => {
     const startAt = leftBoundCursor || r.minval
-    const nextBatch = (
-      await r
-        .table('ScheduledJob')
-        .between(startAt, r.maxval, {index: 'runAt', leftBound: 'open'})
-        .orderBy({index: 'runAt'})
-        .limit(batchSize)
-        .run()
-    ).map(transformRethinkRow)
+    const nextBatch = await r
+      .table('ScheduledJob')
+      .between(startAt, r.maxval, {index: 'runAt', leftBound: 'open'})
+      .orderBy({index: 'runAt'})
+      .limit(batchSize)
+      .run()
     if (nextBatch.length === 0) return null
     if (nextBatch.length < batchSize) return nextBatch
     const lastItem = nextBatch.pop()
@@ -44,7 +32,7 @@ export async function up() {
         'batchSize is smaller than the number of items that share the same cursor. Increase batchSize'
       )
     }
-    return nextBatch.slice(0, lastMatchingRunAt + 1)
+    return nextBatch.slice(0, lastMatchingRunAt)
   }
 
   await pg.tx('ScheduledJob', (task) => {