diff --git a/packages/core-elasticsearch/src/indices/rounds.ts b/packages/core-elasticsearch/src/indices/rounds.ts index e1af0d2d1f..f9b8fdabf9 100644 --- a/packages/core-elasticsearch/src/indices/rounds.ts +++ b/packages/core-elasticsearch/src/indices/rounds.ts @@ -24,6 +24,10 @@ export class Rounds extends Index { this.logger.info(`[ES] Indexing ${rows.length} round slots [${first(rounds)} - ${last(rounds)}]`); try { + for (const row of rows) { + row.id = `${row.height}_${row.publicKey}`; + } + await this.bulkUpsert(rows); storage.update({