iiRecord
Agentic AI Atlas · CDC Pipeline Validation
workflow:cdc-pipeline-validationa5c.ai
II.
Workflow JSON

workflow:cdc-pipeline-validation

Structured · live

CDC Pipeline Validation json

Inspect the normalized record payload exactly as the atlas UI reads it.

File · workflows/workflows/workflows-data-eng-deep.yamlCluster · workflows
Record JSON
{
  "id": "workflow:cdc-pipeline-validation",
  "_kind": "Workflow",
  "_file": "workflows/workflows/workflows-data-eng-deep.yaml",
  "_cluster": "workflows",
  "attributes": {
    "displayName": "CDC Pipeline Validation",
    "workflowKind": "data",
    "triggerType": "event-driven",
    "typicalCadence": "per-change",
    "complexity": "cross-team",
    "description": "Validates change data capture pipelines after source schema changes or\nconnector upgrades — verifying Debezium/CDC connector configuration\ncorrectness, testing schema evolution compatibility, measuring consumer lag\nagainst SLA thresholds, checking exactly-once delivery guarantees,\nvalidating dead-letter queue handling, and confirming end-to-end data\nconsistency between source and sink. Excludes CDC architecture design.\n"
  },
  "outgoingEdges": [
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "role:data-scientist",
      "kind": "involves_role",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "role:database-administrator",
      "kind": "involves_role",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "role:platform-engineer",
      "kind": "involves_role",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "skill-area:python-data-pipelines",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "domain:data-science",
      "kind": "applies_to_domain",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "domain:databases",
      "kind": "applies_to_domain",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "responsibility:data-quality-monitoring",
      "kind": "triggers_responsibility",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "responsibility:respond-incidents",
      "kind": "triggers_responsibility",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "org-unit:data-platform-team",
      "kind": "performed_by_org_unit",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "org-unit:database-team",
      "kind": "performed_by_org_unit",
      "attributes": {}
    }
  ],
  "incomingEdges": []
}