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()]); }; }