Hello! I have a very misterious bug with queues. I have a job that iterates a batch of 3 messages, but it only iterates 2 messages and then it never gets to the third:
export async function queue(batch, env) { console.log({ messages: JSON.stringify(batch.messages) }) // This logs an array of 3 objects for (const msg of batch.messages) { console.log({ message: JSON.stringify(msg) }) // This only logs twice try { // ...do things msg.ack() } catch (e) { console.error(`adjustUser error: ${e}`) // This never logs msg.retry() } }}
export async function queue(batch, env) { console.log({ messages: JSON.stringify(batch.messages) }) // This logs an array of 3 objects for (const msg of batch.messages) { console.log({ message: JSON.stringify(msg) }) // This only logs twice try { // ...do things msg.ack() } catch (e) { console.error(`adjustUser error: ${e}`) // This never logs msg.retry() } }}