Mirrors/Dispatcharr
1
0
Fork 1
mirror of https://github.com/Dispatcharr/Dispatcharr.git synced 2026-07-24 18:48:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

attempting to fix issue with periodic tasks already existing

Browse source
This commit is contained in:
dekzter 2025-04-08 17:12:07 -04:00
parent 2b39597e60
commit 103ce065e4
1 changed files with 22 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

45
apps/epg/signals.py
View file

@ -17,35 +17,35 @@ def create_or_update_refresh_task(sender, instance, **kwargs):
Create or update a Celery Beat periodic task when an EPGSource is created/updated.
"""
task_name = f"epg_source-refresh-{instance.id}"
interval, _ = IntervalSchedule.objects.get_or_create(
every=24,
every=int(instance.refresh_interval),
period=IntervalSchedule.HOURS
)
if not instance.refresh_task:
refresh_task = PeriodicTask.objects.create(
name=task_name,
interval=interval,
task="apps.epg.tasks.refresh_epg_data",
kwargs=json.dumps({"source_id": instance.id}),
enabled=instance.refresh_interval != 0,
)
EPGSource.objects.filter(id=instance.id).update(refresh_task=refresh_task)
else:
task = instance.refresh_task
updated_fields = []
task, created = PeriodicTask.objects.get_or_create(name=task_name, defaults={
"interval": interval,
"task": "apps.epg.tasks.refresh_epg_data",
"kwargs": json.dumps({"source_id": instance.id}),
"enabled": instance.refresh_interval != 0,
})
if task.enabled != (instance.refresh_interval != 0):
task.enabled = instance.refresh_interval != 0
updated_fields.append("enabled")
update_fields = []
if created:
task.interval = interval
if task.interval != interval:
task.interval = interval
updated_fields.append("interval")
if task.interval != interval:
task.interval = interval
update_fields.append("interval")
if task.enabled != (instance.refresh_interval != 0):
task.enabled = instance.refresh_interval != 0
update_fields.append("enabled")
if updated_fields:
task.save(update_fields=updated_fields)
if update_fields:
task.save(update_fields=update_fields)
if instance.refresh_task != task:
instance.refresh_task = task
instance.save(update_fields=update_fields)
@receiver(post_delete, sender=EPGSource)
def delete_refresh_task(sender, instance, **kwargs):
@ -53,5 +53,4 @@ def delete_refresh_task(sender, instance, **kwargs):
Delete the associated Celery Beat periodic task when a Channel is deleted.
"""
if instance.refresh_task:
instance.refresh_task.interval.delete()
instance.refresh_task.delete()