queued for the status.get(crypto.randomUUID()) always return an existing instance?queued?Network connection lost. error. pretty weird!



[vpw:inf] Starting isolated runtimes for vitest.config.mts...running the worker via
Worker "workflows:shipped"'s binding "USER_WORKFLOW" refers to service "core:user:vitest-pool-workers-runner-" with a named entrypoint "ShippedWorkflow", but "core:user:vitest-pool-workers-runner-" has no such named entrypoint.
npm run dev works as expected. Ideas?
An RPC stub was not disposed properly, but I still couldn't figure out the issue. I made a minimal reproducible example. My workflow has 1 step and does nothing except for logging:3.95.0Successful nevertheless.userId in the params, generate a composite ID e.g. ${userId}-${randomHex} event param?WorkflowEvent Requests (invocations): the number of Workflow invocations. Subrequests made from a Workflow do not incur additional request costs.


queuedqueued.get(crypto.randomUUID())Network connection lost.npm run dev An RPC stub was not disposed properlyexport class AddOrUpdateItemWorkflow extends WorkflowEntrypoint<Bindings, Params> {
async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
await step.do('assign item sqid', async () => {
console.log(event.payload.item.title);
});
}
}const instance = await env.ADD_UPDATE_ITEM_WORKFLOW.create({params: { item }});
console.log(instance.id);
console.log(await instance.status());[ERROR] An RPC stub was not disposed properly. You must call dispose() on all stubs in order to let the other side know that you are no longer using them. You cannot rely on the garbage collector for this because it may take arbitrarily long before actually collecting unreachable objects. As a shortcut, calling dispose() on the result of an RPC call disposes all stubs within it.3.95.0{
"$cloudflare": {
"diagnosticsChannelEvents": [],
"truncated": false,
"event": {
"rpcMethod": "run"
},
"scriptName": "minifeed",
"outcome": "exception",
"eventType": "rpc",
"entrypoint": "AddOrUpdateItemWorkflow",
"scriptVersion": {
"id": "44488eac-<REDACTED>-b1db278bc4cc"
},
"executionModel": "stateless",
"$metadata": {
"requestId": "L7NQ<REDACTED>U6AF",
"id": "01JE<REDACTED>VKMK8",
"type": "cf-worker-event",
"error": "run"
}
},
"level": "error",
"message": "run"
}Successful${userId}-${randomHex}eventWorkflowEventimport Cloudflare from 'cloudflare';
const client = new Cloudflare({
apiToken: this.env.CLOUDFLARE_API_TOKEN
});
for await (const instance of client.workflows.instances.list('my-workflow', { account_id: this.env.ACCOUNT_ID, status: "running"})) {
console.log(instance.id);
}