Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/serdes/serdes.py
| Show First 20 Lines • Show All 264 Lines • ▼ Show 20 Lines | ) -> tuple: | ||||
| if not isinstance(dagster_namedtuple, tuple): | if not isinstance(dagster_namedtuple, tuple): | ||||
| raise DeserializationError( | raise DeserializationError( | ||||
| f"Output of deserialized json_str was not expected type of tuple. Received type {type(dagster_namedtuple)}." | f"Output of deserialized json_str was not expected type of tuple. Received type {type(dagster_namedtuple)}." | ||||
| ) | ) | ||||
| return dagster_namedtuple | return dagster_namedtuple | ||||
| def deserialize_as(json_str: str, cls: type) -> tuple: | |||||
| """Deserialize a json encoded string to a specific namedtuple class.""" | |||||
| return check.inst(deserialize_json_to_dagster_namedtuple(json_str), cls) | |||||
| def _deserialize_json(json_str: str, whitelist_map: WhitelistMap): | def _deserialize_json(json_str: str, whitelist_map: WhitelistMap): | ||||
| value = seven.json.loads(json_str) | value = seven.json.loads(json_str) | ||||
| return _unpack_value(value, whitelist_map=whitelist_map, descent_path=_root(value)) | return _unpack_value(value, whitelist_map=whitelist_map, descent_path=_root(value)) | ||||
| def deserialize_value(val: str) -> Any: | def deserialize_value(val: str) -> Any: | ||||
| """Deserialize a json encoded string in to its original value""" | """Deserialize a json encoded string in to its original value""" | ||||
| return _unpack_value( | return _unpack_value( | ||||
| ▲ Show 20 Lines • Show All 161 Lines • Show Last 20 Lines | |||||