Function get_cache_directive_for_path

tests/query_test/test_hdfs_caching.py:313–317

(path)

def get_cache_directive_for_path(path):
  rc, stdout, stderr = exec_process("hdfs cacheadmin -listDirectives -path %s" % path)
  assert rc == 0
  dirid = re.search(r'^\s+?(\d+)\s+?testPool\s+?.*?$', stdout, re.MULTILINE).group(1)
  return dirid


def change_cache_directive_repl_for_path(path, repl):