Update helper/subscriptions.py

helper/subscriptions.py

@@ -117,17 +117,15 @@ SUPABASE_KEY = os.getenv("SUPABASE_SERVICE_ROLE_KEY")
 supabase: Client = create_client(SUPABASE_URL, SUPABASE_KEY)
 POSTGRE_SECRET = os.getenv("POSTGRE_SECRET")
 
-conn = await psycopg.AsyncConnection.connect(POSTGRE_SECRET, row_factory=dict_row, sslmode="verify-full", sslrootcert="prod-ca-2021.crt")
-
-
 async def get_conn():
     global conn
 
     if conn is None or conn.closed:
-        conn = psycopg.connect(POSTGRE_SECRET, row_factory=dict_row, sslmode="verify-full", sslrootcert="prod-ca-2021.crt")
+       conn = await psycopg.AsyncConnection.connect(POSTGRE_SECRET, row_factory=dict_row, sslmode="verify-full", sslrootcert="prod-ca-2021.crt")
 
     return conn
-
+    
+conn = await get_conn()
 
 import psycopg
 from psycopg.rows import dict_row