Method _remote

sdk/python/feast/infra/ray_initializer.py:409–412

(file_path, read_kwargs)

        @ray.remote
        def _remote(file_path, read_kwargs):
            import ray

            return ray.data.read_parquet(file_path, **read_kwargs)

        opts = self._get_task_options()
        remote_fn = _remote.options(**opts) if opts else _remote