"""Celery task: еженедельная синхронизация OSM POI для site-finder."""

import logging

from app.workers.celery_app import celery_app

logger = logging.getLogger(__name__)


@celery_app.task(name="tasks.poi_sync.sync_osm_poi_ekb", queue="celery")
def sync_osm_poi_ekb() -> dict:
    """Еженедельная синхронизация OSM POI из Overpass API в osm_poi_ekb.

    Запускается через beat (понедельник 03:00 МСК).
    """
    from app.services.site_finder.poi_loader import sync_poi_to_db

    result = sync_poi_to_db()
    logger.info("POI sync done: %s", result)
    return result