Дублирование данных, хранящихся в django, с помощью задачи celery

Мне кажется, что задача celery вызывается дважды Вот мой код

@task(run_every=crontab(minute="*/1"), queue="accountability")
def analyse():
    with transaction.atomic():
         analyzed_record, _ = Model.objects.get_or_create(
                    invoice_tag=invoice_tags,
                    product_name="demo"
                )
                analyzed_record.current = 0
                analyzed_record.prev = 1
                analyzed_record.invoiced = 2
                analyzed_record.save()

Я использую следующие args celery celery worker --beat --app=demo --concurrency=10 --loglevel=INFO -Q calculate_cost,accountability,scriptQ,ScriptQ,defaultQ

Я ожидаю, что если я использую get_or_create, то данные объекта должны быть уникальными

Вернуться на верх