Skip to content
Snippets Groups Projects
Verified Commit 4e53ed3c authored by Nik | Klampfradler's avatar Nik | Klampfradler
Browse files

Revert "Make only message sending run on_commit"

This reverts commit 3bae1a9a.
parent 57c1300b
No related branches found
No related tags found
1 merge request!491Resolve "Make Celery non-optional"
import os
from functools import partial
from django.db import transaction
......@@ -12,8 +11,12 @@ app.config_from_object("django.conf:settings", namespace="CELERY")
app.autodiscover_tasks()
def _amqp_send_task_message_on_commit(*args, **kwargs):
transaction.on_commit(partial(app.amqp.send_task_message, *args, **kwargs))
class OnCommitTask(app.Task):
"""Task that is delayed at least until the current transaction commits."""
def delay(self, *args, **kwargs):
def _real_delay():
return super().delay(*args, **kwargs)
transaction.on_commit(_real_delay)
app.amqp.send_task_message = _amqp_send_task_message_on_commit
app.Task = OnCommitTask
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment