Fix for backfiller masterQueue/workerQueue

Author: matt-aitken

apps/webapp/app/routes/admin.api.v1.runs-replication.backfill.ts

@@ -59,7 +59,12 @@ export async function action({ request }: ActionFunctionArgs) {
       throw new Error("Runs replication instance not found");
     }
 
-    await runsReplicationInstance.backfill(runs);
+    await runsReplicationInstance.backfill(
+      runs.map((run) => ({
+        ...run,
+        masterQueue: run.workerQueue,
+      }))
+    );
 
     logger.info("Backfilled runs", { runs });
 

apps/webapp/app/services/runsBackfiller.server.ts

@@ -73,7 +73,12 @@ export class RunsBackfillerService {
         lastCreatedAt: runs[runs.length - 1].createdAt,
       });
 
-      await this.runsReplicationInstance.backfill(runs);
+      await this.runsReplicationInstance.backfill(
+        runs.map((run) => ({
+          ...run,
+          masterQueue: run.workerQueue,
+        }))
+      );
 
       const lastRun = runs[runs.length - 1];