update

py/core/providers/database/base.py

@@ -167,14 +167,14 @@ class PostgresConnectionManager(DatabaseConnectionManager):
             if isolation_level:
                 async with conn.transaction(isolation=isolation_level):
                     if params:
-                        return await conn.execute(query, *params)
+                        return await conn.execute(query, *params, timeout=60)
                     else:
-                        return await conn.execute(query)
+                        return await conn.execute(query, timeout=60)
             else:
                 if params:
-                    return await conn.execute(query, *params)
+                    return await conn.execute(query, *params, timeout=60)
                 else:
-                    return await conn.execute(query)
+                    return await conn.execute(query, timeout=60)
 
     async def execute_many(self, query, params=None, batch_size=1000):
         if not self.pool: