route to worker depending on result in celery?,"my_task.apply_async(exchange='C.dq', routing_key=host)"