Added missing await

stevebux · stevebux · commit e564ec123ac6 · 2026-01-12T16:36:59.000Z
diff --git a/lambdas/allocation/src/allocator.ts b/lambdas/allocation/src/allocator.ts
@@ -17,10 +17,9 @@ export default function createAllocator(deps: Deps): SNSHandler {
     for (const sqsCommand of sqsCommands) {
       deps.logger.info({
         description: "Placing message on queue",
-        // MessageGroupId: sqsCommand.MessageGroupId,
-        Message: JSON.stringify(sqsCommand),
+        MessageGroupId: sqsCommand.input.MessageGroupId,
       });
-      deps.sqsClient.send(sqsCommand);
+      await deps.sqsClient.send(sqsCommand);
     }
   };
 }

Original file line number	Diff line number	Diff line change
`@@ -17,10 +17,9 @@ export default function createAllocator(deps: Deps): SNSHandler {`
`17`	`17`	`for (const sqsCommand of sqsCommands) {`
`18`	`18`	`deps.logger.info({`
`19`	`19`	`description: "Placing message on queue",`
`20`		`- // MessageGroupId: sqsCommand.MessageGroupId,`
`21`		`- Message: JSON.stringify(sqsCommand),`
	`20`	`+ MessageGroupId: sqsCommand.input.MessageGroupId,`
`22`	`21`	`});`
`23`		`- deps.sqsClient.send(sqsCommand);`
	`22`	`+ await deps.sqsClient.send(sqsCommand);`
`24`	`23`	`}`
`25`	`24`	`};`
`26`	`25`	`}`