feat(tableau): add support for Google BigQuery connection type in pla…

[brock-acryl]

added googlebigquery -> bigquery mapping for sql parsing with tableau custom queries.

[codecov]

❌ 4 Tests Failed:

Tests completed	Failed	Passed	Skipped
3220	4	3216	45

View the full list of 3 ❄️ flaky tests

tests.lineage.test_lineage_sdk::test_filtered_column_level_lineage

Flake rate in main: 8.33% (Passed 44 times, Failed 4 times)

Stack Traces | 0.013s run time

test_client = <datahub.sdk.main_client.DataHubClient object at 0x7f3a8ebfb490>
test_datasets = {'downstream1': Dataset('urn:li:dataset:(urn:li:dataPlatform:snowflake,test_lineage_downstream_001,PROD)'), 'downstrea...ream_003,PROD)'), 'upstream': Dataset('urn:li:dataset:(urn:li:dataPlatform:snowflake,test_lineage_upstream_001,PROD)')}

    def test_filtered_column_level_lineage(
        test_client: DataHubClient, test_datasets: Dict[str, Dataset]
    ):
        filtered_column_lineage_results = test_client.lineage.get_lineage(
            source_urn=str(test_datasets["upstream"].urn),
            source_column="id",
            direction="downstream",
            max_hops=3,
            filter=F.and_(F.platform("mysql"), F.entity_type("dataset")),
        )
    
>       assert len(filtered_column_lineage_results) == 1
E       assert 0 == 1
E        +  where 0 = len([])

tests/lineage/test_lineage_sdk.py:185: AssertionError

tests.lineage.test_lineage_sdk::test_column_level_lineage_from_schema_field

Flake rate in main: 8.33% (Passed 44 times, Failed 4 times)

Stack Traces | 0.014s run time

test_client = <datahub.sdk.main_client.DataHubClient object at 0x7f3a8ebfb490>
test_datasets = {'downstream1': Dataset('urn:li:dataset:(urn:li:dataPlatform:snowflake,test_lineage_downstream_001,PROD)'), 'downstrea...ream_003,PROD)'), 'upstream': Dataset('urn:li:dataset:(urn:li:dataPlatform:snowflake,test_lineage_upstream_001,PROD)')}

    def test_column_level_lineage_from_schema_field(
        test_client: DataHubClient, test_datasets: Dict[str, Dataset]
    ):
        source_schema_field = SchemaFieldUrn(test_datasets["upstream"].urn, "id")
        column_lineage_results = test_client.lineage.get_lineage(
            source_urn=str(source_schema_field), direction="downstream", max_hops=3
        )
    
>       assert len(column_lineage_results) == 3
E       assert 0 == 3
E        +  where 0 = len([])

tests/lineage/test_lineage_sdk.py:203: AssertionError

tests.lineage.test_lineage_sdk::test_table_level_lineage

Flake rate in main: 8.33% (Passed 44 times, Failed 4 times)

Stack Traces | 0.161s run time

test_client = <datahub.sdk.main_client.DataHubClient object at 0x7f3a8ebfb490>
test_datasets = {'downstream1': Dataset('urn:li:dataset:(urn:li:dataPlatform:snowflake,test_lineage_downstream_001,PROD)'), 'downstrea...ream_003,PROD)'), 'upstream': Dataset('urn:li:dataset:(urn:li:dataPlatform:snowflake,test_lineage_upstream_001,PROD)')}

    def test_table_level_lineage(
        test_client: DataHubClient, test_datasets: Dict[str, Dataset]
    ):
        table_lineage_results = test_client.lineage.get_lineage(
            source_urn=str(test_datasets["upstream"].urn),
            direction="downstream",
            max_hops=3,
        )
    
>       assert len(table_lineage_results) == 3
E       assert 0 == 3
E        +  where 0 = len([])

tests/lineage/test_lineage_sdk.py:109: AssertionError

To view more test analytics, go to the Test Analytics Dashboard
_{📋 Got 3 mins? Take this short survey to help us improve Test Analytics.}

[ligfx]

This is also going to match connection_types like:

• google
• glebigqu
  etc.

Should be

elif connection_type in ("googlebigquery",):

or

elif connection_type == "googlebigquery":

(And yes the other two above it are similarly broken.)