Question

I have two celery workers, worker 1 has tasks A and B, worker 2 with tasks A, B, and C. If I submit a task C, it doesn't seem to be executed in the celery worker that has task C; is there some way I can make sure that only worker 2 gets assigned tasks C?

Was it helpful?

Solution

I'd take a look at routing tasks in the documentation. You can create queues with specific topics, and specify which worker(s) can handle which queue(s).

Licensed under: CC-BY-SA with attribution
Not affiliated with StackOverflow
scroll top