AWS¶
- class laminar.configurations.datastores.AWS¶
Bases:
object
Methods
Attributes
- class S3(root: str, cache: ~typing.Dict[str, ~typing.Any] = <factory>, protocols: ~typing.Dict[str, ~laminar.configurations.serde.Protocol] = <factory>)¶
Bases:
DataStore
Store the laminar workspace in AWS S3.
Usage:
Flow(datastore=AWS.S3())
- __init__(root: str, cache: ~typing.Dict[str, ~typing.Any] = <factory>, protocols: ~typing.Dict[str, ~laminar.configurations.serde.Protocol] = <factory>)¶
- cache : dict[str, Any]¶
Internal datastore cache
- protocol(*dtypes: type) Callable[[type[ProtocolType]], type[ProtocolType]] ¶
Register a custom serde protocol for a type.
Usage:
@datastore.protocol(pd.DataFrame) def DataFrameProtocol(serde.Protocol): ...
-
read_archive(*, layer: Layer, index: int, name: str, cache: bool =
False
) Archive ¶ Read an archive from the laminar datastore.
- root : str¶
URI root of the datastore
-
write_archive(*, layer: Layer, name: str, artifacts: list[Artifact], cache: bool =
False
) Archive ¶ Write an archive to the laminar datastore.
- __init__()¶