Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/bin/__pycache__/migrate.cpython-39.pyc
Ðазад
a t�h< � @ s� d Z ddlZddlmZ ddlmZmZmZ ddlm Z ej ed�e� d�e� d�ej d d ee d d d �ej ddeed dd �ej ddedd dd�ej dded dd�ej dded d d�ej d d edd d d�ejed d!� �����������ZdS )"zAThe ``celery migrate`` command, used to filter and move messages.� N)� Connection)� CeleryCommand� CeleryOption�handle_preload_options)� migrate_tasks)�cls�source� destinationz-nz--limitzMigration OptionszNumber of tasks to consume.)r �type� help_group�helpz-tz --timeoutz%Timeout in seconds waiting for tasks.z-az--ack-messagesTz Ack messages from source broker.)r Zis_flagr r z-Tz--tasksz List of task names to filter on.)r r r z-Qz--queueszList of queues to migrate.z-Fz --foreverz'Continually migrate tasks until killed.c s. � fdd�}t t|�t|�fd|i|�� dS )z�Migrate tasks from one broker to another. Warning: This command is experimental, make sure you have a backup of the tasks before you continue. c s& � j �d| j� d| j� d|� �� d S )NzMigrating task �/z: )�objZecho�countZstrtotal)�state�body�message��ctx� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/bin/migrate.py�on_migrate_task9 s z migrate.<locals>.on_migrate_task�callbackN)r r )r r r �kwargsr r r r �migrate s 0 ���r )�__doc__ZclickZkombur Zcelery.bin.baser r r Zcelery.contrib.migrater �command�argument�option�int�floatZ pass_contextr r r r r �<module> sd ������
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка