perago.LakeFSConfig#

class perago.LakeFSConfig(*, endpoint_url, access_key_id, secret_access_key)[源代码]#

Worker-local LakeFS connection settings.

LakeFSConfig is assembled from the LakeFS environment variables used by the worker runtime. The values stay local to the worker process and are not serialized into Conductor task input, task output, or generated TaskDefs.

Parameters:

endpoint_urlstr: LakeFS endpoint read from LAKECTL_SERVER_ENDPOINT_URL.
access_key_idstr: LakeFS access key id read from LAKECTL_CREDENTIALS_ACCESS_KEY_ID.
secret_access_keypydantic.SecretStr: LakeFS secret access key read from LAKECTL_CREDENTIALS_SECRET_ACCESS_KEY. Pydantic redacts this value from model reprs and JSON dumps.

Raises:

RuntimeConfigError: Raised by load_runtime_config() when only part of the LakeFS environment variable set is present or when a value is still "replace-me".

参数:

endpoint_url (str)
access_key_id (str)
secret_access_key (SecretStr)

参见

load_runtime_config: Load this model from worker environment settings.
RuntimeConfig: Full runtime configuration containing this model.

Notes

The model is frozen and rejects unknown fields. The three LakeFS variables must be configured together for perago start; perago check and perago extract may omit all three.

Examples

>>> LakeFSConfig(
...     endpoint_url="http://localhost:8000",
...     access_key_id="key",
...     secret_access_key="secret",
... )
LakeFSConfig(...)

Attributes

`endpoint_url`
`access_key_id`
`secret_access_key`