NeoAnd/netbox
1
0
Fork 0
mirror of https://github.com/netbox-community/netbox.git synced 2025-07-27 10:58:37 -06:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Fix logic for clearing pending jobs on interval change

Browse Source
This commit is contained in:
Jeremy Stretch 2025-02-27 08:28:10 -05:00
parent 91d8cb596e
commit 50cdee4710
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
netbox/core/signals.py
View File

@ -182,7 +182,7 @@ def clear_events_queue(sender, **kwargs):
# #
@receiver(post_save, sender=DataSource) @receiver(post_save, sender=DataSource)
def enqueue_sync_job(instance, **kwargs): def enqueue_sync_job(instance, created, **kwargs):
""" """
When a DataSource is saved, check its sync_interval and enqueue a sync job if appropriate. When a DataSource is saved, check its sync_interval and enqueue a sync job if appropriate.
""" """
@ -190,9 +190,9 @@ def enqueue_sync_job(instance, **kwargs):
if instance.sync_interval: if instance.sync_interval:
SyncDataSourceJob.enqueue_once(instance, interval=instance.sync_interval) SyncDataSourceJob.enqueue_once(instance, interval=instance.sync_interval)
else: elif not created:
# Delete any previously scheduled recurring jobs for this DataSource # Delete any previously scheduled recurring jobs for this DataSource
SyncDataSourceJob.get_jobs(instance).filter(sync_interval__isnull=False).delete() SyncDataSourceJob.get_jobs(instance).filter(interval__isnull=False).delete()
@receiver(post_sync) @receiver(post_sync)