Revert "Migrate to aiven"

This reverts commit 55a2ce8.
greg-finley · Mar 25, 2024 · 6b47de2 · 6b47de2
1 parent 74ec329
commit 6b47de2
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 6 deletions.
diff --git 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
@@ -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
@@ -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"],