diff --git a/packages/cubejs-query-orchestrator/src/orchestrator/BaseQueueDriver.ts b/packages/cubejs-query-orchestrator/src/orchestrator/BaseQueueDriver.ts index a6fd830dfc330..1c931b044b3cd 100644 --- a/packages/cubejs-query-orchestrator/src/orchestrator/BaseQueueDriver.ts +++ b/packages/cubejs-query-orchestrator/src/orchestrator/BaseQueueDriver.ts @@ -12,8 +12,8 @@ export abstract class BaseQueueDriver implements QueueDriverInterface { public counter = 0; - public generateQueueId() { - return `${this.processUid}-${this.counter++}`; + public generateQueueId(): number { + return this.counter++; } public redisHash(queryKey: QueryKey): QueryKeyHash {