From 6b47de2bb945662eee16d8835cd4aae8f139e382 Mon Sep 17 00:00:00 2001 From: Greg Finley Date: Mon, 25 Mar 2024 10:45:58 -0700 Subject: [PATCH] Revert "Migrate to aiven" This reverts commit 55a2ce8f62b3391bcf32ac471f7b47a2d795bf69. --- process_file/main.py | 3 +-- queue_files/main.py | 3 +-- requeue_failed_files/main.py | 3 +-- 3 files changed, 3 insertions(+), 6 deletions(-) diff --git a/process_file/main.py b/process_file/main.py index 8c6623a..fae94b3 100644 --- a/process_file/main.py +++ b/process_file/main.py @@ -18,8 +18,7 @@ mysql_connection = mysql.connector.connect( - host=mysql_config_dict["MYSQL_HOST"], - port=mysql_config_dict["MYSQL_PORT"], + unix_socket=mysql_config_dict["MYSQL_SOCKET"], user=mysql_config_dict["MYSQL_USERNAME"], passwd=mysql_config_dict["MYSQL_PASSWORD"], database=mysql_config_dict["MYSQL_DATABASE"], diff --git a/queue_files/main.py b/queue_files/main.py index 1f1ad76..839a465 100644 --- a/queue_files/main.py +++ b/queue_files/main.py @@ -15,8 +15,7 @@ mysql_config = json.loads(os.environ["MYSQL_CONFIG"]) mysql_connection = mysql.connector.connect( - host=mysql_config["MYSQL_HOST"], - port=mysql_config["MYSQL_PORT"], + unix_socket=mysql_config["MYSQL_SOCKET"], user=mysql_config["MYSQL_USERNAME"], passwd=mysql_config["MYSQL_PASSWORD"], database=mysql_config["MYSQL_DATABASE"], diff --git a/requeue_failed_files/main.py b/requeue_failed_files/main.py index 3bfd2de..5ed3e1c 100644 --- a/requeue_failed_files/main.py +++ b/requeue_failed_files/main.py @@ -14,8 +14,7 @@ mysql_config = json.loads(os.environ["MYSQL_CONFIG"]) mysql_connection = mysql.connector.connect( - host=mysql_config["MYSQL_HOST"], - port=mysql_config["MYSQL_PORT"], + unix_socket=mysql_config["MYSQL_SOCKET"], user=mysql_config["MYSQL_USERNAME"], passwd=mysql_config["MYSQL_PASSWORD"], database=mysql_config["MYSQL_DATABASE"],