o wvXj@s|dZddlmZmZmZddlZddlZddlZddlZddl m Z ddl m Z dZ dadaeZeZdadd Zd d Zd d ZddZGdddejZeZe ZejZejZ ddZ!ddZ"ddZ#ej$%drsddZ&n ej$%dr~ddZ&ne"Z&ddZ'dd Z(e e&Z)e e'Z*d!d"Z+d#d$Z,d%d&Z-d0d'd(Z.d0d)d*Z/d+d,Z0d-d.Z1ej$%d/re0dSe1dS)1zInternal state. This is an internal module containing thread state like the ``current_app``, and ``current_task``. This module shouldn't be used directly. )absolute_importprint_functionunicode_literalsN)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)callbackrJ/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/_state.pyr -s r cCstt}|D]}||qdSN)setr)app callbacksrrrr_announce_app_finalized3s rcCs|adSr_task_join_will_block)blocksrrr_set_task_join_will_block9rcCtSrrrrrrtask_join_will_block>rc@seZdZdZdS)_TLSN)__name__ __module__ __qualname__r rrrrr Bsr cCs|adS)zSet default app.N) default_apprrrrrXrcCs>tdurddlm}t|dgdtjdpddtjptS)NrCelerydefaultF CELERY_LOADER)fixupsset_as_currentloader) r$celery.app.baser(rosenvironget_tlsr r'rrr_get_current_app^s  r3cCs |t_dSr)r2r r%rrr_set_current_appis r4 C_STRICT_APPcCstd)zReturn the current app.zUSES CURRENT APP) RuntimeErrorrrrrrnrr C_WARN_APPcCs*ddl}tdtjd|jtjdtS)Nrz-- USES CURRENT_APP)file) tracebackprintsysstderr print_stackr3)r9rrrrrscCstjS)zCurrently executing task.) _task_stacktoprrrrr {sr cCs$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 r cCt|dSr)_appsrr%rrr _register_apprGcCrEr)rFdiscardr%rrr_deregister_apprHrJcCrr)rFrrrr_get_active_appsrrKcCs|durtS|Sr)rr%rrr_app_or_defaultsrLcCsddlm}zddlm}Wn tyd}Ynw|durCttddr.td|tjS|r6|j dkr:t dtd|t S|S) Nr)r=)current_processr z-- RETURNING TO CURRENT APP -- MainProcessz DEFAULT APPz-- RETURNING TO DEFAULT APP --) r9r=billiard.processrM ImportErrorgetattrr2r:r _name Exceptionr$)rr=rMrrr_app_or_default_traces"   rTcCtadS)z Enable tracing of app instances.N)rTapp_or_defaultrrrr enable_tracer&rWcCrU)z!Disable tracing of app instances.N)rLrVrrrr disable_tracer&rXCELERY_TRACE_APPr)2__doc__ __future__rrrr/r; threadingweakref celery.localrcelery.utils.threadsr__all__r$rVWeakSetrFrrrr rrrlocalr r2r>pushpush_current_taskpoppop_current_taskrr3r4r0r1rr r r r rGrJrKrLrTrWrXrrrrsZ