schon/vibes_auth/tasks.py
2025-10-06 15:58:30 +03:00

24 lines
816 B
Python

from celery import shared_task
from core.models import Order, Wishlist
from vibes_auth.models import User
@shared_task(queue="default")
def create_pending_order(user_uuid: str) -> tuple[bool, str]:
try:
user = User.objects.get(uuid=user_uuid)
Order.objects.create(user=user, status="PENDING")
return True, f"Successfully created order for {user_uuid}"
except User.DoesNotExist:
return False, f"Bad uuid was given: {user_uuid}"
@shared_task(queue="default")
def create_wishlist(user_uuid: str) -> tuple[bool, str]:
try:
user = User.objects.get(uuid=user_uuid)
Wishlist.objects.create(user=user)
return True, f"Successfully created wishlist for {user_uuid}"
except User.DoesNotExist:
return False, f"Bad uuid was given: {user_uuid}"