Scheduled exports: Add required transaction

This commit is contained in:
Raphael Michel
2023-01-19 18:41:46 +01:00
parent 5ee1213dbf
commit b29efb9694

View File

@@ -26,7 +26,7 @@ from typing import Any, Dict, Union
from celery.exceptions import MaxRetriesExceededError from celery.exceptions import MaxRetriesExceededError
from django.conf import settings from django.conf import settings
from django.core.files.base import ContentFile from django.core.files.base import ContentFile
from django.db import connection from django.db import connection, transaction
from django.dispatch import receiver from django.dispatch import receiver
from django.utils.timezone import now, override from django.utils.timezone import now, override
from django.utils.translation import gettext from django.utils.translation import gettext
@@ -328,6 +328,7 @@ def scheduled_event_export(self, event: Event, schedule: int) -> None:
@receiver(signal=periodic_task) @receiver(signal=periodic_task)
@scopes_disabled() @scopes_disabled()
@transaction.atomic
def run_scheduled_exports(sender, **kwargs): def run_scheduled_exports(sender, **kwargs):
qs = ScheduledEventExport.objects.filter( qs = ScheduledEventExport.objects.filter(
schedule_next_run__lt=now(), schedule_next_run__lt=now(),