fix: Lambda pre-aggregations aren't served by external refresh instance

Author: paveltiunov

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

@@ -458,7 +458,7 @@ type LoadPreAggregationResult = {
   targetTableName: string;
   refreshKeyValues: any[];
   lastUpdatedAt: number;
-  buildRangeEnd?: string;
+  buildRangeEnd: string;
   lambdaTable?: InlineTable;
   queryKey?: any[];
   rollupLambdaId?: string;
@@ -586,8 +586,9 @@ export class PreAggregationLoader {
           // immediately return the latest rollup data that instance already has
           return {
             targetTableName: this.targetTableName(versionEntryByStructureVersion),
-            lastUpdatedAt: versionEntryByStructureVersion.last_updated_at,
             refreshKeyValues: [],
+            lastUpdatedAt: versionEntryByStructureVersion.last_updated_at,
+            buildRangeEnd: versionEntryByStructureVersion.build_range_end,
           };
         }
       }
@@ -726,6 +727,7 @@ export class PreAggregationLoader {
           targetTableName,
           refreshKeyValues: [],
           lastUpdatedAt: newVersionEntry.last_updated_at,
+          buildRangeEnd: this.preAggregation.buildRangeEnd,
         };
       } else {
         await this.executeInQueue(invalidationKeys, this.priority(10), newVersionEntry);

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

@@ -1228,6 +1228,13 @@ describe('QueryOrchestrator', () => {
     result = await queryOrchestrator.fetchQuery(query(['2021-05-31T00:00:00.000', '2021-05-31T23:59:59.999']));
     console.log(JSON.stringify(result, null, 2));
     expect(result.data[0]).toMatch(/orders_h2021053100/);
+
+    result = await queryOrchestratorExternalRefresh.fetchQuery(query());
+    console.log(JSON.stringify(result, null, 2));
+    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/);
   });
 
   test('loadRefreshKeys', async () => {