Queue always retries
I have a queue consumer that's literally ACK-ing messages:
But I keep seeing retries (see screenshot). What's going on?
Btw here's my config:
export default {
async queue(batch: MessageBatch, env: Env, ctx: ExecutionContext) {
try {
await process(env, ctx);
} catch (e) {
const logger = getLogger(ctx, env.LOG_TAIL_TOKEN);
await logger.error(`Uncaught error: ${e instanceof Error ? e.stack : String(e)}`);
} finally {
batch.ackAll(); // <-- ACK ALL
}
},
...router
};export default {
async queue(batch: MessageBatch, env: Env, ctx: ExecutionContext) {
try {
await process(env, ctx);
} catch (e) {
const logger = getLogger(ctx, env.LOG_TAIL_TOKEN);
await logger.error(`Uncaught error: ${e instanceof Error ? e.stack : String(e)}`);
} finally {
batch.ackAll(); // <-- ACK ALL
}
},
...router
};But I keep seeing retries (see screenshot). What's going on?
Btw here's my config:
"queues": {
"consumers": [
{
"queue": "job-kickstart",
"max_batch_size": 5,
"max_batch_timeout": 2,
"max_concurrency": 10
}
],
"producers": [...]
}, "queues": {
"consumers": [
{
"queue": "job-kickstart",
"max_batch_size": 5,
"max_batch_timeout": 2,
"max_concurrency": 10
}
],
"producers": [...]
},
