Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/celery/__pycache__/ |
a
��Sh� � @ sh d Z ddlZddlZddlZddlZddlmZ ddlmZ dZ da
da e� � Z
e� Zdadd� Zd d
� Zd d � Zd
d� ZG dd� dej�Ze� Ze� ZejZejZ dd� Z dd� Z dd� Z ej �!d�r�dd� Z"nej �!d�r�dd� Z"ne Z"d d � Z#d d � Z$ee"�Z%ee#�Z&d d!� Z'd"d#� Z(d$d%� Z)d/d&d'�Z*d0d(d)�Z+d*d+� Z,d,d-� Z-ej �!d.��r^e,� ne-� dS )1z�Internal 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_app�get_current_app�get_current_task�get_current_worker_task� current_app� current_task�connect_on_app_finalizeFc C s t �| � | S )z8Connect callback to be called when any app is finalized.)�_on_app_finalizers�add)�callback� r �7/usr/local/lib/python3.9/site-packages/celery/_state.pyr
+ s
r
c C s t t�}|D ] }|| � q d S �N)�setr )�app� callbacksr
r r r �_announce_app_finalized1 s r c C s | a d S r ��_task_join_will_block)�blocksr r r �_set_task_join_will_block7 s r c C s t S r r r r r r �task_join_will_block< s r c @ s e Zd ZdZdS )�_TLSN)�__name__�
__module__� __qualname__r r r r r r @ s r c C s | a dS )zSet default app.N)� default_app�r r r r r V s r c C s> t d u r4ddlm} t| dg dtj�d�p,dd�� tjp<t S )Nr ��Celery�defaultFZ
CELERY_LOADER)�fixupsZset_as_current�loader) r Zcelery.app.baser! r �os�environ�get�_tlsr r r r r �_get_current_app\ s �r) c C s
| t _d S r )r( r r r r r �_set_current_appg s r* Z C_STRICT_APPc C s t d��dS )zReturn the current app.zUSES CURRENT APPN)� RuntimeErrorr r r r r l s r Z
C_WARN_APPc C s* dd l } tdtjd� | jtjd� t� S )Nr z-- USES CURRENT_APP)�file)� traceback�print�sys�stderr� print_stackr) )r- r r r r p s c C s t jS )zCurrently executing task.)� _task_stack�topr r r r r y s r c C s$ t tj�D ]} | jjs
| S q
dS )z�Currently 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)�reversedr2 �stack�requestZcalled_directly)�taskr r r r ~ s r c C s t �| � d S r )�_appsr r r r r �
_register_app� s r9 c C s t �| � d S r )r8 �discardr r r r �_deregister_app� s r; c C s t S r )r8 r r r r �_get_active_apps� s r< c C s | d u rt � S | S r )r r r r r �_app_or_default� s r= c C s� ddl m} zddlm} W n ty2 d }Y n0 | d u r�ttdd �r\td� |� tjS |rl|� j dkrtt
d��td� |� t S | S ) Nr )r1 )�current_processr z -- RETURNING TO CURRENT APP --� MainProcessz DEFAULT APPz -- RETURNING TO DEFAULT APP --) r- r1 Zbilliard.processr> � ImportError�getattrr( r. r �_name� Exceptionr )r r1 r> r r r �_app_or_default_trace� s
rD c C s t adS )z Enable tracing of app instances.N)rD �app_or_defaultr r r r � enable_trace� s rF c C s t adS )z!Disable tracing of app instances.N)r= rE r r r r �
disable_trace� s rG ZCELERY_TRACE_APP)N)N).�__doc__r% r/ � threading�weakrefZ celery.localr Zcelery.utils.threadsr �__all__r rE �WeakSetr8 r r r r
r r r �localr r( r2 �pushZpush_current_task�popZpop_current_taskr r) r* r& r' r r r r r r9 r; r< r= rD rF rG r r r r �<module> sV