Execute function Mirrors ``DictCursor.execute`` so this cursor stays substitutable for ``psycopg.AsyncCursor`` when used via ``AsyncConnection.execute``.
(self, query, params=None, *, prepare=None, binary=None)
| 280 | return self._odt_desc |
| 281 | |
| 282 | def execute(self, query, params=None, *, prepare=None, binary=None): |
| 283 | """ |
| 284 | Execute function |
| 285 | |
| 286 | Mirrors ``DictCursor.execute`` so this cursor stays substitutable |
| 287 | for ``psycopg.AsyncCursor`` when used via ``AsyncConnection.execute``. |
| 288 | """ |
| 289 | try: |
| 290 | return asyncio.run( |
| 291 | self._execute(query, params, prepare=prepare, binary=binary) |
| 292 | ) |
| 293 | except RuntimeError as e: |
| 294 | current_app.logger.exception(e) |
| 295 | |
| 296 | async def _execute(self, query, params=None, *, |
| 297 | prepare=None, binary=None): |