I have many celery nodes running on different Linux boxes. A simplified cluster looks like: 
I have a long-running taskA which downloads a (huge) file from a remote file-server, and I want to trigger taskB once the taskA finishes its job on the same machine because that is where the taskA downloaded the file which is basically an input to the taskB. I know Celery is supposed to be distributed, but in some cases, like this one having a true distributed solution would be expensive.
Notice in the diagram that taskA on nodeA triggers taskB on the same node, while taskA that runs on nodeB triggers taskB on nodeB (same node that runs the "parent" task).
apply() does not work because I want to queue the taskB() to run when there is a spare worker process (on the same node!) for it.
I started exploring possibility of having a unique queue on each node (so nodeA has queueA, nodeB has queueB, etc), but I do not know how to get available queue names from taskA so I can queue task on the queue on the same node. (This would probably solve my problem.)
I was trying to find solution in Celery documentation, but I could not find anything that helps me. Any idea will greatly appreciated.