diff --git a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts index 1c793eb0fc..bd32582b12 100644 --- a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts +++ b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts @@ -263,9 +263,10 @@ export class DefaultProcessingDatabase implements ProcessingDatabase { return items; }; - const items = knex.isTransaction - ? await run(knex) - : await knex.transaction(run); + const items = + knex.isTransaction || !useLocking + ? await run(knex) + : await knex.transaction(run); return { items: items.map( diff --git a/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts b/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts index 4ed41e9308..0b77167ca3 100644 --- a/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts +++ b/plugins/catalog-backend/src/database/operations/stitcher/getDeferredStitchableEntities.ts @@ -92,7 +92,7 @@ export async function getDeferredStitchableEntities(options: { })); }; - if (knex.isTransaction) { + if (knex.isTransaction || !useLocking) { return run(knex); } return knex.transaction(run);