From afc872aac6bac648863c2f0e8ee762c8d99e595c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fredrik=20Adel=C3=B6w?= Date: Wed, 20 May 2026 08:06:37 +0200 Subject: [PATCH] Fix implicit any types on transaction callback parameters MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude Opus 4.6 (1M context) Signed-off-by: Fredrik Adelöw --- .../catalog-backend/src/database/DefaultProcessingDatabase.ts | 4 ++-- .../operations/stitcher/getDeferredStitchableEntities.ts | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts index 540e7fea26..1c793eb0fc 100644 --- a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts +++ b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts @@ -229,7 +229,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase { // single transaction so that the row locks persist until // next_update_at has been bumped. const run = async (tx: Knex | Knex.Transaction) => { - const items = await tx('refresh_state') + const items: DbRefreshStateRow[] = await tx('refresh_state') .select([ 'entity_id', 'entity_ref', @@ -250,7 +250,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase { }); if (items.length > 0) { - await tx('refresh_state') + await tx('refresh_state') .whereIn( 'entity_ref', items.map(i => i.entity_ref), diff --git a/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts b/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts index 7535d6e5ed..4ed41e9308 100644 --- a/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts +++ b/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts @@ -61,7 +61,7 @@ export async function getDeferredStitchableEntities(options: { // are released after the SELECT auto-commits, and another worker can // claim the same rows before the UPDATE runs. const run = async (tx: Knex | Knex.Transaction) => { - const items = await tx('stitch_queue') + const items: DbStitchQueueRow[] = await tx('stitch_queue') .select('entity_ref', 'next_stitch_at', 'stitch_ticket') .where('next_stitch_at', '<=', tx.fn.now()) .orderBy('next_stitch_at', 'asc') @@ -76,7 +76,7 @@ export async function getDeferredStitchableEntities(options: { return []; } - await tx('stitch_queue') + await tx('stitch_queue') .whereIn( 'entity_ref', items.map(i => i.entity_ref),