diff --git a/lifecycle/migrate.py b/lifecycle/migrate.py
index 6239f8904b..858cfd73b5 100755
--- a/lifecycle/migrate.py
+++ b/lifecycle/migrate.py
@@ -73,6 +73,7 @@ def release_lock(conn: Connection, cursor: Cursor):
 
 
 def run_migrations():
+    conn_opts = CONFIG.get_dict_from_b64_json("postgresql.conn_options", default={})
     conn = connect(
         dbname=CONFIG.get("postgresql.name"),
         user=CONFIG.get("postgresql.user"),
@@ -83,6 +84,7 @@ def run_migrations():
         sslrootcert=CONFIG.get("postgresql.sslrootcert"),
         sslcert=CONFIG.get("postgresql.sslcert"),
         sslkey=CONFIG.get("postgresql.sslkey"),
+        **conn_opts,
     )
     curr = conn.cursor()
     try:
diff --git a/lifecycle/wait_for_db.py b/lifecycle/wait_for_db.py
index e0d8c1860e..09d6aa3c29 100755
--- a/lifecycle/wait_for_db.py
+++ b/lifecycle/wait_for_db.py
@@ -18,6 +18,7 @@ def check_postgres():
         if attempt >= CHECK_THRESHOLD:
             sysexit(1)
         try:
+            conn_opts = CONFIG.get_dict_from_b64_json("postgresql.conn_options", default={})
             conn = connect(
                 dbname=CONFIG.refresh("postgresql.name"),
                 user=CONFIG.refresh("postgresql.user"),
@@ -28,6 +29,7 @@ def check_postgres():
                 sslrootcert=CONFIG.get("postgresql.sslrootcert"),
                 sslcert=CONFIG.get("postgresql.sslcert"),
                 sslkey=CONFIG.get("postgresql.sslkey"),
+                **conn_opts,
             )
             conn.cursor()
             break