From 82eadcbe2fefd6ec5fc74b098445a6dedc63528b Mon Sep 17 00:00:00 2001 From: Chris Guimaraes Date: Mon, 31 Jul 2023 16:53:35 +0100 Subject: [PATCH] fix: lint --- src/datastore/pg-write-store.ts | 1 - src/event-replay/parquet-based/helpers.ts | 2 +- .../parquet-based/replay-controller.ts | 14 ++------------ 3 files changed, 3 insertions(+), 14 deletions(-) diff --git a/src/datastore/pg-write-store.ts b/src/datastore/pg-write-store.ts index d1cbb00c..deb794b2 100644 --- a/src/datastore/pg-write-store.ts +++ b/src/datastore/pg-write-store.ts @@ -3327,7 +3327,6 @@ export class PgWriteStore extends PgStore { const tables: string[] = tablesQuery.map((r: { tablename: string }) => r.tablename); for (const table of tables) { - console.log(table) const result = await sql`REINDEX TABLE ${sql(table)}`; if (result.count === 0) { throw new Error(`No updates made while toggling table indexes`); diff --git a/src/event-replay/parquet-based/helpers.ts b/src/event-replay/parquet-based/helpers.ts index 84b1bd9b..32655ae5 100644 --- a/src/event-replay/parquet-based/helpers.ts +++ b/src/event-replay/parquet-based/helpers.ts @@ -70,7 +70,7 @@ const genIdsFiles = async (dataset: DatasetStore) => { const args = process.argv.slice(2); let workers: number = 1; - if(args.length > 1) { + if (args.length > 1) { workers = Number(args[1].split('=')[1]); } diff --git a/src/event-replay/parquet-based/replay-controller.ts b/src/event-replay/parquet-based/replay-controller.ts index 49c33432..b102dc56 100644 --- a/src/event-replay/parquet-based/replay-controller.ts +++ b/src/event-replay/parquet-based/replay-controller.ts @@ -268,19 +268,9 @@ export class ReplayController { await this.ingestNewBlockEvents(); // RAW events to event_observer_requests table - await Promise.all( - [ - this.ingestRawEvents(), - this.ingestRawNewBlockEvents() - ] - ); + await Promise.all([this.ingestRawEvents(), this.ingestRawNewBlockEvents()]); // NEW_BURN_BLOCK and ATTACHMENTS/NEW events - await Promise.all( - [ - this.ingestNewBurnBlockEvents(), - this.ingestAttachmentNewEvents() - ] - ); + await Promise.all([this.ingestNewBurnBlockEvents(), this.ingestAttachmentNewEvents()]); }; }