Migrate single task message.
(producer, body_, message, queues=None)
| 78 | |
| 79 | |
| 80 | def migrate_task(producer, body_, message, queues=None): |
| 81 | """Migrate single task message.""" |
| 82 | info = message.delivery_info |
| 83 | queues = {} if queues is None else queues |
| 84 | republish(producer, message, |
| 85 | exchange=queues.get(info['exchange']), |
| 86 | routing_key=queues.get(info['routing_key'])) |
| 87 | |
| 88 | |
| 89 | def filter_callback(callback, tasks): |
searching dependent graphs…