return on exception

libqmpbackup/qmpcommon.py

@@ -12,7 +12,7 @@
 import logging
 from time import sleep
 import asyncio
-from qemu.qmp import EventListener
+from qemu.qmp import EventListener, qmp_client
 from libqmpbackup import fs
 
 
@@ -268,7 +268,10 @@ async def progress(self):
         """Report progress for active block job"""
         while True:
             sleep(1)
-            jobs = await self.qmp.execute("query-block-jobs")
+            try:
+                jobs = await self.qmp.execute("query-block-jobs")
+            except qmp_client.ExecInterruptedError:
+                return
             if len(jobs) == 0:
                 return
             for job in jobs:

qmpbackup

@@ -464,6 +464,7 @@ async def main():
 
         for task in asyncio.all_tasks():
             if task.get_name() == "progress" and task.done() is not True:
+                log.debug("Cancelling progress job")
                 task.cancel()
         await qmp.disconnect()