ensure task is not dereferenced

Author: sanderegg

services/web/server/src/simcore_service_webserver/projects/_crud_api_delete.py

@@ -12,6 +12,8 @@
 from aiohttp import web
 from models_library.projects import ProjectID
 from models_library.users import UserID
+from servicelib.aiohttp.application_keys import APP_FIRE_AND_FORGET_TASKS_KEY
+from servicelib.utils import fire_and_forget_task
 
 from ..director_v2 import director_v2_service
 from ..storage.api import delete_data_folders_of_project
@@ -189,21 +191,19 @@ def _log_state_when_done(fut: asyncio.Future):
             )
 
     # ------
-
-    task = asyncio.create_task(
+    task = fire_and_forget_task(
         delete_project(
             app,
             project_uuid,
             user_id,
             simcore_user_agent,
             remove_project_dynamic_services,
         ),
-        name=_DELETE_PROJECT_TASK_NAME.format(project_uuid, user_id),
+        task_suffix_name=_DELETE_PROJECT_TASK_NAME.format(project_uuid, user_id),
+        fire_and_forget_tasks_collection=app[APP_FIRE_AND_FORGET_TASKS_KEY],
     )
 
-    assert task.get_name() == _DELETE_PROJECT_TASK_NAME.format(  # nosec
-        project_uuid, user_id
-    )
+    assert task in get_scheduled_tasks(project_uuid, user_id)  # nosec
 
     task.add_done_callback(_log_state_when_done)
     return task
@@ -214,5 +214,7 @@ def get_scheduled_tasks(project_uuid: ProjectID, user_id: UserID) -> list[asynci
     return [
         task
         for task in asyncio.all_tasks()
-        if task.get_name() == _DELETE_PROJECT_TASK_NAME.format(project_uuid, user_id)
+        if task.get_name().endswith(
+            _DELETE_PROJECT_TASK_NAME.format(project_uuid, user_id)
+        )
     ]