batch.queue === env.FOO_QUEUE.name
batch.queue === env.FOO_QUEUE.name
JstartsWith ugliness
B
send() methods. wrangler.toml
J
J
P
JJ
MBoth max_batch_size and max_batch_timeout work together. Whichever limit is reached first will trigger the delivery of a batch.
AA
d1a94a7c4e4a4c23a6dbc74a8abbad11
OO
max_concurrency
await wait(1000)
AA
AAPAA
XXX
1
S
welcome-and-rules. It creates confusion for people trying to help you and doesn't get your issue or question solved any faster.
PP
P
PPAAAA
A
A
NP
I think the issue here is that the queue is not a standard worker. It has extra limitations that nobody is mentioning anywhere. Something to add to the docs as it will save so much time PA
S
J
try/catch
GJB
max_concurrency1max_batch_sizestartsWithsend()export default {
async queue(batch) {
const ntfyUrl = 'https://ntfy.sh/doofy';
const message = batch.messages[0];
if (message) {
try {
const response = await fetch(ntfyUrl, {
method: 'POST',
body: message.body,
});
if (response.ok) message.ack();
} catch (error) {
console.error(`Failed to process message: ${error}`);
}
}
},
};