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<DbRefreshStateRow>('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<DbRefreshStateRow>('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<DbStitchQueueRow>('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<DbStitchQueueRow>('stitch_queue')
+    await tx('stitch_queue')
       .whereIn(
         'entity_ref',
         items.map(i => i.entity_ref),