+
    Tj                         ^ RI HtHt ^ RIHt ^ RIHt ^ RIHt ^ RI	H
t
 ^ RIHtHtHtHt ^ RIHt ^ RIHt ^ R	IHtHt  ! R
 R]R7      tR# )    )ABCMetaabstractmethod)iscoroutinefunction)sync_to_async)settings)DEFAULT_TASK_QUEUE_NAME)DEFAULT_TASK_PRIORITYTASK_MAX_PRIORITYTASK_MIN_PRIORITYTask)InvalidTask)timezone)get_func_argsis_module_level_functionc                   h   a  ] tR t^t o ]tRtRtRtRt	R t
R t]R 4       tR tR tR tR tR	tV tR
# )BaseTaskBackendFc                    Wn         \        VP                  R \        .4      4      V n        VP                  R/ 4      V n        R# )QUEUESOPTIONSN)aliassetgetr   queuesoptions)selfr   paramss   &&&O/var/www/idalgo/venv/lib/python3.14/site-packages/django/tasks/backends/base.py__init__BaseTaskBackend.__init__%   s4    
&**X0G/HIJzz)R0    c                   \        VP                  4      '       g   \        R4      hV P                  '       g'   \	        VP                  4      '       d   \        R4      h\        VP                  4      pVP                  '       d"   V'       d   V^ ,          R8w  d   \        R4      hV P                  '       g!   VP                  \        8w  d   \        R4      hVP                  \        8  g:   VP                  \        8  g%   \        VP                  4      VP                  8w  d   \        R\         R\         R24      hV P                  '       g   VP                  e   \        R
4      h\        P                   '       d@   VP                  e2   \"        P$                  ! VP                  4      '       g   \        R4      hV P&                  '       d7   VP(                  V P&                  9  d   \        RVP(                   R24      hR	# R	# )zE
Determine whether the provided Task can be executed by the backend.
z0Task function must be defined at a module level.z%Backend does not support async Tasks.contextzCTask takes context but does not have a first argument of 'context'.z3Backend does not support setting priority of tasks.z(priority must be a whole number between z and .Nz#Backend does not support run_after.z$run_after must be an aware datetime.zQueue 'z' is not valid for backend.)r   funcr   supports_async_taskr   r   takes_contextsupports_prioritypriorityr	   r   r
   intsupports_defer	run_afterr   USE_TZr   is_awarer   
queue_name)r   tasktask_func_argss   && r   validate_taskBaseTaskBackend.validate_task*   s    (		22PQQ''',?		,J,JEFF&tyy1."3y"@U  %%%$--;P*PSTTMM--}}004==!T]]2:;L:MU$%Q( 
 """t~~'ACDD OOO*%%dnn55DEE;;;4??$++='88STUU >;r    c                    R# )zQueue up a task to be executed.N r   r/   argskwargss   &&&&r   enqueueBaseTaskBackend.enqueueU   s    r    c                \   "   \        V P                  RR7      ! WVR7      G Rj  xL
 #  L5i)z7Queue up a task function (or coroutine) to be executed.Tthread_sensitive)r/   r6   r7   N)r   r8   r5   s   &&&&r   aenqueueBaseTaskBackend.aenqueueY   s,     "4<<$G
 
 	
 
s   #,*,c                    \        R4      h)z\
Retrieve a task result by id.

Raise TaskResultDoesNotExist if such result does not exist.
z?This backend does not support retrieving or refreshing results.)NotImplementedErrorr   	result_ids   &&r   
get_resultBaseTaskBackend.get_result_   s     "M
 	
r    c                Z   "   \        V P                  RR7      ! VR7      G Rj  xL
 #  L5i)zSee get_result().Tr;   )rB   N)r   rC   rA   s   &&r   aget_resultBaseTaskBackend.aget_resulti   s*     "4??TJ
 
 	
 
s   "+)+c                    . # )Nr4   )r   r7   s   &,r   checkBaseTaskBackend.checko   s    	r    )r   r   r   N)__name__
__module____qualname____firstlineno__r   
task_classr*   r%   supports_get_resultr'   r   r1   r   r8   r=   rC   rF   rI   __static_attributes____classdictcell__)__classdict__s   @r   r   r      sb     J N     1
)VV . .


 r    r   )	metaclassN)abcr   r   inspectr   asgiref.syncr   django.confr   django.tasksr   django.tasks.baser	   r
   r   r   django.tasks.exceptionsr   django.utilsr   django.utils.inspectr   r   r   r4   r    r   <module>r^      s7    ' ' &   0  0 ! H] ]r    