File: //usr/local/lib/python3.9/site-packages/celery/worker/__pycache__/loops.cpython-39.pyc
a
X>h� � @ 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 �exc� exc_errno� r �=/usr/local/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_type� 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 s� t j� | �� }
| j�dg�t| jdd�r8t| j�|d��|
|_|� � | �
� � �����fdd�} �j � kr�| j r�zt �
� W | � qd| � 0 qddS )zEFallback blocking event loop for transports that doesn't support AIO.NZis_greenFr c st �d dur�d ��j �jkr(��� z�� �jdd� W n0 tjyR Y n tyn �j� krj� Y n0 dS )zC
Perform one iteration of the blocking event loop.
r Nr r
)r, r- r" r
�socketr �OSErrorr r �r! r5 r r �perform_pending_operationsr7 r r � _loop_cyclez s
z synloop.<locals>._loop_cycle)r r! r# r@ r r( r r r$ r& r' r r r+ ) r3 r r4 r5 r6 r7 r r8 r9 �kwargsr; rA r r? r r l s
r )r )r )r )r )�__doc__r r= Zceleryr Zcelery.exceptionsr Zcelery.utils.logr � r �__all__�__name__r1 r r r r r r r r �<module> s
�
; �