From 5337e37ddbed289b3e4adf33cdc8d872d1de42bf Mon Sep 17 00:00:00 2001 From: Jia Xu Date: Wed, 6 Nov 2024 14:45:06 -0800 Subject: [PATCH] Fix unix_socket connection (#1812) --- jobs/payment-jobs/services/data_warehouse.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/jobs/payment-jobs/services/data_warehouse.py b/jobs/payment-jobs/services/data_warehouse.py index 15de87eff..f9ec0678e 100644 --- a/jobs/payment-jobs/services/data_warehouse.py +++ b/jobs/payment-jobs/services/data_warehouse.py @@ -53,7 +53,7 @@ def getconn(connector: Connector, db_config: DBConfig) -> object: instance_connection_string = db_config.unix_sock.replace("/cloudsql/", "") return connector.connect( instance_connection_string=instance_connection_string, - ip_type="private", + ip_type="public", user=db_config.user, password=db_config.password, db=db_config.database,