From 261f4ea04034edf6fe7c6c8d69ea73cbf3b3c00a Mon Sep 17 00:00:00 2001 From: brandantck Date: Wed, 19 Aug 2026 17:13:07 +0800 Subject: [PATCH 1/3] add D2E_BIGQUERY_JDBC_URL env to docker compose --- docker-compose.yml | 1 + 1 file changed, 1 insertion(+) diff --git a/docker-compose.yml b/docker-compose.yml index 40ab89f912..990cb013e2 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -933,6 +933,7 @@ services: TASK_API_ENFORCE_HTTPS: ${TASK_API_ENFORCE_HTTPS:-true} LOW_NUMBER_SUPPRESSION_THRESHOLD: ${LOW_NUMBER_SUPPRESSION_THRESHOLD:-10} ROUNDING_TARGET: ${ROUNDING_TARGET:-10} + D2E_BIGQUERY_JDBC_URL: ${D2E_BIGQUERY_JDBC_URL:-} # Needed only for future alterations of schema when version upgrades # alp-logto-db-post-alterations-init: From 5f61d8e1e75a71d0fba2661c4059e3c94a7f1362 Mon Sep 17 00:00:00 2001 From: brandantck Date: Wed, 19 Aug 2026 17:19:49 +0800 Subject: [PATCH 2/3] enable session for bigquery jdbc connection --- plugins/flows/_shared_flow_utils/dao/daobase.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/plugins/flows/_shared_flow_utils/dao/daobase.py b/plugins/flows/_shared_flow_utils/dao/daobase.py index 185106ed46..31071302b3 100644 --- a/plugins/flows/_shared_flow_utils/dao/daobase.py +++ b/plugins/flows/_shared_flow_utils/dao/daobase.py @@ -33,7 +33,8 @@ def build_bigquery_r_connection_string( "jdbc:bigquery://https://www.googleapis.com/bigquery/v2:443;" f"ProjectId={project};OAuthType=0;" f"OAuthServiceAcctEmail={client_email};" - f"OAuthPvtKeyPath={key_path}" + f"OAuthPvtKeyPath={key_path};" + "EnableSession=1" ) return ( "connectionDetails <- DatabaseConnector::createConnectionDetails(" From fc6b9df0531e760fc47ef9b596d58c63b77bc388 Mon Sep 17 00:00:00 2001 From: brandantck Date: Wed, 19 Aug 2026 17:40:25 +0800 Subject: [PATCH 3/3] update test --- .../flows/_shared_flow_utils/tests/test_r_connection_string.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/plugins/flows/_shared_flow_utils/tests/test_r_connection_string.py b/plugins/flows/_shared_flow_utils/tests/test_r_connection_string.py index f54f68c1b0..fe2a5d8b3e 100644 --- a/plugins/flows/_shared_flow_utils/tests/test_r_connection_string.py +++ b/plugins/flows/_shared_flow_utils/tests/test_r_connection_string.py @@ -13,6 +13,7 @@ def test_bigquery_r_connection_string_shape(): "connectionString = 'jdbc:bigquery://https://www.googleapis.com/bigquery/v2:443;" "ProjectId=my-gcp-project;OAuthType=0;" "OAuthServiceAcctEmail=svc@my-gcp-project.iam.gserviceaccount.com;" - "OAuthPvtKeyPath=/tmp/google-sa.json'" in result + "OAuthPvtKeyPath=/tmp/google-sa.json;" + "EnableSession=1'" in result ) assert "user = ''" in result and "password = ''" in result