@@ -2,7 +2,7 @@ import crypto from 'crypto';
22import csvWriter from 'csv-write-stream' ;
33import { LRUCache } from 'lru-cache' ;
44import { pipeline } from 'stream' ;
5- import { asyncDebounce , getEnv , MaybeCancelablePromise , streamToArray } from '@cubejs-backend/shared' ;
5+ import { AsyncDebounce , getEnv , MaybeCancelablePromise , streamToArray } from '@cubejs-backend/shared' ;
66import { CubeStoreCacheDriver , CubeStoreDriver } from '@cubejs-backend/cubestore-driver' ;
77import {
88 BaseDriver ,
@@ -811,7 +811,8 @@ export class QueryCache {
811811 return cacheKeyQueries . map ( ( q ) => this . loadRefreshKey ( q , expireSecs , options ) ) ;
812812 }
813813
814- public loadRefreshKey = asyncDebounce ( async ( q : QueryWithParams , expireSecs : number , options : LoadRefreshKeyOptions ) => {
814+ @AsyncDebounce ( )
815+ public async loadRefreshKey ( q : QueryWithParams , expireSecs : number , options : LoadRefreshKeyOptions ) {
815816 const [ query , values , queryOptions ] : QueryWithParams = Array . isArray ( q ) ? q : [ q , [ ] , { } ] ;
816817
817818 return this . cacheQueryResult (
@@ -829,7 +830,7 @@ export class QueryCache {
829830 external : queryOptions ?. external ,
830831 } ,
831832 ) ;
832- } ) ;
833+ }
833834
834835 public withLock = < T = any > (
835836 key : string ,
0 commit comments