Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/worker/__pycache__/loops.cpython-39.pyc
Ðазад
a t�hQ � @ s| d Z ddlZddlZddlmZ ddlmZ ddlmZ ddl m Z dZ ee �Z dd d �Zdd d�Zddd�Zddd�ZdS )z*The consumers highly-optimized inner loop.� N)� bootsteps)�WorkerLostError)� get_logger� )�state)�asynloop�synloop皙�����?c C sZ z| j |d� W nD tyT } z,t|dd �}|d ur@|tjkr@� W Y d }~n d }~0 0 d S )N��timeout�errno)� drain_events� Exception�getattrr �EAGAIN)� connectionr �excZ exc_errno� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/worker/loops.py� _quick_drain s r � @c sJ d g�� s�S � � � }|r � js$�S � �fdd�}| �|| ||f� �S )Nc s@ z� � | � W n, ty: } z|�d< W Y d }~n d }~0 0 d S )Nr )Zheartbeat_checkr )�rate�e�r �heartbeat_errorr r �tick& s z#_enable_amqheartbeats.<locals>.tick)Zget_heartbeat_intervalZsupports_heartbeatsZcall_repeatedly)�timerr r � heartbeatr r r r �_enable_amqheartbeats s r c C s� t j} |j} |j} | �� } t|j||d�} | |_| j� |� | � |� |� � | � � | j sn| j �� sntd��|jjdkr�|�t|� | |_|�� }z�|j| kr�| jr�t�� | d dur�| d �|j|jkr�| � z t|� W q� t y� |�� }Y q�0 q�W z |� � W n2 t �y> } zt � d|� W Y d}~n d}~0 0 nBz |� � W n2 t �y� } zt � d|� W Y d}~n d}~0 0 0 dS )zNon-blocking event loop.�r z Could not start worker processesZamqpr Nz&Error cleaning up after event loop: %r)!r �RUN�updateZconnection_errors�create_task_handlerr r � on_message� controllerZregister_with_event_loop�consume�on_readyZ restart_count�poolZ did_start_okr � transportZ driver_typeZ call_soonr Zpropagate_errorsZ create_loopr r �maybe_shutdown�prev�value�next� StopIteration�resetr �logger� exception)�objr �consumer� blueprint�hub�qosr �clock�hbrater Z update_qos�errors�on_task_receivedr �loopr r r r r 2 sN � � �r c K s� t j} | �� } | j} dg} t| jdd�r8t| j||d�} | |_|� � | � � |j | kr�| j r�t � � | d durz| d �|j|jkr�|�� z| � |jdd� W qN tjy� Y qN ty� |j | krЂ Y qN0 qNdS )zEFallback blocking event loop for transports that doesn't support AIO.NZis_greenFr r r r )r r r" �perform_pending_operationsr r' r r r# r% r& r r r) r* r+ r! r �socketr �OSError)r1 r r2 r3 r4 r5 r r6 r7 �kwargsr r9 r; r r r r r l s. r )r )r )r )r )�__doc__r r< Zceleryr Zcelery.exceptionsr Zcelery.utils.logr � r �__all__�__name__r/ r r r r r r r r �<module> s � ; �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка