Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/apps/__pycache__/worker.cpython-39.pyc
Ðазад
a t�h�3 � @ s d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m Z ddl m Z ddl mZ ddlmZmZmZ dd lmZ dd lmZ dd lmZmZmZ dd lm Z m Z dd l m Z ddl m!Z! ddl"m#Z#m$Z$m%Z% ddl&m'Z' ddl(m)Z) dZ*e#e+�Z,ej�-d�Z.e/ed�Z0g d�Z1dZ2dZ3dd� Z4ej5fdd�Z6G d d � d e)�Z7d d defd d!�Z8e d"k�rzee8d#d$ed%�Z9nee8d#d d&�Z9e.�s�ee8d"d$ed%�Z:n d'd(� Z9Z:d)d*� Z;e.�s�ee8d+e;ed,�Z<nd-d.� Z<d/d0� Z=d=d2d3�Z>d>d5d6�Z?d?d9d:�Z@d@d;d<�ZAdS )Az�Worker command-line program. This module is the 'program-version' of :mod:`celery.worker`. It does everything necessary to run that module as an actual application, like installing signal handlers, platform tweaks, and so on. � N)�datetime)�partial)� REMAP_SIGTERM)�current_process)�safe_str)�VERSION_BANNER� platforms�signals)�trace)� AppLoader)� EX_FAILURE�EX_OK�check_privileges)�static�term)�cry)�qualname)� get_logger� in_sighandler�set_in_sighandler)� pluralize)�WorkController)�Worker�java�pypy_version_info) � --------------�--- ***** -----�-- ******* ----�- *** --- * ---�- ** ----------r r r r r r r z�{hostname} v{version} {platform} {timestamp} [config] .> app: {app} .> transport: {conninfo} .> results: {results} .> concurrency: {concurrency} .> task events: {events} [queues] {queues} z [tasks] {tasks} c C s ddl m} tdd� | � D ��S )Nr �� enumeratec s s | ]}|j �d �sdV qdS )zDummy-� N)�name� startswith)�.0�t� r' ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/apps/worker.py� <genexpr>L s �z&active_thread_count.<locals>.<genexpr>)� threadingr! �sumr r' r' r( �active_thread_countJ s r, c C s t d| � �|dd� d S )N� T��file�flush)�print)�msg�fr' r' r( �safe_sayP s r4 c s� e Zd ZdZd#dd�Zd$� fdd� Zdd � Z� fd d �Zd d � Zdd� Z d%dd�Z dd� Z d&dd�Z dd� Z d'dd �Zd d � Zd d � Zd!d"� Z� ZS )(r zWorker as a program.Fc K sB || _ t�| j| j� tjj| j| | jj|d� t | jjj � d S )N)�sender�instance�conf�options) �quietr �setup_worker_optimizations�app�hostnamer Z celeryd_init�sendr7 r Zaccept_content)�selfr9 �kwargsr' r' r( �on_before_initW s �zWorker.on_before_initNc sr | j �d|�| _| j �d|�| _t� jf i |�� || _|| _tj � � | _ | j j j | j|d urd| n|d�| _ d S )NZworker_redirect_stdoutsZ worker_redirect_stdouts_level)�enabled)r; Zeither�redirect_stdouts�redirect_stdouts_level�superZsetup_defaults�purge�no_color�sys�stdout�isatty�_isatty�log�colored�logfile)r> rE rF rB rC r? �� __class__r' r( � on_after_initc s �� �zWorker.on_after_initc C s | � � | _t�| j| j� d S �N)� setup_logging�_custom_loggingr r: r; r< �r> r' r' r( �on_init_blueprints s zWorker.on_init_blueprintc s� | j }t� �� tjj| j| |jd� | jr4| � � | j sB| � � | � d� | � | � | jsp| jrp|j�| j� d}|j}t|t�r�|�� dv}|r�|j�� r�t�d� d S )N)r5 r6 r7 z-active-T)zdjango.conf:settingszPlease run `celery upgrade settings path/to/settings.py` to avoid these warnings and to allow a smoother upgrade to Celery 6.0.)r; rD �on_startr Zceleryd_after_setupr= r< r7 rE �purge_messagesr9 � emit_banner�set_process_status�install_platform_tweaksrS rB rK rC Z_config_source� isinstance�str�lowerZ maybe_warn_deprecated_settings�logger�warning)r> r; Zwarn_deprecatedZ config_sourcerN r' r( rV y s, � �zWorker.on_startc C sl t �� }|r tt �t�� �� ttd�t| j � d| j | d���t| j � | � � pRd��g��tjdd� d S )N� z )�artlinesTr. )r Zsupports_imagesr1 Zimgcatr Zlogor �joinr\ rL �cyan� startup_info�reset� extra_inforG � __stdout__)r> Z use_imager' r' r( rX � s ���zWorker.emit_bannerc C s$ t jj|d� t�dt| j�� d S )N)r5 z %s ready.)r Z worker_readyr= r^ �infor r< )r> Zconsumerr' r' r( �on_consumer_ready� s zWorker.on_consumer_readyc C s8 |d u r| j d ur| j }| jjj| j| jd|| jd�S )NF)rB �colorizer< )rF r; rK �setup�loglevelrM r< )r> rj r' r' r( rR � s �zWorker.setup_loggingc C sb | j �� �D}| j jj|d�}|r@td|� dt|d�� d�dd� W d � n1 sT0 Y d S )N)� connectionzpurge: Erased � �messagez from the queue. T)r0 )r; Zconnection_for_write�controlrE r1 r )r> rm �countr' r' r( rW � s zWorker.purge_messagesTr- �celery.c s" |� � �fdd�t| jj�D ��S )Nc 3 s, | ]$}� s|� ��sn|rd |� �V qdS )z . N)r$ )r% �task��include_builtins�int_r' r( r) � s �z"Worker.tasklist.<locals>.<genexpr>)rb �sortedr; �tasks)r> ru �seprv r' rt r( �tasklist� s �zWorker.tasklistc C sB | j d u rd S | j tjkr>| j tjk}| j|d�}tj|d�S d S )N)ru )rx )rl �logging�INFO�DEBUGrz �EXTRA_INFO_FMT�format)r> ru rz r' r' r( rf � s zWorker.extra_infoc C s� | j }t| j�}d�|jp dt|��}t|jt�sbt |j�}|� d�rR|dd � }|d|� d�7 }| j r�| j \}}d|� d|� d �}| j }t|t�s�|j }|d|�d �d � d�7 }d } | js�d } tj|t| j�t�� jdd�t| j �� �� | j j�� |tt�� �| |j j jddd�d� � � } |�r|t | �D ]N\} } z d� t!| | | g�| | < W n$ t"�yv d| | | | < Y n0 �q,d� | �d S )Nz{}:{:#x}�__main__zcelery.loaders� � (�)z{min=z, max=�}�.����ONz/OFF (enable -E to monitor tasks in this worker)r )� microsecondF)�indent� indent_first) r; r< � timestamp�versionZconninfo�results� concurrency�platform�events�queuesrn z r- )#r; r\ r� r �main�idr[ �loaderr r r$ Z autoscale�pool_cls� __module__�splitZ task_events�BANNERr r< r �now�replacer rm �as_uri�backend� _platformr� Zamqpr� � splitlinesr! rb �ARTLINES� IndexError) r> ra r; r� Zapprr� �max�min�poolr� Zbanner�i�_r' r' r( rd � sJ � zWorker.startup_infoc C sX | j jr| �� | js0| j jr(t|� nt|� t|� t|� t|� t � t � dS )z1Install platform specific tweaks and workarounds.N) r; ZIS_macOS� macOS_proxy_detection_workaroundrJ �!install_HUP_not_supported_handler� install_worker_restart_handler�install_worker_term_handler� install_worker_term_hard_handler�install_worker_int_handler�install_cry_handler�install_rdb_handler)r> �workerr' r' r( rZ � s z Worker.install_platform_tweaksc C s t j�dd� dS )z6See https://github.com/celery/celery/issues#issue/161.Zcelery_dummy_proxyZset_by_celerydN)�os�environ� setdefaultrT r' r' r( r� s z'Worker.macOS_proxy_detection_workaroundc C s& t jd|� dt �tj�� d�| jd�S )NZcelerydr� r� )rh r< )r Zset_mp_process_titleZstrargvrG �argvr< )r> rh r' r' r( rY s �zWorker.set_process_status)F)FNNN)N)Tr- rr )T)�__name__r� � __qualname__�__doc__r@ rP rU rV rX ri rR rW rz rf rd rZ r� rY � __classcell__r' r' rN r( r T s" � ( *r �TERM�Warmc s2 � ����fdd�}t d�� ��|_|tj�< d S )Nc s� t � �t ddlm} t� jdkrV� r,� �� td�� d�tj� tj j �j ���d� t |ddd �� �� W d � n1 s�0 Y d S ) Nr ��state� MainProcesszworker: z shutdown (MainProcess))r5 �sig�how�exitcode� should_stopZshould_terminate)r� �Cold) r � celery.workerr� r �_namer4 rG rg r Zworker_shutting_downr= r< �setattr)�argsr� ��callbackr� r� r� r� r' r( �_handle_request s" ����z*_shutdown_handler.<locals>._handle_requestZworker_)r\ r� r r )r� r� r� r� r� r� r' r� r( �_shutdown_handler s r� �SIGQUIT�SIGTERMr� )r� r� r� )r� r� c O s d S rQ r' )�a�kwr' r' r( �<lambda>< � r� c C s t dtj� t| dd� d S )Nz>worker: Hitting Ctrl+C again will terminate all running tasks!�SIGINT�r� )r4 rG rg r� )r� r' r' r( � on_SIGINT? s �r� r� )r� r� r� c O s d S rQ r' )r� r? r' r' r( r� K s r� c C s2 t �tjtjtjg� t�tjtjgtj � d S rQ ) r Zclose_open_fdsrG � __stdin__rg � __stderr__r� �execv� executabler� r' r' r' r( �_reload_current_workerO s �r� �SIGHUPc C s dd� }|t j|< d S )Nc W sL t d� tdd�tj�� d�tj� ddl}|�t� ddl m } t |_ dS )z5Signal handler restarting the current python program.TzRestarting celery worker (rn r� r Nr� ) r r4 rb rG r� rg �atexit�registerr� r� r� r r� )r� r� r� r' r' r( �restart_worker_sig_handlerX s � zBinstall_worker_restart_handler.<locals>.restart_worker_sig_handler�r r )r� r� r� r' r' r( r� V s r� �SIGUSR1c C s t rd S dd� }|tj| < d S )Nc W s4 t � � tt� � W d � n1 s&0 Y dS )z=Signal handler logging the stack-trace of all active threads.N)r r4 r )r� r' r' r( � cry_handleri s z(install_cry_handler.<locals>.cry_handler)�is_pypyr r )r� r� r' r' r( r� d s r� � CELERY_RDBSIG�SIGUSR2c C s" dd� }t j�| �r |tj|< d S )Nc W sV t � �< ddlm}m} | r$| d n|� j}||� W d � n1 sH0 Y dS )z=Signal handler setting a rdb breakpoint at the current frame.r )�_frame� set_tracer" N)r Zcelery.contrib.rdbr� r� �f_back)r� r� r� �framer' r' r( � rdb_handlers s z(install_rdb_handler.<locals>.rdb_handler)r� r� �getr r )Zenvvarr� r� r' r' r( r� p s r� c s � fdd�}|t j� < d S )Nc s: t � � tdj� d�� W d � n1 s,0 Y d S )NzH{sig} not supported: Restarting with {sig} is unstable on this platform!r� )r r4 r )�signumr� r� r' r( �warn_on_HUP_handler� s �z>install_HUP_not_supported_handler.<locals>.warn_on_HUP_handlerr� )r� r� r� r' r� r( r� s r� )r� )r� )r� r� )r� )Br� r{ r� r� r� rG r � functoolsr Zbilliard.commonr Zbilliard.processr Zkombu.utils.encodingr Zceleryr r r Z celery.appr Zcelery.loaders.appr Zcelery.platformsr r r Z celery.utilsr r Zcelery.utils.debugr Zcelery.utils.importsr Zcelery.utils.logr r r Zcelery.utils.textr r� r �__all__r� r^ r$ Z is_jython�hasattrr� r� r� r~ r, r� r4 r r� r� r� r� r� r� r� r� r� r� r' r' r' r( �<module> s| F� ����� �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка