/
opt
/
imh-python
/
lib
/
python3.9
/
site-packages
/
celery
/
contrib
/
django
/
/opt/imh-python/lib/python3.9/site-packages/celery/contrib/django
mkdir
upload
Name
Size
Mode
Actions
__pycache__/
-
0755
rm
task.py
725
0644
edit
dl
rm
__init__.py
0
0644
edit
dl
rm
Edit:
/opt/imh-python/lib/python3.9/site-packages/celery/contrib/django/task.py
(725B)
import functools from django.db import transaction from celery.app.task import Task class DjangoTask(Task): """ Extend the base :class:`~celery.app.task.Task` for Django. Provide a nicer API to trigger tasks at the end of the DB transaction. """ def delay_on_commit(self, *args, **kwargs): """Call :meth:`~celery.app.task.Task.delay` with Django's ``on_commit()``.""" return transaction.on_commit(functools.partial(self.delay, *args, **kwargs)) def apply_async_on_commit(self, *args, **kwargs): """Call :meth:`~celery.app.task.Task.apply_async` with Django's ``on_commit()``.""" return transaction.on_commit(functools.partial(self.apply_async, *args, **kwargs))
Save
cmd:
run