diff --git a/server/lib/indexers/shared/abstract-indexer.ts b/server/lib/indexers/shared/abstract-indexer.ts index a2f439b..8940733 100644 --- a/server/lib/indexers/shared/abstract-indexer.ts +++ b/server/lib/indexers/shared/abstract-indexer.ts @@ -109,7 +109,11 @@ export abstract class AbstractIndexer { const elements = this.elementsToBulkIndex this.elementsToBulkIndex = [] + logger.info(`Bulk indexing ${elements.length} elements in ${this.indexName}`) + this.bulkProcessEnqueuedTask = await this.indexElements(elements) + + this.bulkIndexationTimer = undefined } catch (err) { logger.error({ err }, 'Cannot schedule bulk indexation') }