move forget

giancarloromeo · giancarloromeo · commit b0fa11bd4a10 · 2025-04-24T11:55:59.000+02:00
diff --git a/services/storage/src/simcore_service_storage/modules/celery/_task.py b/services/storage/src/simcore_service_storage/modules/celery/_task.py
@@ -67,6 +67,7 @@ async def abort_monitor():
                                         main_task,
                                         max_delay=_DEFAULT_CANCEL_TASK_TIMEOUT.total_seconds(),
                                     )
+                                    AbortableAsyncResult(task_id, app=app).forget()
                                     raise TaskAbortedError
                                 await asyncio.sleep(
                                     _DEFAULT_ABORT_TASK_TIMEOUT.total_seconds()
diff --git a/services/storage/src/simcore_service_storage/modules/celery/client.py b/services/storage/src/simcore_service_storage/modules/celery/client.py
@@ -89,7 +89,6 @@ async def delete_task(self, task_context: TaskContext, task_uuid: TaskUUID) -> N
         ):
             task_id = build_task_id(task_context, task_uuid)
             await self._task_info_store.remove_task(task_id)
-            await self._forget_task(task_id)
 
     @make_async()
     def _forget_task(self, task_id: TaskID) -> None:

Original file line number	Diff line number	Diff line change
`@@ -67,6 +67,7 @@ async def abort_monitor():`
`67`	`67`	`main_task,`
`68`	`68`	`max_delay=_DEFAULT_CANCEL_TASK_TIMEOUT.total_seconds(),`
`69`	`69`	`)`
	`70`	`+ AbortableAsyncResult(task_id, app=app).forget()`
`70`	`71`	`raise TaskAbortedError`
`71`	`72`	`await asyncio.sleep(`
`72`	`73`	`_DEFAULT_ABORT_TASK_TIMEOUT.total_seconds()`