File: //usr/local/lib/python3.9/site-packages/celery/app/__pycache__/builtins.cpython-39.pyc
a
X>h � @ s� d Z ddlmZ ddlmZ dZee�Zedd� �Zedd� �Z ed d
� �Z
ed d � �Z ed
d� �Z edd� �Z
edd� �Zedd� �Zedd� �ZdS )zOBuilt-in Tasks.
The built-in tasks are always available in all app instances.
� )�connect_on_app_finalize)�
get_logger� c s � j dddd�� fdd��}|S )z�Task used to clean up expired results.
If the configured backend requires periodic cleanup this task is also
automatically configured to run every day at 4am (requires
:program:`celery beat` to be running).
zcelery.backend_cleanupF��name�shared�lazyc s � j �� d S �N)�backend�cleanupr ��appr �=/usr/local/lib/python3.9/site-packages/celery/app/builtins.py�backend_cleanup s z1add_backend_cleanup_task.<locals>.backend_cleanup��task)r
r r r r �add_backend_cleanup_task s r c C s | j ddddd�dd� �}|S )z9Task used by Task.replace when replacing task with group.Tzcelery.accumulateF)�bindr r r c _ s |� d�}|d ur|| S |S )N�index)�get)�self�args�kwargsr r r r �
accumulate s
z'add_accumulate_task.<locals>.accumulater )r
r r r r �add_accumulate_task s
r c sl ddl m� ddlm� ddlm�m} �jddd�jj dddd �ddd�j
�j |f� ���fd
d � �}|S ) z�Task used by result backends without native chord support.
Will joins chord by creating a task chain polling the header
for completion.
r ��maybe_signature)�
ChordError)�allow_join_result�result_from_tuplezcelery.chord_unlockNFT)r � max_retriesr �default_retry_delay�
ignore_resultr r c s� |d u r| j }�|��}||�� fdd�|D ��d�}
|
jrB|
jn|
j} z |
�� } W n4 ty� }
z | j|
||d��W Y d }
~
n d }
~
0 0 | s�| j||d���|�d�}z:�� � | �jjdd�}W d � n1 s�0 Y W n� t�yh }
zlz"t |
�
� �}d|j � d |
��}W n t �y2 t
|
�}Y n0 t�d
||
� �j�|�|�� W Y d }
~
nhd }
~
0 0 z|�|� W nN t�y� }
z4t�d
||
� �jj|�d |
���d � W Y d }
~
n
d }
~
0 0 d S )
Nc s g | ]}�|� d ��qS �r r )�.0�r)r
r r r �
<listcomp>< � z?add_unlock_chord_task.<locals>.unlock_chord.<locals>.<listcomp>r )�exc� countdownr )r) r T)�timeout� propagatez Dependency z raised zChord %r raised: %rzCallback error: )r( )r! Zsupports_native_joinZ join_native�join�ready� Exception�retry�confZresult_chord_join_timeout�nextZ_failed_join_report�id�
StopIteration�repr�logger� exceptionr
Zchord_error_from_stack�delay)r �group_id�callback�intervalr �result�Result� GroupResultr r �deps�jr- r( �retZculprit�reason�r r r
r �r r � unlock_chord/ sP
� � �( ( �z+add_unlock_chord_task.<locals>.unlock_chord) �
celery.canvasr Zcelery.exceptionsr �
celery.resultr r r r0 Zresult_chord_retry_intervalZ AsyncResultr= )r
r rD r rB r �add_unlock_chord_task$ s
��2rG c s. ddl m� � jdddd�� �fdd��}|S )Nr �� signaturez
celery.mapFr c s �� �d�j � � fdd�|D �S )Nr c s g | ] }� |��qS r r �r$ �itemr r r r& m r' z.add_map_task.<locals>.xmap.<locals>.<listcomp>��type�r �it�r
rI r r �xmapj s zadd_map_task.<locals>.xmap�rE rI r )r
rQ r rP r � add_map_taskf s rS c s. ddl m� � jdddd�� �fdd��}|S )Nr rH zcelery.starmapFr c s �� �d�j � � fdd�|D �S )Nr c s g | ] }� |� �qS r r rJ r r r r& x r' z6add_starmap_task.<locals>.xstarmap.<locals>.<listcomp>rL rN rP r r �xstarmapu s z"add_starmap_task.<locals>.xstarmaprR )r
rT r rP r �add_starmap_taskq s rU c s, ddl m� | jdddd�� fdd��}|S )Nr )�chunksz
celery.chunksFr c s � � | ||�S r )Z apply_chunks)r rO �n��_chunksr r rV � s z add_chunk_task.<locals>.chunks)rE rV r )r
rV r rX r �add_chunk_task| s rZ c s> ddl m� ddlm� | jddddd�d
� �fdd � �}|S ) �5No longer used, but here for backwards compatibility.r r rC z celery.groupTF)r r r r c s� | j � �|� �}� ��fdd�t|�D �}� �� �$���fdd�|D � W d � n1 s\0 Y � j}|r~|r~|�|� |S )Nc 3 s$ | ] \}}�|� d �� ��V qdS )r N)�clone)r$ �ir )r
r � partial_argsr r � <genexpr>� s �z0add_group_task.<locals>.group.<locals>.<genexpr>c s g | ]}|j � �d d��qS )F)r8 �producer�
add_to_parent)Z apply_async)r$ Zstask)r8 r` r r r& � s ��z1add_group_task.<locals>.group.<locals>.<listcomp>)r
� enumerateZproducer_or_acquireZcurrent_worker_taskZ add_trail)r �tasksr; r8 r^ ra Ztaskit�parent�r r )r
r8 r^ r` r �group� s
�
�$
z add_group_task.<locals>.group)T)rE r rF r r )r
rf r re r �add_group_task� s
rg c C s | j dddd�dd� �}|S )r[ z celery.chainFr c _ s t d��d S )Nzchain is not a real task)�NotImplementedError)r r r r r �chain� s z add_chain_task.<locals>.chainr )r
ri r r r �add_chain_task� s
rj c sN ddl m� ddl m� ddlm� | jdddddd�d� ��fd d
� �}|S )r[ r )�chord)rf r z celery.chordTF)r r r" r r r N� c sl | j � t|��r|jn|} �� �fdd�| D �| j d�}�|� d�}�||�}
|
j|||� |||fi |��S )Nc s g | ]}�|� d ��qS r# r )r$ �s)r
r r r r& � s z1add_chord_task.<locals>.chord.<locals>.<listcomp>r )r
�
isinstancerc �run) r �header�bodyr^ r: r) r �eagerr rc �ch�Z_chordrf r r r rk � s ��
��z add_chord_task.<locals>.chord)r Nrl NF)Zceleryrk rf rE r r )r
rk r rt r �add_chord_task� s
� � ru N)�__doc__Z
celery._stater Zcelery.utils.logr �__all__�__name__r5 r r rG rS rU rZ rg rj ru r r r r �<module> s,
A