From 2cd44e393111ed2c4c4712931e6f470a08e67f78 Mon Sep 17 00:00:00 2001 From: Sven Sauleau Date: Wed, 1 Mar 2023 14:59:08 +0000 Subject: [PATCH] consumer: create db connection for each message (debug) --- consumer/src/index.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consumer/src/index.ts b/consumer/src/index.ts index ada414d..0e3cec8 100644 --- a/consumer/src/index.ts +++ b/consumer/src/index.ts @@ -22,10 +22,10 @@ export type Env = { export default { async queue(batch: MessageBatch, env: Env, ctx: ExecutionContext) { const sentry = initSentryQueue(env, ctx) - const db = await getDatabase(env) try { for (const message of batch.messages) { + const db = await getDatabase(env) const actor = await actors.getActorById(db, new URL(message.body.actorId)) if (actor === null) { console.warn(`actor ${message.body.actorId} is missing`)