From 77c207ccba33b5d80f3d06e5d5f513ddaa62f4dc Mon Sep 17 00:00:00 2001 From: Damon Kaswell Date: Mon, 28 Nov 2022 08:03:35 -0800 Subject: [PATCH] Remove reference to unused schema Signed-off-by: Damon Kaswell --- .../IncrementalIngestionDatabaseManager.ts | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) 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 c6d5fe795b..0fd560544d 100644 --- a/plugins/catalog-backend-module-incremental-ingestion/src/database/IncrementalIngestionDatabaseManager.ts +++ b/plugins/catalog-backend-module-incremental-ingestion/src/database/IncrementalIngestionDatabaseManager.ts @@ -311,14 +311,14 @@ export class IncrementalIngestionDatabaseManager { .join('search', 'search.entity_id', 'final_entities.entity_id') .whereNotIn( 'entity_ref', - tx('ingestion.ingestion_marks') + tx('ingestion_marks') .join( - 'ingestion.ingestion_mark_entities', - 'ingestion.ingestion_marks.id', - 'ingestion.ingestion_mark_entities.ingestion_mark_id', + 'ingestion_mark_entities', + 'ingestion_marks.id', + 'ingestion_mark_entities.ingestion_mark_id', ) - .select('ingestion.ingestion_mark_entities.ref') - .where('ingestion.ingestion_marks.ingestion_id', ingestionId), + .select('ingestion_mark_entities.ref') + .where('ingestion_marks.ingestion_id', ingestionId), ) .andWhere( 'search.key', @@ -463,7 +463,7 @@ export class IncrementalIngestionDatabaseManager { } /** - * Starts the cancel process for the current ingestion. + * Starts the cancel process for the current * @param ingestionId - string * @param message - string (optional) */ @@ -478,7 +478,7 @@ export class IncrementalIngestionDatabaseManager { } /** - * Completes the cancel process and triggers a new ingestion. + * Completes the cancel process and triggers a new * @param ingestionId - string */ async setProviderCanceled(ingestionId: string) {