(self, loop, context)
| 110 | self._termlog_addon.uninstall() |
| 111 | |
| 112 | def _asyncio_exception_handler(self, loop, context) -> None: |
| 113 | try: |
| 114 | exc: Exception = context["exception"] |
| 115 | except KeyError: |
| 116 | logger.error(f"Unhandled asyncio error: {context}") |
| 117 | else: |
| 118 | if isinstance(exc, OSError) and exc.errno == 10038: |
| 119 | return # suppress https://bugs.python.org/issue43253 |
| 120 | logger.error( |
| 121 | "Unhandled error in task.", |
| 122 | exc_info=(type(exc), exc, exc.__traceback__), |
| 123 | ) |
| 124 | |
| 125 | async def load_flow(self, f): |
| 126 | """ |