Skip to main content
Glama
frothkoetter

data-quality-cde-mcp-server

by frothkoetter
OverviewSchemaRelated ServersScoreDiscussions
Python
Remote

Server Configuration

Describes the environment variables required to run the server.

NameRequiredDescriptionDefault
CDE_BINNoPath to cde CLI (default: cde)cde
CDE_USERNoCDE workload username
CDE_PASSWORDNoCDE workload password
CDE_ENDPOINT_URLNoCDE service endpoint URL
CDW_CONNECTION_IDNoAirflow connection id for Hive/Impala in CDW (default: CDW)CDW
DEFAULT_DAG_SCHEDULENoCron schedule (default: daily at 03:00 UTC)0 3 * * *

Capabilities

Features and capabilities supported by this server

CapabilityDetails
tools
{
  "listChanged": false
}
prompts
{
  "listChanged": false
}
resources
{
  "subscribe": false,
  "listChanged": false
}
experimental
{}

Tools

Functions exposed to the LLM to take actions

NameDescription
get_cde_configA

Return current CDE/CDW configuration (passwords redacted).

Reads CDE_USER, CDE_PASSWORD, CDE_ENDPOINT_URL, CDE_BIN, CDW_CONNECTION_ID from environment or .env file.

diagnose_cde_connectivityB

Probe CDE CLI connectivity (configure endpoint + list jobs).

Args: cde_user: CDE workload username (overrides CDE_USER env). cde_password: CDE workload password (overrides CDE_PASSWORD env). cde_endpoint_url: CDE service URL (overrides CDE_ENDPOINT_URL env).

generate_dag_from_contractA

Generate Airflow DAG Python from an ODCS data contract (no WAP).

Validates live table schema (required columns, PK uniqueness) and data quality rules using Airflow SQLCheckOperator against the CDW connection (default: CDW). Default schedule is once daily (0 3 * * *) unless overridden.

Args: contract_json: ODCS-compatible contract JSON (schema_objects + quality rules). schedule: Cron schedule (default 0 3 * * * — daily at 03:00 UTC). cdw_connection_id: Airflow connection id for Hive/Impala in CDW (default CDW). audit_table: Optional qualified audit table name for check results.

preview_contract_checksA

Preview schema and quality SQL checks that would be generated from a contract.

deploy_contract_dq_jobA

Generate DAG from data contract and deploy to Cloudera CDE as an Airflow job.

Creates/updates a CDE files resource (lib/, sql/, DAG) and an Airflow job. Checks live table data against schema and quality rules — no WAP/staging branch.

Args: contract_json: ODCS-compatible contract JSON. cde_user: CDE workload username. cde_password: CDE workload password. cde_endpoint_url: CDE REST/CLI endpoint URL. cdw_connection_id: Airflow CDW connection id (default CDW). schedule: Cron schedule (default daily 0 3 * * *). audit_table: Optional audit table qualified name. force_recreate: Delete and recreate job/resource before deploy. trigger_after_deploy: Trigger a manual CDE job run after deploy.

list_cde_jobsC

List all CDE jobs.

describe_cde_jobC

Describe a CDE job by name.

list_cde_resourcesC

List CDE file resources.

trigger_cde_jobC

Trigger a manual CDE job run.

list_cde_job_runsA

List CDE runs for a job (monitor execution status).

get_cde_job_run_statusB

Get status of a specific CDE job run.

get_airflow_dag_run_statusA

Monitor latest CDE Airflow job run status (via CDE run API).

Returns the most recent run for the given CDE Airflow job, including status, start/end times, and run id for further inspection.

delete_cde_jobB

Delete a CDE Airflow job. WRITE OPERATION

Prompts

Interactive templates invoked by user choice

NameDescription

No prompts

Resources

Contextual data attached and managed by the client

NameDescription

No resources

Latest Blog Posts

MCP directory API

We provide all the information about MCP servers via our MCP API.

curl -X GET 'https://glama.ai/api/mcp/v1/servers/frothkoetter/data-quality-cde-mcp-server'

If you have feedback or need assistance with the MCP directory API, please join our Discord server