diff --git a/plugins/catalog-backend-module-incremental-ingestion/src/database/IncrementalIngestionDatabaseManager.ts b/plugins/catalog-backend-module-incremental-ingestion/src/database/IncrementalIngestionDatabaseManager.ts index 9eb52c4558..e837f2b259 100644 --- a/plugins/catalog-backend-module-incremental-ingestion/src/database/IncrementalIngestionDatabaseManager.ts +++ b/plugins/catalog-backend-module-incremental-ingestion/src/database/IncrementalIngestionDatabaseManager.ts @@ -577,13 +577,15 @@ export class IncrementalIngestionDatabaseManager { .update('ingestion_mark_id', markId) .whereIn('ref', existingRefsArray); - await tx('ingestion_mark_entities').insert( - newRefs.map(ref => ({ - id: v4(), - ingestion_mark_id: markId, - ref, - })), - ); + if (newRefs.length > 0) { + await tx('ingestion_mark_entities').insert( + newRefs.map(ref => ({ + id: v4(), + ingestion_mark_id: markId, + ref, + })), + ); + } }); }