chore: up code quality

Author: ovr

packages/cubejs-query-orchestrator/test/unit/QueryQueue.abstract.ts

@@ -56,6 +56,8 @@ export const QueryQueueTest = (name: string, options: QueryQueueTestOptions = {}
       }
 
       logger.mockClear();
+      delayCount = 0;
+      streamCount = 0;
     });
 
     afterAll(async () => {
@@ -89,7 +91,6 @@ export const QueryQueueTest = (name: string, options: QueryQueueTestOptions = {}
     });
 
     test('priority', async () => {
-      delayCount = 0;
       const result = await Promise.all([
         queue.executeInQueue('delay', '11', { delay: 600, result: '1' }, 1),
         queue.executeInQueue('delay', '12', { delay: 100, result: '2' }, 0),
@@ -99,7 +100,6 @@ export const QueryQueueTest = (name: string, options: QueryQueueTestOptions = {}
     });
 
     test('timeout', async () => {
-      delayCount = 0;
       const query = ['select * from 2'];
       let errorString = '';
 
@@ -120,7 +120,6 @@ export const QueryQueueTest = (name: string, options: QueryQueueTestOptions = {}
     });
 
     test('stage reporting', async () => {
-      delayCount = 0;
       const resultPromise = queue.executeInQueue('delay', '1', { delay: 200, result: '1' }, 0, { stageQueryKey: '1' });
       await delayFn(null, 50);
       expect((await queue.getQueryStage('1')).stage).toBe('Executing query');
@@ -129,7 +128,6 @@ export const QueryQueueTest = (name: string, options: QueryQueueTestOptions = {}
     });
 
     test('priority stage reporting', async () => {
-      delayCount = 0;
       const resultPromise1 = queue.executeInQueue('delay', '31', { delay: 200, result: '1' }, 20, { stageQueryKey: '12' });
       await delayFn(null, 50);
       const resultPromise2 = queue.executeInQueue('delay', '32', { delay: 200, result: '1' }, 10, { stageQueryKey: '12' });
@@ -142,7 +140,6 @@ export const QueryQueueTest = (name: string, options: QueryQueueTestOptions = {}
     });
 
     test('negative priority', async () => {
-      delayCount = 0;
       const results = [];
 
       queue.executeInQueue('delay', '31', { delay: 400, result: '4' }, -10);
@@ -166,7 +163,6 @@ export const QueryQueueTest = (name: string, options: QueryQueueTestOptions = {}
         await queue.executeInQueue('delay', `11${i}`, { delay: 50, result: `${i}` }, 0);
       }
       cancelledQuery = null;
-      delayCount = 0;
 
       let result = queue.executeInQueue('delay', '111', { delay: 800, result: '1' }, 0);
       delayFn(null, 50).then(() => queue.executeInQueue('delay', '112', { delay: 800, result: '2' }, 0)).catch(e => e);