Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/__pycache__/_state.cpython-39.pyc
Ðазад
a t�h� � @ 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 �}/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка