lukas
/
timetracker
1
0
Fork 0
Code Issues 17 Pull Requests 4 Actions Packages Projects 1 Releases 20 Wiki Activity

Schedule tasks hourly

This commit is contained in:
Lukáš Kucharczyk 2024-11-10 23:39:03 +01:00
parent 527cf4ba52
commit a32996ccc3
Signed by: lukas
SSH Key Fingerprint: SHA256:vMuSwvwAvcT6htVAioMP7rzzwMQNi3roESyhv+nAxeg
2 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
games/apps.py
View File

@ -2,8 +2,6 @@ from datetime import timedelta
from django.apps import AppConfig from django.apps import AppConfig
from django.utils.timezone import now from django.utils.timezone import now
from django_q.models import Schedule
from django_q.tasks import schedule
class GamesConfig(AppConfig): class GamesConfig(AppConfig):
@ -11,10 +9,13 @@ class GamesConfig(AppConfig):
name = "games" name = "games"
def ready(self): def ready(self):
from django_q.models import Schedule
from django_q.tasks import schedule
if not Schedule.objects.filter(name="Update converted prices").exists(): if not Schedule.objects.filter(name="Update converted prices").exists():
schedule( schedule(
"games.tasks.update_converted_prices", "games.convert_price.update_converted_prices",
name="Update converted prices", name="Update converted prices",
schedule_type="D", schedule_type=Schedule.HOURLY,
next_run=now() + timedelta(days=1), next_run=now() + timedelta(seconds=30),
) )

6
games/management/commands/schedule_update_task.py
View File

@ -12,10 +12,10 @@ 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.tasks.update_converted_prices", "games.convert_price.update_converted_prices",
name="Update converted prices", name="Update converted prices",
schedule_type="D", schedule_type=Schedule.HOURLY,
next_run=now() + timedelta(days=1), next_run=now() + timedelta(seconds=30),
) )
self.stdout.write( self.stdout.write(
self.style.SUCCESS("Scheduled the update_converted_prices task.") self.style.SUCCESS("Scheduled the update_converted_prices task.")