Yohohohohohooho | Sanrei Aya
Sanrei Aya


Server : LiteSpeed
System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64
User : elvh3918 ( 1528)
PHP Version : 8.2.31
Disable Function : mail
Directory :  /usr/local/lib/python3.9/site-packages/celery/bin/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //usr/local/lib/python3.9/site-packages/celery/bin/__pycache__/migrate.cpython-39.pyc
a

��Sh<�@s�dZddlZddlmZddlmZmZmZddlm	Z	ej
ed�e�d�e�d�ejd	d
ee
ddd
�ejddeeddd
�ejddedddd�ejddeddd�ejddeddd�ejddedddd�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.)rZis_flagrrz-Tz--tasksz List of task names to filter on.)rrrz-Qz--queueszList of queues to migrate.z-Fz	--foreverz'Continually migrate tasks until killed.cs.�fdd�}tt|�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.
    cs&�j�d|j�d|j�d|���dS)NzMigrating task �/z: )�objZecho�countZstrtotal)�state�body�message��ctx��</usr/local/lib/python3.9/site-packages/celery/bin/migrate.py�on_migrate_task9sz migrate.<locals>.on_migrate_task�callbackN)rr)rrr	�kwargsrrrr�migrate	s0���r)�__doc__ZclickZkomburZcelery.bin.baserrrZcelery.contrib.migrater�command�argument�option�int�floatZpass_contextrrrrr�<module>sd
������

Yohohohohohooho | Sanrei Aya