CD
Cloudflare Developers•2mo ago
TW

Queue always retries

I have a queue consumer that's literally ACK-ing messages: 
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": [...]
    },
No description
0 Replies
No replies yetBe the first to reply to this messageJoin

Did you find this page helpful?