o Df<@sdZddlZddlmZddlmZmZmZddlm Z ej ede de dej d d ee d d d ej ddeed dd ej ddedd ddej dded ddej dded ddej ddedd ddejed d!ZdS)"zAThe ``celery migrate`` command, used to filter and move messages.N) Connection) CeleryCommand CeleryOptionhandle_preload_options) migrate_tasks)clssource destinationz-nz--limitzMigration OptionszNumber of tasks to consume.)rtype help_grouphelpz-tz --timeoutz%Timeout in seconds waiting for tasks.z-az--ack-messagesTz Ack messages from source broker.)ris_flagr r z-Tz--tasksz List of task names to filter on.)rr r z-Qz--queueszList of queues to migrate.z-Fz --foreverz'Continually migrate tasks until killed.c s.fdd}tt|t|fd|i|dS)zMigrate tasks from one broker to another. Warning: This command is experimental, make sure you have a backup of the tasks before you continue. cs&jd|jd|jd|dS)NzMigrating task /z: )objechocountstrtotal)statebodymessagectxK/home/ubuntu/webapp/venv/lib/python3.10/site-packages/celery/bin/migrate.pyon_migrate_task9s&z migrate..on_migrate_taskcallbackN)rr)rrr kwargsrrrrmigrate s 0 r)__doc__clickkomburcelery.bin.baserrrcelery.contrib.migratercommandargumentoptionintfloat pass_contextrrrrrsf   "