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