Implement converting prices #79
|
@ -20,7 +20,7 @@ def schedule_tasks(sender, **kwargs):
|
||||||
|
|
||||||
if not Schedule.objects.filter(name="Update converted prices").exists():
|
if not Schedule.objects.filter(name="Update converted prices").exists():
|
||||||
schedule(
|
schedule(
|
||||||
"games.convert_price.update_converted_prices",
|
"games.tasks.convert_prices",
|
||||||
name="Update converted prices",
|
name="Update converted prices",
|
||||||
schedule_type=Schedule.MINUTES,
|
schedule_type=Schedule.MINUTES,
|
||||||
next_run=now() + timedelta(seconds=30),
|
next_run=now() + timedelta(seconds=30),
|
||||||
|
|
|
@ -12,7 +12,7 @@ class Command(BaseCommand):
|
||||||
def handle(self, *args, **kwargs):
|
def handle(self, *args, **kwargs):
|
||||||
if not Schedule.objects.filter(name="Update converted prices").exists():
|
if not Schedule.objects.filter(name="Update converted prices").exists():
|
||||||
schedule(
|
schedule(
|
||||||
"games.convert_price.update_converted_prices",
|
"games.tasks.convert_prices",
|
||||||
name="Update converted prices",
|
name="Update converted prices",
|
||||||
schedule_type=Schedule.MINUTES,
|
schedule_type=Schedule.MINUTES,
|
||||||
next_run=now() + timedelta(seconds=30),
|
next_run=now() + timedelta(seconds=30),
|
|
@ -16,7 +16,7 @@ def save_converted_info(purchase, converted_price, converted_currency):
|
||||||
purchase.save()
|
purchase.save()
|
||||||
|
|
||||||
|
|
||||||
def update_converted_prices():
|
def convert_prices():
|
||||||
purchases = Purchase.objects.filter(
|
purchases = Purchase.objects.filter(
|
||||||
converted_price__isnull=True, converted_currency__isnull=True
|
converted_price__isnull=True, converted_currency__isnull=True
|
||||||
)
|
)
|
Loading…
Reference in New Issue