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