how to send jobs to queue dynamically 1

how to send jobs to queue dynamically

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

Here is what the above code is Doing:
1. It’s sending a task to the queue named ‘queue_name_1’
2. It’s sending a task to the queue named ‘queue_name_2’

Similar Posts