diff --git a/.github/workflows/drivers-tests.yml b/.github/workflows/drivers-tests.yml index ec9d3a16d5526..764d90a84d014 100644 --- a/.github/workflows/drivers-tests.yml +++ b/.github/workflows/drivers-tests.yml @@ -343,6 +343,6 @@ jobs: timeout_minutes: 20 command: | cd ./packages/cubejs-testing-drivers - export DEBUG=testcontainers + export DEBUG=testcontainers* yarn ${{ matrix.database }}-full diff --git a/packages/cubejs-athena-driver/src/AthenaDriver.ts b/packages/cubejs-athena-driver/src/AthenaDriver.ts index aaea16c04a275..818694be315f9 100644 --- a/packages/cubejs-athena-driver/src/AthenaDriver.ts +++ b/packages/cubejs-athena-driver/src/AthenaDriver.ts @@ -480,6 +480,7 @@ export class AthenaDriver extends BaseDriver implements DriverInterface { ...(this.config.catalog != null ? { QueryExecutionContext: { Catalog: this.config.catalog } } : {}) }; const { QueryExecutionId } = await this.athena.startQueryExecution(request); + console.log('athena started query ', query, QueryExecutionId); return { QueryExecutionId: checkNonNullable('StartQueryExecution', QueryExecutionId) }; } diff --git a/packages/cubejs-testing-drivers/src/helpers/buildPreaggs.ts b/packages/cubejs-testing-drivers/src/helpers/buildPreaggs.ts index 4570e8bbc949a..f752bcaa3e576 100644 --- a/packages/cubejs-testing-drivers/src/helpers/buildPreaggs.ts +++ b/packages/cubejs-testing-drivers/src/helpers/buildPreaggs.ts @@ -135,7 +135,7 @@ export async function hookPreaggs( }, tokens, ); - + selectors.forEach((info) => { const { status } = info; if (status.indexOf('failure') >= 0) { diff --git a/packages/cubejs-testing-drivers/src/tests/testIncrementalSchemaLoading.ts b/packages/cubejs-testing-drivers/src/tests/testIncrementalSchemaLoading.ts index 8cfcfe3e0916c..a29d71d6a8ed5 100644 --- a/packages/cubejs-testing-drivers/src/tests/testIncrementalSchemaLoading.ts +++ b/packages/cubejs-testing-drivers/src/tests/testIncrementalSchemaLoading.ts @@ -26,7 +26,11 @@ export function incrementalSchemaLoadingSuite( }); execute('should load schemas', async () => { + const start = performance.now(); + console.log('should load schemas', 'start'); const inputSchemas: QuerySchemasResult[] = await driver().getSchemas(); + console.log('should load schemas', 'after getSchemas', performance.now() - start); + console.log('should load schemas', 'inputSchemas', inputSchemas); expect(inputSchemas).toBeInstanceOf(Array); expect(inputSchemas.length).toBeGreaterThan(0); expect(inputSchemas).toContainEqual({ @@ -35,9 +39,14 @@ export function incrementalSchemaLoadingSuite( }); execute('should load tables for specific schemas', async () => { + const start = performance.now(); + console.log('should load tables for specific schemas', 'start'); let inputSchemas: QuerySchemasResult[] = await driver().getSchemas(); + console.log('should load schemas', 'after getSchemas', performance.now() - start); inputSchemas = inputSchemas.filter((s) => !!s.schema_name); const inputTables = await driver().getTablesForSpecificSchemas(inputSchemas); + console.log('should load schemas', 'after getTablesForSpecificSchemas', performance.now() - start); + console.log('should load schemas', 'inputTables', inputTables); expect(inputTables).toBeInstanceOf(Array); expect(inputTables.length).toBeGreaterThan(0); expect(inputTables).toContainEqual({