Skip to content

Commit f6860be

Browse files
fix exc
1 parent 004ae64 commit f6860be

File tree

2 files changed

+3
-1
lines changed
  • packages/service-library/src/servicelib
  • services/storage/src/simcore_service_storage/modules/celery

2 files changed

+3
-1
lines changed

packages/service-library/src/servicelib/progress_bar.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,8 @@ async def __aenter__(self) -> "ProgressBarData":
109109
return self
110110

111111
async def __aexit__(self, exc_type, exc_value, traceback) -> None:
112-
await self.finish()
112+
if exc_type is not None:
113+
await self.finish()
113114

114115
async def _update_parent(self, value: float) -> None:
115116
if self._parent:

services/storage/src/simcore_service_storage/modules/celery/_task.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ async def run_task(task_id: TaskID) -> R:
6060
if AbortableAsyncResult(task_id).is_aborted():
6161
_logger.warning("Task %s was aborted by user.", task_id)
6262
await cancel_wait_task(task_coro, max_delay=5) # to constant
63+
raise asyncio.CancelledError
6364
if task_coro.done():
6465
break
6566

0 commit comments

Comments
 (0)