hNdZddlZddlZddlZddlZddlmZddlmZdZ da da ejZ eZdadZdZd Zd ZGd d ej*ZeZeZej2Zej6Zd ZdZdZej@jCdrdZ"n!ej@jCdrdZ"neZ"dZ#dZ$ee"Z%ee#Z&dZ'dZ(dZ)ddZ*ddZ+dZ,dZ-ej@jCdre,ye-y)zInternal state. This is an internal module containing thread state like the ``current_app``, and ``current_task``. This module shouldn't be used directly. N)Proxy) LocalStack)set_default_appget_current_appget_current_taskget_current_worker_task current_app current_taskconnect_on_app_finalizeFc0tj||S)z8Connect callback to be called when any app is finalized.)_on_app_finalizersadd)callbacks I/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/_state.pyr r +s8$ Oc@tt}|D] }|| yN)setr )app callbacksrs r_announce_app_finalizedr1s&'I rc|ayr_task_join_will_block)blockss r_set_task_join_will_blockr7s"rctSrrrrtask_join_will_blockr<s  rceZdZdZy)_TLSN)__name__ __module__ __qualname__r rrrr!r!@s Krr!c|ay)zSet default app.N) default_apprs rrrVs Krc t>/2?i      *{*rc|t_yr)r4r r's r_set_current_appr7gs Dr C_STRICT_APPctd)zReturn the current app.zUSES CURRENT APP) RuntimeErrorrrrrrls-..r C_WARN_APPcddl}tdtj|j tjt S)Nrz-- USES CURRENT_APP)file) tracebackprintsysstderr print_stackr5)r>s rrrps2 ##**53::.!!rc"tjS)zCurrently executing task.) _task_stacktoprrrrrys ??rctttjD]}|jjr|cSy)zCurrently executing task, that was applied by the worker. This is used to differentiate between the actual task executed by the worker and any task that was called within a task (using ``task.__call__`` or ``task.apply``) N)reversedrDstackrequestcalled_directly)tasks rrr~s+**+||++K,rc.tj|yr)_appsrr's r _register_apprNs  IIcNrc.tj|yr)rMdiscardr's r_deregister_apprQs MM#rctSr)rMrrr_get_active_appsrSs Lrc| tS|Sr)rr's r_app_or_defaultrUs {  Jrcddlm} ddlm}|lt t ddr"td|t jS|r|jdk(r tdtd|tS|S#t$rd}Y}wxYw) Nr)rB)current_processr z-- RETURNING TO CURRENT APP -- MainProcessz DEFAULT APPz-- RETURNING TO DEFAULT APP --) r>rBbilliard.processrW ImportErrorgetattrr4r?r _name Exceptionr&)rrBrWs r_app_or_default_tracer^s%4 { 4 - 2 3 M## #/"3"9"9]"JM* * ./  J sA>> B  B ctay)z Enable tracing of app instances.N)r^app_or_defaultrrr enable_traceras +Nrctay)z!Disable tracing of app instances.N)rUr`rrr disable_tracercs %NrCELERY_TRACE_APPr).__doc__r1r@ threadingweakref celery.localrcelery.utils.threadsr__all__r&r`WeakSetrMrr rr rrrlocalr!r4rDpushpush_current_taskpoppop_current_taskrr5r7r2r3rrrr r rNrQrSrUr^rarcrrrrqsH +   U  # !9?? vl  $$?? +::>>.!/ZZ^^L!" 'O O$ %&  &+ % ::>>$%NOr