diff --git a/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts b/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts index 0b77167ca3..b139d5672e 100644 --- a/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts +++ b/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts @@ -92,10 +92,9 @@ export async function getDeferredStitchableEntities(options: { })); }; - if (knex.isTransaction || !useLocking) { - return run(knex); - } - return knex.transaction(run); + return knex.isTransaction || !useLocking + ? await run(knex) + : await knex.transaction(run); } function nowPlus(knex: Knex, duration: HumanDuration): Knex.Raw {