
    ]j|                     F    d dl Z  e j                         Zd Zd Zd Zd Zy)    Nc                  B    t         j                  j                  dg       S )a  
    Returns a temporary queue to store jobs before they're committed
    later in the request/response cycle. Each job is stored as a tuple
    containing the queue, args and kwargs.

    For example, if we call ``queue.enqueue_call(foo, kwargs={'bar': 'baz'})`` during the
    request/response cycle, job_queue will look like:

    job_queue = [(default_queue, foo, {'kwargs': {'bar': 'baz'}})]

    This implementation is heavily inspired by
    https://github.com/chrisdoble/django-celery-transactions
    	job_queue)_thread_data__dict__
setdefault     @/root/env/lib/python3.12/site-packages/django_rq/thread_queue.py	get_queuer      s       ++K<<r	   c                 <    t               j                  | ||f       y N)r   append)queueargskwargss      r
   addr      s    KtV,-r	   c                      t               }	 |r*|j                  d      \  }} } |j                  | i | |r*t                y# t                w xY w)z2
    Processes all jobs in the delayed queue.
    r   N)r   poporiginal_enqueue_callclear)r   r   delayed_queuer   s       r
   commitr      sQ     KM"/"3"3A"6E4'E''88  	s   +A Ac                  0    	 t         `y # t        $ r Y y w xY wr   )r   r   AttributeError)r   r   s     r
   r   r   )   s    " s   	 	)	threadinglocalr   r   r   r   r   r   r	   r
   <module>r      s,     y =".
r	   