mex.extractors.system package

Submodules

mex.extractors.system.api module

mex.extractors.system.api.build_system_routes(instance: DagsterInstance) → list[Route]

Build the mex system routes to serve on the dagster webserver.

mex.extractors.system.api.get_daemon_health(instance: DagsterInstance) → dict[str, bool] | None

Check whether each required dagster daemon has sent a recent heartbeat.

mex.extractors.system.api.get_daemon_status(instance: DagsterInstance) → VersionStatus

Get the status and version of the dagster daemons.

mex.extractors.system.api.get_postgres_status(instance: DagsterInstance) → VersionStatus

Get the status and version of the postgres database.

mex.extractors.system.api.get_system_status() → VersionStatus

Get the status and version of the extractors webserver.

mex.extractors.system.api.patch_dagster_webserver() → None

Patch the dagster webserver to also serve the mex system routes.

mex.extractors.system.api.run_webserver() → None

Run the dagster webserver with the mex system routes.

mex.extractors.system.main module

mex.extractors.system.main._delete_asset_data(storage_base: Path, asset_key: AssetKey) → None

Delete an obsolete Dagster asset, its files and metadata.

mex.extractors.system.settings module

class mex.extractors.system.settings.SystemSettings(*, max_run_age_in_days: Annotated[int, Ge(ge=1)] = 30, protected_asset_prefixes: list[str] = ['protected'])

Bases: BaseModel

Settings for System.

max_run_age_in_days: int

model_config = {}

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

protected_asset_prefixes: list[str]

Module contents