from celery import shared_task
from product.models import ProductVariant

@shared_task
def update_product_prices():
    print("\033[92m Calling update product prices from Celery\033[00m")
    ProductVariant.update_all_prices()
    print("\033[92m its working\033[00m")