caikit.core.data_model.streams.resolver

DataStream resolver that resolves a given file or Datastream to a DataStream

Attributes

log
error

Classes

DataStreamResolver

Resolves files or DataStreams into DataStreams

Module Contents

caikit.core.data_model.streams.resolver.log

caikit.core.data_model.streams.resolver.error

class caikit.core.data_model.streams.resolver.DataStreamResolver(target_stream_type: type, expected_keys: Dict[str, type])

Resolves files or DataStreams into DataStreams

_converter: caikit.core.data_model.streams.converter.DataStreamConverter

_validator: caikit.core.data_model.streams.validator.DataStreamValidator

_csv_formatter: caikit.core.data_model.streams.csv_column_formatter.CSVColumnFormatter

as_data_stream(file_or_data_stream) → caikit.core.data_model.DataStream

Marshals whatever you give it into a data stream, or dies trying. …Or leaves the error for you to find later when reading the stream.

Args:

file_or_data_stream (str or DataStream): Either a string path to a

file, or a DataStream

Returns:

DataStream: The data as a converted and properly formatted data stream