o Df@shdZddlZddlZddlZddlZddlmZddlmZdZ da da e Z eZdaddZd d Zd d Zd dZGdddejZeZeZejZejZddZddZddZej !driddZ"n ej !drtddZ"neZ"ddZ#ddZ$ee"Z%ee#Z&d d!Z'd"d#Z(d$d%Z)d/d&d'Z*d/d(d)Z+d*d+Z,d,d-Z-ej !d.re,dSe-dS)0zInternal 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_finalizeFcCst||S)z8Connect callback to be called when any app is finalized.)_on_app_finalizersadd)callbackrF/home/ubuntu/webapp/venv/lib/python3.10/site-packages/celery/_state.pyr +s r cCstt}|D]}||qdSN)setr )app callbacksr rrr_announce_app_finalized1s rcCs|adSr_task_join_will_block)blocksrrr_set_task_join_will_block7rcCtSrrrrrrtask_join_will_block<rc@seZdZdZdS)_TLSN)__name__ __module__ __qualname__rrrrrr@srcCs|adS)zSet default app.N) default_apprrrrrVrcCs>tdurddlm}t|dgdtjdpddtjptS)NrCelerydefaultF CELERY_LOADER)fixupsset_as_currentloader) r!celery.app.baser%rosenvironget_tlsrr$rrr_get_current_app\s  r0cCs |t_dSr)r/rr"rrr_set_current_appgs r1 C_STRICT_APPcCstd)zReturn the current app.zUSES CURRENT APP) RuntimeErrorrrrrrlrr C_WARN_APPcCs*ddl}tdtjd|jtjdtS)Nrz-- USES CURRENT_APP)file) tracebackprintsysstderr print_stackr0)r6rrrrpscCstjS)zCurrently executing task.) _task_stacktoprrrrrysrcCs$ttjD] }|jjs|SqdS)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)reversedr;stackrequestcalled_directly)taskrrrr~s rcCt|dSr)_appsr r"rrr _register_apprDcCrBr)rCdiscardr"rrr_deregister_apprErGcCrr)rCrrrr_get_active_appsrrHcCs|durtS|Sr)rr"rrr_app_or_defaultsrIcCsddlm}zddlm}Wn tyd}Ynw|durCttddr.td|tjS|r6|j dkr:t dtd|t S|S) Nr)r:)current_processrz-- RETURNING TO CURRENT APP -- MainProcessz DEFAULT APPz-- RETURNING TO DEFAULT APP --) r6r:billiard.processrJ ImportErrorgetattrr/r7r_name Exceptionr!)rr:rJrrr_app_or_default_traces"   rQcCtadS)z Enable tracing of app instances.N)rQapp_or_defaultrrrr enable_tracer#rTcCrR)z!Disable tracing of app instances.N)rIrSrrrr disable_tracer#rUCELERY_TRACE_APPr).__doc__r,r8 threadingweakref celery.localrcelery.utils.threadsr__all__r!rSWeakSetrCrr rr rrrlocalrr/r;pushpush_current_taskpoppop_current_taskrr0r1r-r.rrrrr rDrGrHrIrQrTrUrrrrsX