import logging from app.celery_app import celery_app logger = logging.getLogger(__name__) @celery_app.task(name="notifications.send_push") def send_push_notification_task(user_id: int, title: str, body: str, data: dict) -> None: logger.info("PUSH user=%s title=%s body=%s data=%s", user_id, title, body, data) @celery_app.task(name="notifications.send_mention") def send_mention_notification_task(user_id: int, title: str, body: str, data: dict) -> None: logger.info("MENTION user=%s title=%s body=%s data=%s", user_id, title, body, data)