Fix all celery calls to use remote_query function. Fix remote_queue_name to check for node online state. Add node_online() and node_offline() to track availability of node.
