ray.rllib.offline.mixed_input.MixedInput#

class ray.rllib.offline.mixed_input.MixedInput(dist: Dict[JsonReader, float], ioctx: IOContext)[source]#

Bases: InputReader

Mixes input from a number of other input sources.

from ray.rllib.offline.io_context import IOContext
from ray.rllib.offline.mixed_input import MixedInput
ioctx = IOContext(...)
MixedInput({
   "sampler": 0.4,
   "/tmp/experiences/*.json": 0.4,
   "s3://bucket/expert.json": 0.2,
}, ioctx)

Methods

`__init__`	Initialize a MixedInput.
`tf_input_ops`	Returns TensorFlow queue ops for reading inputs from this reader.