Фоновая задача по расписанию

Решение

import asyncio
import logging
from contextlib import asynccontextmanager

logger = logging.getLogger(__name__)


async def refresh_loop(interval, refresh):
    while True:
        try:
            await refresh()
        except asyncio.CancelledError:
            logger.info("фоновое обновление остановлено")
            raise
        except Exception:
            # одна неудача не должна убивать цикл навсегда
            logger.exception("не удалось обновить кэш")

        await asyncio.sleep(interval)


@asynccontextmanager
async def lifespan(app):
    task = asyncio.create_task(refresh_loop(30, refresh_rates))
    try:
        yield
    finally:
        task.cancel()
        await asyncio.gather(task, return_exceptions=True)

Почему так

Почему except Exception внутри цикла

• Исключение, вылетевшее из корутины задачи, завершает её — обновление просто перестанет происходить
• Заметить это тяжело: приложение работает, кэш тихо устаревает, и никто не получает ошибку
• Ловим и логируем внутри итерации, чтобы цикл дожил до следующего раза

Почему ссылку на задачу нужно хранить

• create_task не удерживает задачу: цикл событий хранит только слабую ссылку, и сборщик мусора может забрать её на середине
• Поэтому task кладут в переменную или в множество на всё время жизни — это известная ловушка из документации
• Хранение ссылки заодно даёт возможность отменить задачу при остановке

Почему отмена и gather при завершении

• Без cancel задача останется висеть, а интерпретатор при выходе напечатает «Task was destroyed but it is pending»
• gather после cancel даёт задаче завершиться: отработают finally и закроются соединения
• return_exceptions=True нужен, чтобы ожидаемый CancelledError не всплыл при штатной остановке