File tree Expand file tree Collapse file tree 1 file changed +8
-1
lines changed
Expand file tree Collapse file tree 1 file changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -1563,7 +1563,14 @@ async function provisionResources<B extends Bindings>(
15631563 input . eventSources
15641564 ? Promise . all (
15651565 input . eventSources . map ( async ( eventSource ) => {
1566- return await QueueConsumer ( `${ eventSource . queue . id } -consumer` , {
1566+ // In local dev mode, queue.id is "" (no Cloudflare API call).
1567+ // Use queue.dev.id (resource ID, e.g. "email-queue") to avoid
1568+ // all consumers colliding on the same "-consumer" resource ID.
1569+ // See: https://github.com/alchemy-run/alchemy/issues/1363
1570+ const queueConsumerId = options . local
1571+ ? eventSource . queue . dev ?. id || eventSource . queue . id
1572+ : eventSource . queue . id ;
1573+ return await QueueConsumer ( `${ queueConsumerId } -consumer` , {
15671574 queue : eventSource . queue ,
15681575 scriptName : options . name ,
15691576 settings : eventSource . settings ,
You can’t perform that action at this time.
0 commit comments