mirror of
https://github.com/dat515-2025/Group-8.git
synced 2026-03-22 06:57:47 +01:00
20 lines
622 B
Python
20 lines
622 B
Python
import logging
|
|
|
|
from celery import shared_task
|
|
|
|
logger = logging.getLogger("celery_tasks")
|
|
if not logger.handlers:
|
|
_h = logging.StreamHandler()
|
|
logger.addHandler(_h)
|
|
logger.setLevel(logging.INFO)
|
|
|
|
|
|
@shared_task(name="workers.send_email")
|
|
def send_email(to: str, subject: str, body: str) -> None:
|
|
if not (to and subject and body):
|
|
logger.error("Email task missing fields. to=%r subject=%r body_len=%r", to, subject, len(body) if body else 0)
|
|
return
|
|
|
|
# Placeholder for real email sending logic
|
|
logger.info("[Celery] Email sent | to=%s | subject=%s | body_len=%d", to, subject, len(body))
|