We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 36ab8b2 commit 2d419ffCopy full SHA for 2d419ff
src/cloudai/_core/runner.py
@@ -85,6 +85,10 @@ async def run(self):
85
try:
86
await self.runner.run()
87
logging.debug("All jobs finished successfully.")
88
+ except asyncio.CancelledError:
89
+ logging.info("Runner cancelled, performing cleanup...")
90
+ await self.runner.shutdown()
91
+ return
92
except JobFailureError as exc:
93
logging.debug(f"Runner failed JobFailure exception: {exc}", exc_info=True)
94
0 commit comments