chore: Fix system queries for rollupLambda (cube-js#5322)

Author: paveltiunov

packages/cubejs-client-core/index.d.ts

@@ -151,7 +151,7 @@ declare module '@cubejs-client/core' {
     measureToLeafMeasures?: Record<string, LeafMeasure[]>;
   };
 
-  export type PreAggregationType = 'rollup' | 'rollupJoin' | 'originalSql';
+  export type PreAggregationType = 'rollup' | 'rollupJoin' | 'rollupLambda' | 'originalSql';
 
   type UsedPreAggregation = {
     targetTableName: string;

packages/cubejs-server-core/src/core/RefreshScheduler.ts

@@ -302,9 +302,10 @@ export class RefreshScheduler {
       const { timezones } = queryingOptions;
       const { partitions: partitionsFilter, cacheOnly } = preAggregationsQueryingOptions[preAggregation.id] || {};
 
-      const isRollupJoin = preAggregation?.preAggregation?.type === 'rollupJoin';
+      const type = preAggregation?.preAggregation?.type;
+      const isEphemeralPreAggregation = type === 'rollupJoin' || type === 'rollupLambda';
 
-      const queriesForPreAggregation: RefreshQueries[] = !isRollupJoin && (await Promise.all(
+      const queriesForPreAggregation: RefreshQueries[] = !isEphemeralPreAggregation && (await Promise.all(
         timezones.map(async timezone => this.refreshQueriesForPreAggregation(
           context,
           compilerApi,

packages/cubejs-testing/test/smoke-lambda.test.ts

@@ -1,6 +1,7 @@
 import R from 'ramda';
 import { StartedTestContainer } from 'testcontainers';
 import { pausePromise } from '@cubejs-backend/shared';
+import fetch from 'node-fetch';
 import { PostgresDBRunner } from '@cubejs-backend/testing-shared';
 import cubejs, { CubejsApi, Query } from '@cubejs-client/core';
 // eslint-disable-next-line import/no-extraneous-dependencies
@@ -278,4 +279,15 @@ describe('lambda', () => {
     await runScheduledRefresh(client);
     await checkCubestoreState(cubestore);
   });
+
+  it('Pre-aggregations API', async () => {
+    const preAggs = await fetch(`${birdbox.configuration.playgroundUrl}/cubejs-system/v1/pre-aggregations`, {
+      method: 'GET',
+      headers: {
+        Authorization: ''
+      },
+    });
+    console.log(await preAggs.json());
+    expect(preAggs.status).toBe(200);
+  });
 });