Bagaimana cara mengirim pekerjaan ke antrian secara dinamis

celery.send_task('job1', args=[], kwargs={}, queue='queue_name_1')
celery.send_task('job1', args=[], kwargs={}, queue='queue_name_2')
Anies