refactor: удержать фоновые asyncio task до завершения

- сохранить ссылки на задачи инвалидации кэша в реестре
- автоматически удалять завершённые task из набора
- добавить тест на жизненный цикл фоновой задачи

Author: RomanVetrov

app/routes/tasks.py

@@ -36,13 +36,20 @@
 RedisClient = Annotated[Redis, Depends(get_redis)]
 TaskFilters = Annotated[TaskListFilters, Depends()]
 logger = getLogger(__name__)
+_BACKGROUND_CACHE_INVALIDATION_TASKS: set[asyncio.Task[None]] = set()
 
 _DUE_DATE_ERROR = HTTPException(
     status_code=status.HTTP_400_BAD_REQUEST,
     detail="Дедлайн не может быть в прошлом",
 )
 
 
+def _track_background_task(task: asyncio.Task[None]) -> None:
+    """Сохраняет strong reference на фоновую задачу до её завершения."""
+    _BACKGROUND_CACHE_INVALIDATION_TASKS.add(task)
+    task.add_done_callback(_BACKGROUND_CACHE_INVALIDATION_TASKS.discard)
+
+
 def _schedule_invalidate_user_tasks_cache(redis: Redis, user_id: UUID) -> None:
     """Запускает инвалидацию кэша списка задач в фоне (fire-and-forget).
     Исключения в фоновой задаче логируются и не пробрасываются в вызывающий код.
@@ -58,7 +65,7 @@ async def _run() -> None:
                 exc_info=True,
             )
 
-    asyncio.create_task(_run())
+    _track_background_task(asyncio.create_task(_run()))
 
 
 @router.post(

tests/unit/routes/test_tasks_fire_forget.py

@@ -8,7 +8,10 @@
 
 import pytest
 
-from app.routes.tasks import _schedule_invalidate_user_tasks_cache
+from app.routes.tasks import (
+    _BACKGROUND_CACHE_INVALIDATION_TASKS,
+    _schedule_invalidate_user_tasks_cache,
+)
 
 pytestmark = pytest.mark.asyncio
 
@@ -28,3 +31,22 @@ async def test_schedule_invalidate_runs_in_background_and_does_not_propagate_exc
         await asyncio.sleep(0.05)
 
     assert "Не удалось инвалидировать кэш задач пользователя" in caplog.text
+
+
+async def test_schedule_invalidate_keeps_task_reference_until_completion() -> None:
+    """Фоновая задача хранится в реестре до завершения и затем автоматически удаляется."""
+    redis = AsyncMock()
+    user_id = uuid4()
+
+    with patch(
+        "app.routes.tasks.delete_cached_tasks_list_for_user",
+        new_callable=AsyncMock,
+    ) as delete_cached_tasks:
+        _schedule_invalidate_user_tasks_cache(redis, user_id)
+
+        assert len(_BACKGROUND_CACHE_INVALIDATION_TASKS) == 1
+
+        await asyncio.sleep(0.05)
+
+    delete_cached_tasks.assert_awaited_once_with(redis, user_id)
+    assert not _BACKGROUND_CACHE_INVALIDATION_TASKS