chore: better name for ScheduledJob migration

- also: removed unecessary transform from earlier revision
ParabolInc · Mar 2, 2024 · d58e5ea · d58e5ea
1 parent 2571c9e
commit d58e5ea
Showing 1 changed file with 6 additions and 18 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()