Deno Kv: "Database is locked" on enqueue

I'm running 2 Deno services. Service

gathers info and posts it to service

via HTTP post, where

immediately offloads the request to a

Deno.kv

Deno.kv

queue and returns. There are a lot of posts being made, and once a couple thousand events are queued I'm noticing that inconsistently service

will throw the following error:

[uncaught application error]: TypeError - database is locked

request: {
  url: "http://localhost:8080/api/events",
  method: "POST",
  hasBody: true
}
response: { status: 500, type: "text", hasBody: true, writable: true }

    at async doAtomicWriteInPlace (ext:deno_kv/01_db.ts:629:10)
    at async Kv.enqueue (ext:deno_kv/01_db.ts:163:26)
    at async file:///<my_filepath>/src/api/events.controller.ts:13:5
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async default (file:///<my_filepath>/src/middleware/errorhandling.middleware.ts:9:9)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async Application.#handleRequest (https://jsr.io/@oak/oak/17.0.0/application.ts:605:9)

[uncaught application error]: TypeError - database is locked

request: {
  url: "http://localhost:8080/api/events",
  method: "POST",
  hasBody: true
}
response: { status: 500, type: "text", hasBody: true, writable: true }

    at async doAtomicWriteInPlace (ext:deno_kv/01_db.ts:629:10)
    at async Kv.enqueue (ext:deno_kv/01_db.ts:163:26)
    at async file:///<my_filepath>/src/api/events.controller.ts:13:5
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async default (file:///<my_filepath>/src/middleware/errorhandling.middleware.ts:9:9)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async Application.#handleRequest (https://jsr.io/@oak/oak/17.0.0/application.ts:605:9)

the controller handling these calls looks like the following:

eventsRouter.post("/", async (ctx) => {
    const data: Dto = await ctx.request.body.json();

    await kv.enqueue({ type: "handle_event", details: data }, cfg.KV_OPTIONS);

    ctx.response.status = 200;
});

eventsRouter.post("/", async (ctx) => {
    const data: Dto = await ctx.request.body.json();

    await kv.enqueue({ type: "handle_event", details: data }, cfg.KV_OPTIONS);

    ctx.response.status = 200;
});

It doesn't seem to be breaking consistently after 'x amount of queued items' or anything like that, from what I can see.
I'm not quite sure what is causing it, perhaps anyone else has some experience with this? Thanks for any help

Deno Kv: "Database is locked" on enqueue

I'm running 2 Deno services. Service

gathers info and posts it to service

via HTTP post, where

immediately offloads the request to a

Deno.kv

Deno.kv

queue and returns. There are a lot of posts being made, and once a couple thousand events are queued I'm noticing that inconsistently service

will throw the following error:

[uncaught application error]: TypeError - database is locked

request: {
  url: "http://localhost:8080/api/events",
  method: "POST",
  hasBody: true
}
response: { status: 500, type: "text", hasBody: true, writable: true }

    at async doAtomicWriteInPlace (ext:deno_kv/01_db.ts:629:10)
    at async Kv.enqueue (ext:deno_kv/01_db.ts:163:26)
    at async file:///<my_filepath>/src/api/events.controller.ts:13:5
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async default (file:///<my_filepath>/src/middleware/errorhandling.middleware.ts:9:9)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async Application.#handleRequest (https://jsr.io/@oak/oak/17.0.0/application.ts:605:9)

[uncaught application error]: TypeError - database is locked

request: {
  url: "http://localhost:8080/api/events",
  method: "POST",
  hasBody: true
}
response: { status: 500, type: "text", hasBody: true, writable: true }

    at async doAtomicWriteInPlace (ext:deno_kv/01_db.ts:629:10)
    at async Kv.enqueue (ext:deno_kv/01_db.ts:163:26)
    at async file:///<my_filepath>/src/api/events.controller.ts:13:5
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async default (file:///<my_filepath>/src/middleware/errorhandling.middleware.ts:9:9)
    at async dispatch (https://jsr.io/@oak/oak/17.0.0/middleware.ts:90:7)
    at async Application.#handleRequest (https://jsr.io/@oak/oak/17.0.0/application.ts:605:9)

the controller handling these calls looks like the following:

eventsRouter.post("/", async (ctx) => {
    const data: Dto = await ctx.request.body.json();

    await kv.enqueue({ type: "handle_event", details: data }, cfg.KV_OPTIONS);

    ctx.response.status = 200;
});

eventsRouter.post("/", async (ctx) => {
    const data: Dto = await ctx.request.body.json();

    await kv.enqueue({ type: "handle_event", details: data }, cfg.KV_OPTIONS);

    ctx.response.status = 200;
});

Deno Kv: "Database is locked" on enqueue

Similar Threads

Deno Kv: "Database is locked" on enqueue

Similar Threads

Similar Threads

Similar Threads