`fZdZddlZddlZddlZddlZddlmZddlmZdZ da da ej Z eZdadZdZd Zd ZGd d ejZeZeZejZejZd ZdZdZej !drdZ"n ej !drdZ"neZ"dZ#dZ$ee"Z%ee#Z&dZ'dZ(dZ)ddZ*ddZ+dZ,dZ-ej !dr e,dSe-dS)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_finalizeFc:t||S)z8Connect callback to be called when any app is finalized.)_on_app_finalizersadd)callbacks ?/var/www/html/env/lib/python3.11/site-packages/celery/_state.pyr r +s8$$$ OcNtt}|D] }||dSN)setr )app callbacksrs r_announce_app_finalizedr1s8&''I rc |adSr_task_join_will_block)blockss r_set_task_join_will_blockr7s"rctSrrrrtask_join_will_blockr<s  rceZdZdZdS)_TLSN)__name__ __module__ __qualname__r rrrr!r!@sKKKrr!c |adS)zSet default app.N) default_apprs rrrVs KKKrc tAddlm}t|dgdtjdpdtjptS)NrCelerydefaultF CELERY_LOADER)fixupsset_as_currentloader) r&celery.app.baser*rosenvironget_tlsr r)s r_get_current_appr5\sl****** b:>>/22?i         *{*rc|t_dSr)r4r r's r_set_current_appr7gsDr C_STRICT_APPc td)zReturn the current app.zUSES CURRENT APP) RuntimeErrorrrrrrls-...r C_WARN_APPcddl}tdtj|tjt S)Nrz-- USES CURRENT_APP)file) tracebackprintsysstderr print_stackr5)r>s rrrpsI ##*55553:...!!!rctjS)zCurrently executing task.) _task_stacktoprrrrrys ?rc^ttjD]}|jjs|cSdS)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~sC*++|+ KKK rc:t|dSr)_appsrr's r _register_apprNs IIcNNNNNrc:t|dSr)rMdiscardr's r_deregister_apprQs MM#rctSr)rMrrr_get_active_appsrSs Lrc&|tS|Sr)rr's r_app_or_defaultrUs {   JrcHddlm} ddlm}n#t$rd}YnwxYw|t t ddr%td|t jS|r|j dkrtdtd|tS|S) 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%%%%%%4444444  { 4 - - $ 2 3 3 3 KMMM# # +//"3"3"9]"J"JM** * .///  Js  ctadS)z Enable tracing of app instances.N)r^app_or_defaultrrr enable_traceras +NNNrctadS)z!Disable tracing of app instances.N)rUr`rrr disable_tracercs %NNNrCELERY_TRACE_APPr).__doc__r1r@ threadingweakref celery.localrcelery.utils.threadsr__all__r&r`WeakSetrMrr rr rrrlocalr!r4rDpushpush_current_taskpoppop_current_taskrr5r7r2r3rrrr r rNrQrSrUr^rarcrrrrqs ++++++   SUU  ### !!!9? tvvjll  $? +++:>>.!! '////Z^^L!!'"""" 'O   eO$$ u%&&  &+++ %%% :>>$%%LNNNNNMOOOOOr