tasks.py 205 B

1234567891011
  1. import uuid
  2. from celery import shared_task
  3. from .data_models import EventIngestSchema
  4. @shared_task
  5. def ingest_event(project_id: int, data: dict):
  6. event = EventIngestSchema(**data)
  7. print(event)