fix queued tx cancel

arcoraven · arcoraven · commit 59cae60b9972 · 2024-08-17T16:18:50.000-07:00
diff --git a/src/worker/tasks/migratePostgresTransactionsWorker.ts b/src/worker/tasks/migratePostgresTransactionsWorker.ts
@@ -94,10 +94,10 @@ const handler: Processor<any, void, string> = async (job: Job<string>) => {
           message: errorMessage,
         });
       }
-
-      await cancelPostgresTransactions({ pgtx, queueIds: toCancel });
-      job.log(`Done migrating ${toCancel.length} queued transactions.`);
     }
+
+    await cancelPostgresTransactions({ pgtx, queueIds: toCancel });
+    job.log(`Done migrating ${toCancel.length} queued transactions.`);
   });
 };
 

Original file line number	Diff line number	Diff line change
`@@ -94,10 +94,10 @@ const handler: Processor<any, void, string> = async (job: Job<string>) => {`
`94`	`94`	`message: errorMessage,`
`95`	`95`	`});`
`96`	`96`	`}`
`97`		`-`
`98`		`- await cancelPostgresTransactions({ pgtx, queueIds: toCancel });`
`99`		- job.log(`Done migrating ${toCancel.length} queued transactions.`);
`100`	`97`	`}`
	`98`	`+`
	`99`	`+ await cancelPostgresTransactions({ pgtx, queueIds: toCancel });`
	`100`	+ job.log(`Done migrating ${toCancel.length} queued transactions.`);
`101`	`101`	`});`
`102`	`102`	`};`
`103`	`103`