def runOnNode(query, node_name, save_dir):
    (pickle_file, json_file) = query.save(save_dir)
    command = ['ssh', node_name, 'python3', os.path.join(BKB_PATHWAY_CORE_DIR, 'driver.py'), '--config_file', os.path.join(BKB_PATHWAY_CORE_DIR, 'driver.config'), '--headless', '--query_file', pickle_file, '--save_dir', save_dir]
    subprocess.run(command)
    return json_file
def runOnNode(query, node_name, save_dir):
    (pickle_file, json_file) = query.save(save_dir)
    command = ['ssh', node_name, 'python3', os.path.join(BKB_PATHWAY_CORE_DIR, 'driver.py'), '--config_file', os.path.join(BKB_PATHWAY_CORE_DIR, 'driver.config'), '--headless', '--query_file', pickle_file, '--save_dir', save_dir]
    subprocess.run(command)
    return json_file