fix invalidateKeyQueries not to be in the future

Author: KSDaemon

packages/cubejs-query-orchestrator/src/orchestrator/PreAggregationPartitionRangeLoader.ts

@@ -161,9 +161,9 @@ export class PreAggregationPartitionRangeLoader {
     return [sql.replace(this.preAggregation.tableName, partitionTableName), params?.map(
       param => {
         if (dateRange && param === FROM_PARTITION_RANGE) {
-          return PreAggregationPartitionRangeLoader.inDbTimeZone(this.preAggregation, dateRange[0]);
+          return dateRange[0];
         } else if (dateRange && param === TO_PARTITION_RANGE) {
-          return PreAggregationPartitionRangeLoader.inDbTimeZone(this.preAggregation, dateRange[1]);
+          return dateRange[1];
         } else {
           return param;
         }
@@ -193,8 +193,9 @@ export class PreAggregationPartitionRangeLoader {
     if ((!partitionInvalidateKeyQueries || partitionInvalidateKeyQueries.length > 0) && buildRangeEnd < range[1]) {
       loadRange[1] = buildRangeEnd;
     }
+    // partitionRanges() returns range in UTC.
     const sealAt = addSecondsToLocalTimestamp(
-      loadRange[1], this.preAggregation.timezone, this.preAggregation.updateWindowSeconds || 0
+      loadRange[1], 'UTC', this.preAggregation.updateWindowSeconds || 0
     ).toISOString();
     return {
       ...this.preAggregation,

packages/cubejs-query-orchestrator/test/unit/QueryOrchestrator.test.js

@@ -177,7 +177,7 @@ class MockDriverUnloadWithoutTempTableSupport extends MockDriver {
   capabilities() {
     return { unloadWithoutTempTable: true };
   }
-  
+
   queryColumnTypes() {
     return [];
   }
@@ -1308,7 +1308,7 @@ describe('QueryOrchestrator', () => {
     expect(result.data[0]).toMatch(/orders_d20210501/);
     expect(result.data[0]).not.toMatch(/orders_h2021053000/);
     expect(result.data[0]).toMatch(/orders_h2021053100/);
-    expect(result.data[0]).toMatch(/orders_h2021060100_uozkyaur_d004iq51/);
+    expect(result.data[0]).toMatch(/orders_h2021060100_fv2h1pdp_3wsilqun/);
 
     result = await queryOrchestrator.fetchQuery(query(['2021-05-31T00:00:00.000', '2021-05-31T23:59:59.999']));
     console.log(JSON.stringify(result, null, 2));
@@ -1319,7 +1319,7 @@ describe('QueryOrchestrator', () => {
     expect(result.data[0]).toMatch(/orders_d20210501/);
     expect(result.data[0]).not.toMatch(/orders_h2021053000/);
     expect(result.data[0]).toMatch(/orders_h2021053100/);
-    expect(result.data[0]).toMatch(/orders_h2021060100_uozkyaur_d004iq51/);
+    expect(result.data[0]).toMatch(/orders_h2021060100_fv2h1pdp_3wsilqun/);
   });
 
   test('lambda partitions week', async () => {
@@ -1407,7 +1407,7 @@ describe('QueryOrchestrator', () => {
     console.log(JSON.stringify(result, null, 2));
     expect(result.data[0]).not.toMatch(/orders_h2021053000/);
     expect(result.data[0]).toMatch(/orders_h2021053100/);
-    expect(result.data[0]).toMatch(/orders_h2021060100_uozkyaur_d004iq51/);
+    expect(result.data[0]).toMatch(/orders_h2021060100_fv2h1pdp_3wsilqun/);
   });
 
   test('real-time sealing partitions', async () => {
@@ -1531,7 +1531,7 @@ describe('QueryOrchestrator', () => {
         external: true,
       }],
       renewQuery: true,
-      
+
       requestId: 'basic'
     };
     const promise = queryOrchestrator.fetchQuery(query);