diff --git a/alluxiofs/client/core.py b/alluxiofs/client/core.py index bbfdab5..5f09550 100644 --- a/alluxiofs/client/core.py +++ b/alluxiofs/client/core.py @@ -458,24 +458,6 @@ def read(self, file_path): if file_status is None: raise FileNotFoundError(f"File {file_path} not found") return self.read_range(file_path, 0, file_status.length) - # self._validate_path(file_path) - # worker_host, worker_http_port = self._get_preferred_worker_address( - # file_path - # ) - # path_id = self._get_path_hash(file_path) - # try: - # if self.data_manager: - # return b"".join( - # self._all_page_generator_alluxiocommon( - # worker_host, worker_http_port, path_id, file_path - # ) - # ) - # else: - # return b"".join( - # self._all_page_generator( - # worker_host, worker_http_port, path_id, file_path - # ) - # ) except Exception as e: raise Exception( f"Error when reading file {file_path}: error {e}" diff --git a/alluxiofs/core.py b/alluxiofs/core.py index d61f900..07a8301 100644 --- a/alluxiofs/core.py +++ b/alluxiofs/core.py @@ -417,12 +417,12 @@ def modified(self, path, *args, **kwargs): @fallback_handler def head(self, path, *args, **kwargs): path = self.unstrip_protocol(path) - return self.alluxio.head(path, **kwargs) + return self.alluxio.head(path, *args, **kwargs) @fallback_handler def tail(self, path, *args, **kwargs): path = self.unstrip_protocol(path) - return self.alluxio.tail(file_path=path, **kwargs) + return self.alluxio.tail(path, *args, **kwargs) @fallback_handler def expand_path(self, path, *args, **kwargs): @@ -479,8 +479,6 @@ def put(self, lpath, rpath, *args, **kwargs): raise NotImplementedError def write(self, path, value, **kwargs): - # path = self.unstrip_protocol(path) - # return self.alluxio.write(path, value) return self.upload_data(path, value, **kwargs) def read(self, path, *args, **kwargs): diff --git a/tests/no_mock_tests/other_option_test_disabled.py b/tests/no_mock_tests/other_option_test_disabled.py index 458d61d..3418400 100644 --- a/tests/no_mock_tests/other_option_test_disabled.py +++ b/tests/no_mock_tests/other_option_test_disabled.py @@ -10,7 +10,6 @@ "alluxiofs", etcd_hosts="localhost", etcd_port=2379, - # target_options=oss_options, target_protocol="s3", page_size="1MB", )