Merge pull request #672 from kprzybyla/one-shot-callback-exception-never-retrieved

Catch and log potential exception during the OneShotCallback task execution

Author: mosquito

aio_pika/tools.py

@@ -304,6 +304,8 @@ async def __task_inner(self, *args: Any, **kwargs: Any) -> None:
 
             try:
                 await self.callback(*args, **kwargs)
+            except Exception:
+                log.exception("Callback %r error", self)
             finally:
                 self.loop.call_soon(self.finished.set)
                 del self.callback