From 047e9e4046ea84ab9d455df792e2ab0c40491e75 Mon Sep 17 00:00:00 2001 From: busma13 Date: Tue, 27 Aug 2024 13:04:50 -0700 Subject: [PATCH] fix import in teraslice-state-storage --- .../src/elasticsearch-state-storage/index.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/packages/teraslice-state-storage/src/elasticsearch-state-storage/index.ts b/packages/teraslice-state-storage/src/elasticsearch-state-storage/index.ts index 7905d9f6a78..d17256ce84a 100644 --- a/packages/teraslice-state-storage/src/elasticsearch-state-storage/index.ts +++ b/packages/teraslice-state-storage/src/elasticsearch-state-storage/index.ts @@ -3,7 +3,7 @@ import { chunk, pMap } from '@terascope/utils'; import { ClientParams, ClientResponse } from '@terascope/types'; -import esApi, { Client, BulkRecord } from '@terascope/elasticsearch-api'; +import esApi from '@terascope/elasticsearch-api'; import { ESStateStorageConfig, MGetCacheResponse } from '../interfaces.js'; import CachedStateStorage from '../cached-state-storage/index.js'; @@ -15,11 +15,11 @@ export default class ESCachedStateStorage { private chunkSize: number; private persist: boolean; private metaKey: string; - private es: Client; + private es: esApi.Client; private logger: Logger; public cache: CachedStateStorage; - constructor(client: Client, logger: Logger, config: ESStateStorageConfig) { + constructor(client: esApi.Client, logger: Logger, config: ESStateStorageConfig) { this.index = config.index; this.type = config.type; this.concurrency = config.concurrency; @@ -228,7 +228,7 @@ export default class ESCachedStateStorage { return this.es.mget(request); } - private _esBulkUpdatePrep(dataArray: DataEntity[]): BulkRecord[] { + private _esBulkUpdatePrep(dataArray: DataEntity[]): esApi.BulkRecord[] { return dataArray.map((doc) => ({ action: { index: {