diff --git a/plugins/incremental-ingestion-backend/src/engine/IncrementalIngestionEngine.ts b/plugins/incremental-ingestion-backend/src/engine/IncrementalIngestionEngine.ts index 6182ae95c4..bc347310a8 100644 --- a/plugins/incremental-ingestion-backend/src/engine/IncrementalIngestionEngine.ts +++ b/plugins/incremental-ingestion-backend/src/engine/IncrementalIngestionEngine.ts @@ -128,11 +128,10 @@ export class IncrementalIngestionEngine implements IterationEngine { attempts: record.attempts as number, nextActionAt: record.next_action_at.valueOf() as number, }; - } else { - const result = await this.manager.createProviderIngestionRecord(providerName); - this.options.logger.info(`incremental-engine: Ingestion record created: '${result.ingestionId}'`); - return result; - } + } + const result = await this.manager.createProviderIngestionRecord(providerName); + this.options.logger.info(`incremental-engine: Ingestion record created: '${result.ingestionId}'`); + return result; } async ingestOneBurst(id: string, signal: AbortSignal) { @@ -149,6 +148,7 @@ export class IncrementalIngestionEngine implements IterationEngine { await this.options.provider.around(async (context: unknown) => { let next = await this.options.provider.next(context, cursor); count++; + // eslint-disable-next-line no-constant-condition while (true) { done = next.done; await this.mark(id, sequence, next.entities, next.done, next.cursor); diff --git a/plugins/incremental-ingestion-backend/src/service/IncrementalCatalogBuilder.ts b/plugins/incremental-ingestion-backend/src/service/IncrementalCatalogBuilder.ts index 93c7c571d8..30bdae9746 100644 --- a/plugins/incremental-ingestion-backend/src/service/IncrementalCatalogBuilder.ts +++ b/plugins/incremental-ingestion-backend/src/service/IncrementalCatalogBuilder.ts @@ -24,10 +24,10 @@ import { createIncrementalProviderRouter } from '../routes'; export class Deferred implements Promise { // eslint-disable-next-line @typescript-eslint/ban-ts-comment - //@ts-ignore + // @ts-ignore resolve: (value: T) => void; // eslint-disable-next-line @typescript-eslint/ban-ts-comment - //@ts-ignore + // @ts-ignore reject: (error: Error) => void; then: Promise['then'];