o wvXje@s8dZddlmZmZddlmZdZGdddeZdS)zAThe ``celery migrate`` command, used to filter and move messages.)absolute_importunicode_literals)CommandzGMigrating task {state.count}/{state.strtotal}: {body[task]}[{body[id]}]c@s0eZdZdZdZeZddZddZddZ d S) migrateanMigrate tasks from one broker to another. Warning: This command is experimental, make sure you have a backup of the tasks before you continue. Example: .. code-block:: console $ celery migrate amqp://A.example.com amqp://guest@B.example.com// $ celery migrate redis://localhost amqp://guest@localhost// z cCs||d}|jddtdd|jddtdd d |jd d d ddd|jdddd|jdddd|jddd ddddS)NzMigration Optionsz--limitz-nz Number of tasks to consume (int))typehelpz --timeoutz-tg?z,Timeout in seconds (float) waiting for tasks)rdefaultrz--ack-messagesz-a store_trueFz Ack messages from source broker.)actionrrz--tasksz-Tz List of task names to filter on.)rz--queuesz-QzList of queues to migrate.z --foreverz-Fz'Continually migrate tasks until killed.)add_argument_group add_argumentintfloat)selfparsergrouprO/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/bin/migrate.py add_argumentss2  zmigrate.add_argumentscCs||jj||ddS)N)statebody)out progress_fmtformat)rrrmessagerrron_migrate_task8szmigrate.on_migrate_taskcKs<ddlm}ddlm}|||||fd|ji|dS)Nr) Connection) migrate_taskscallback)komburcelery.contrib.migraterr)rsource destinationkwargsrrrrrrun;s   z migrate.runN) __name__ __module__ __qualname____doc__argsMIGRATE_PROGRESS_FMTrrrr$rrrrr s  rN)r( __future__rrcelery.bin.baserr*rrrrrs