
    MȂi                     r    S SK Jr  S SKJrJr  S SKJr  S SKJr  S SK	J
r
  S SKJr  SSKJr   " S	 S
\5      rg)    )deepcopy)
TaskResultTaskResultStatus)TaskResultDoesNotExist)task_enqueued)timezone)get_random_string   )BaseTaskBackendc                   R   ^  \ rS rSrSrSrSrU 4S jrS rS r	S r
S rS rS	rU =r$ )
DummyBackend   Tc                 2   > [         TU ]  X5        / U l        g N)super__init__results)selfaliasparams	__class__s      LD:\sksbv-state-backend\venv\Lib\site-packages\django/tasks/backends/dummy.pyr   DummyBackend.__init__   s    '    c                     [         R                  US[        R                  " 5       5        U R                  R                  U5        [        R                  " [        U 5      US9  g )Nenqueued_at)task_result)	object__setattr__r   nowr   appendr   sendtype)r   results     r   _store_resultDummyBackend._store_result   s@    6=(,,.AF#4:6:r   c                     U R                  U5        [        U[        S5      [        R                  S S S S UUU R
                  / / S9nU R                  U5        [        U5      $ )N    )taskidstatusr   
started_atlast_attempted_atfinished_atargskwargsbackenderrors
worker_ids)validate_taskr   r	   r   READYr   r%   r   )r   r)   r/   r0   r$   s        r   enqueueDummyBackend.enqueue   sj    4  $#))"JJ
 	6" r   c                 x   ^  [        U4S jU R                   5       5      $ ! [         a    [        T5      S ef = f)Nc              3   H   >#    U H  oR                   T:X  d  M  Uv   M     g 7fr   r*   .0r$   	result_ids     r   	<genexpr>*DummyBackend.get_result.<locals>.<genexpr>5        T\6YY)=S\   "	"nextr   StopIterationr   r   r=   s    `r   
get_resultDummyBackend.get_result1   s9    	>TT\\TTT 	>(3=	>s   " 9c                    ^#     [        U4S jU R                   5       5      $ ! [         a    [        T5      S ef = f7f)Nc              3   H   >#    U H  oR                   T:X  d  M  Uv   M     g 7fr   r:   r;   s     r   r>   +DummyBackend.aget_result.<locals>.<genexpr>;   r@   rA   rB   rE   s    `r   aget_resultDummyBackend.aget_result9   s;     	>TT\\TTT 	>(3=	>s   >$ >;>c                 8    U R                   R                  5         g r   )r   clear)r   s    r   rN   DummyBackend.clear?   s    r   )r   )__name__
__module____qualname____firstlineno__supports_defersupports_async_tasksupports_priorityr   r%   r6   rF   rK   rN   __static_attributes____classcell__)r   s   @r   r   r      s7    N;
 .>> r   r   N)copyr   django.tasks.baser   r   django.tasks.exceptionsr   django.tasks.signalsr   django.utilsr   django.utils.cryptor	   baser   r    r   r   <module>ra      s&     : : . ! 1 !4? 4r   