ray/rllib/offline/resource.py

from ray.rllib.offline.dataset_reader import (
    _get_resource_bundles as dataset_reader_get_resource_bundles,
)
from ray.rllib.utils.annotations import PublicAPI
from ray.rllib.utils.typing import PartialAlgorithmConfigDict
from typing import Dict, List


@PublicAPI
def get_offline_io_resource_bundles(
    config: PartialAlgorithmConfigDict,
) -> List[Dict[str, float]]:
    # DatasetReader is the only offline I/O component today that
    # requires compute resources.
    if config["input"] == "dataset":
        return dataset_reader_get_resource_bundles(config["input_config"])
    else:
        return []