We think we have a bug here (being a beta) when some messages take a long time to process -> cause d
We think we have a bug here (being a beta) when some messages take a long time to process -> cause delays in subsequent delivery. Working on it.

accountTag as defined there.wrangler queues list today (we need to add it to the dash)startDate?
nodejs_compat.env.QUEUE.send(...) is called but the consumer never receives the message. No errors. If there isn't a known limit then I'll pair my case down to the most minimal case, but wanted to check here first.await kv_storage.put(id, JSON.stringify(data)) and I want it to go to a queue instead, how would I write that?query {
viewer {
accounts(filter: { accountTag: $accountId }) {
queueMessageOperationsAdaptiveGroups(
limit: 10000
filter: { date_geq: $startDate, date_leq: $endDate }
orderBy: [date_DESC]
) {
count
sum {
bytes
}
dimensions {
queueId
date
}
}
}
}
}{
"data": {
"viewer": {
"accounts": [
{
"queueMessageOperationsAdaptiveGroups": [
{
"count": 2446,
"dimensions": {
"date": "2024-01-24",
"queueId": "e4d7d7e594bd48bbbe49703f72e9c92a"
},
"sum": {
"bytes": 264168
}
}
]
}
]
}
},
"errors": null
}accountTagwrangler queues liststartDatenodejs_compatenv.QUEUE.send(...)await kv_storage.put(id, JSON.stringify(data))const v8 = require('v8');
// Serialize an object into a buffer using v8
function serializeWithV8(obj) {
return v8.serialize(obj);
}
// Convert the Buffer to a byte array (Uint8Array)
const byteArray = new Uint8Array(buffer.buffer, buffer.byteOffset, buffer.byteLength);
// Now you can send the byteArray over the network