data-quality-cde-mcp-server
Server Configuration
Describes the environment variables required to run the server.
| Name | Required | Description | Default |
|---|---|---|---|
| CDE_BIN | No | Path to cde CLI (default: cde) | cde |
| CDE_USER | No | CDE workload username | |
| CDE_PASSWORD | No | CDE workload password | |
| CDE_ENDPOINT_URL | No | CDE service endpoint URL | |
| CDW_CONNECTION_ID | No | Airflow connection id for Hive/Impala in CDW (default: CDW) | CDW |
| DEFAULT_DAG_SCHEDULE | No | Cron schedule (default: daily at 03:00 UTC) | 0 3 * * * |
Instructions
Guidance the server publishes about itself, which clients place ahead of the tool catalog so the model reads it before choosing anything.
This server publishes no instructions, or was last inspected before Glama recorded them.
Capabilities
Features and capabilities supported by this server
Protocol revision2025-11-25
| Capability | Details |
|---|---|
| tools | {
"listChanged": false
} |
| prompts | {
"listChanged": false
} |
| resources | {
"subscribe": false,
"listChanged": false
} |
| experimental | {} |
Tools
Functions exposed to the LLM to take actions
| Name | Description |
|---|---|
| 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
| Name | Description |
|---|---|
No prompts | |
Resources
Contextual data attached and managed by the client
| Name | Description |
|---|---|
No resources | |
TDQS
Scored across 13 tools
Most tools are distinct, but there is notable overlap among run-monitoring tools (get_cde_job_run_status, get_airflow_dag_run_status, list_cde_job_runs) and between generate_dag_from_contract and deploy_contract_dq_job, which both generate DAGs. This creates moderate ambiguity for an agent.
All tools follow a consistent verb_noun pattern in lowercase snake_case (e.g., list_cde_jobs, trigger_cde_job, delete_cde_job). The verbs are distinct and the pattern is highly predictable.
13 tools is well-scoped for a CDE/CDW data-quality server, covering configuration, connectivity checks, DAG generation/deployment, job lifecycle, and monitoring without unnecessary bloat.
The tool surface covers the full workflow: configure and diagnose connectivity, generate/preview/deploy data contract DAGs, manage jobs, trigger runs, monitor status, and delete jobs. No critical operations are missing for the stated domain.