
    leJi                     B    d dl Z d dlmZ d dlmZ  G d de          ZdS )    N)transaction)Taskc                   "    e Zd ZdZddZddZdS )
DjangoTaskz
    Extend the base :class:`~celery.app.task.Task` for Django.

    Provide a nicer API to trigger tasks at the end of the DB transaction.
    returnNc                 ^    t          j        t          j        | j        g|R i |           dS )zGCall :meth:`~celery.app.task.Task.delay` with Django's ``on_commit()``.N)r   	on_commit	functoolspartialdelayselfargskwargss      `/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/celery/contrib/django/task.pydelay_on_commitzDjangoTask.delay_on_commit   s6    i/
LTLLLVLLMMMMM    c                 ^    t          j        t          j        | j        g|R i |           dS )zMCall :meth:`~celery.app.task.Task.apply_async` with Django's ``on_commit()``.N)r   r	   r
   r   apply_asyncr   s      r   apply_async_on_commitz DjangoTask.apply_async_on_commit   s7    i/0@R4RRR6RRSSSSSr   )r   N)__name__
__module____qualname____doc__r   r    r   r   r   r      sP         N N N NT T T T T Tr   r   )r
   	django.dbr   celery.app.taskr   r   r   r   r   <module>r      ss        ! ! ! ! ! !            T T T T T T T T T Tr   