Update helper/subscriptions.py

helper/subscriptions.py

@@ -151,7 +151,7 @@ async def execute_query(query: str, params=(), *, fetchone=False, commit=False):
             return result
 
         except psycopg.OperationalError:
-            # reconnect
+            # reconnect using ASYNC connection
             conn = await psycopg.AsyncConnection.connect(
                 POSTGRE_SECRET,
                 row_factory=dict_row,
@@ -177,7 +177,6 @@ async def execute_query(query: str, params=(), *, fetchone=False, commit=False):
             await conn.rollback()
             raise e
 
-
 def normalize_plan_key(plan_name: str | None) -> str:
     if not plan_name:
         return "free"