Use ESLint-enforced code styling
Signed-off-by: Damon Kaswell <damon.kaswell1@hp.com>
This commit is contained in:
committed by
Fredrik Adelöw
parent
79ce0de43f
commit
e8856d5ef9
@@ -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);
|
||||
|
||||
@@ -24,10 +24,10 @@ import { createIncrementalProviderRouter } from '../routes';
|
||||
|
||||
export class Deferred<T> implements Promise<T> {
|
||||
// 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<T>['then'];
|
||||
|
||||
Reference in New Issue
Block a user