Read image directory - dispatched via @ray.remote to cluster workers.
(self, path: Union[str, List[str]], **kwargs)
| 458 | return RemoteDatasetProxy(remote_fn.remote(path, kwargs)) |
| 459 | |
| 460 | def read_images(self, path: Union[str, List[str]], **kwargs) -> Any: |
| 461 | """Read image directory - dispatched via @ray.remote to cluster workers.""" |
| 462 | from feast.infra.ray_shared_utils import RemoteDatasetProxy |
| 463 | |
| 464 | @ray.remote |
| 465 | def _remote(file_path, read_kwargs): |
| 466 | import ray |
| 467 | |
| 468 | return ray.data.read_images(file_path, **read_kwargs) |
| 469 | |
| 470 | opts = self._get_task_options() |
| 471 | remote_fn = _remote.options(**opts) if opts else _remote |
| 472 | return RemoteDatasetProxy(remote_fn.remote(path, kwargs)) |
| 473 | |
| 474 | def read_binary_files(self, path: Union[str, List[str]], **kwargs) -> Any: |
| 475 | """Read binary files - dispatched via @ray.remote to cluster workers.""" |
nothing calls this directly
no test coverage detected