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"],