File: //usr/local/lib/python3.9/site-packages/celery/bin/__pycache__/migrate.cpython-39.pyc
a
X>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� �</usr/local/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
������