h<*dZddlZddlmZddlmZmZmZddlm Z ejeejdejdejd d ee d d ejddeed d ejddedd dejdded dejdded dejddedd dejed Zy)!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 Rfd}tt|t|fd|i|y)zMigrate tasks from one broker to another. Warning: This command is experimental, make sure you have a backup of the tasks before you continue. cvjjd|jd|jd|y)NzMigrating task /z: )objechocountstrtotal)statebodymessagectxs N/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/bin/migrate.pyon_migrate_taskz migrate..on_migrate_task9s/  u{{m1U^^4DBtfMNcallbackN)rr)rr r kwargsrs` rmigrater s5`O*V$[)*r)__doc__clickkomburcelery.bin.baserrrcelery.contrib.migratercommandargumentoptionintfloat pass_contextrrrr,sQG OO0=!  d,0 2 d,: < d,5 7 d,5 7 d,/ 1 d,< >  > 1 7 7 < 2"Nr