Function drop_cache_directives_for_path

tests/query_test/test_hdfs_caching.py:295–299

Drop the cache directive for a given path

(path)

def drop_cache_directives_for_path(path):
  """Drop the cache directive for a given path"""
  rc, stdout, stderr = exec_process("hdfs cacheadmin -removeDirectives -path %s" % path)
  assert rc == 0, \
      "Error removing cache directive for path %s (%s, %s)" % (path, stdout, stderr)


def is_path_fully_cached(path):