`f<@dZddlZddlmZddlmZmZmZddlm Z ej eej dej dej d d ee d d ej ddeed d ej ddedd dej dded dej dded dej ddedd dejed 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 ffd}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. cbjd|jd|jd|dS)NzMigrating task /z: )objechocountstrtotal)statebodymessagectxs D/var/www/html/env/lib/python3.11/site-packages/celery/bin/migrate.pyon_migrate_taskz migrate..on_migrate_task9s:  Mu{MMU^MMtMMNNNNNcallbackN)rr)rr r kwargsrs` rmigrater sl`OOOOO*V$$[))*r)__doc__clickkomburcelery.bin.baserrrcelery.contrib.migratercommandargumentoptionintfloat pass_contextrrrr,sGG OOOOOOOOOO000000=!!!  d,0 222 d,: <<< d,5 777 d,5 777 d,/ 111 d,< >>>  >> 11 77 77 << 22"!Nr