flowchart TD
    subgraph Step1["1. Airflow DAG Authoring"]
        DAG["<b>Business Airflow DAG</b><br/><code>SecureDataprocCreateClusterOperator(</code><br/>&nbsp;&nbsp;<code>cluster_tier=ClusterTier.STANDARD_ANALYTICS,</code><br/>&nbsp;&nbsp;<code>team='marketing', cost_center='cc-10492'</code><br/><code>)</code>"]
    end

    subgraph Step2["2. Platform Governance Operator"]
        PluginOp["<b>SecureDataprocCreateClusterOperator</b><br/><i>(Subclass of native DataprocCreateClusterOperator)</i>"]
        Defaults["🔒 <b>1. Injects Enterprise Defaults</b><br/>Private IP Only, Standard Subnet, Dedicated SA, CMEK Key"]
        Sizing["📐 <b>2. Expands Sizing Tier</b><br/>Translates <code>STANDARD_ANALYTICS</code> to CPU, RAM, & Worker Disks"]
        Guardrail["🛡️ <b>3. Validates Platform Guardrails</b><br/>Checks Worker Quotas (&le;20), FinOps Labels, & Idle TTL (&le;2h)"]
    end

    subgraph Step3["3. Enforcement Outcomes"]
        Pass["✅ <b>Compliant Execution (GCP API)</b><br/>Provisions Hardened Dataproc Cluster<br/><i>Zero Zombie Clusters • 100% FinOps Attributed</i>"]
        Fail["❌ <b>Fail-Fast Interception (&lt;0.01s)</b><br/>Catches Violations in Local Tests & CI<br/><i>Prints Actionable Box Banner with Fix Steps</i>"]
    end

    %% Flow Connections
    DAG -->|"DAG imports & instantiates operator"| PluginOp
    PluginOp --> Defaults
    Defaults --> Sizing
    Sizing --> Guardrail

    Guardrail -->|"Passes all policies"| Pass
    Guardrail -.->|"Policy violation detected"| Fail

    %% Color Coding & Styling (Optimized for Dark & Light Themes)
    classDef dagCard fill:#0f172a,stroke:#38bdf8,stroke-width:2px,color:#f8fafc;
    classDef operatorCard fill:#1e1b4b,stroke:#c084fc,stroke-width:2px,color:#f8fafc;
    classDef engineCard fill:#111827,stroke:#818cf8,stroke-width:1.5px,color:#f8fafc;
    classDef passCard fill:#064e3b,stroke:#34d399,stroke-width:2px,color:#f8fafc;
    classDef failCard fill:#450a0a,stroke:#f87171,stroke-width:2px,color:#f8fafc;

    class DAG dagCard;
    class PluginOp operatorCard;
    class Defaults,Sizing,Guardrail engineCard;
    class Pass passCard;
    class Fail failCard;

    style Step1 fill:none,stroke:#38bdf8,stroke-width:2px,stroke-dasharray: 5 5;
    style Step2 fill:none,stroke:#c084fc,stroke-width:2px,stroke-dasharray: 5 5;
    style Step3 fill:none,stroke:#64748b,stroke-width:2px,stroke-dasharray: 5 5;

    linkStyle default stroke:#94a3b8,stroke-width:2px;

flowchart TD
    subgraph PlatformRepo["🏛️ Central Platform Repo: airflow-platform-plugins (platform_team_repo)"]
        P_Dev["<b>Platform Team Engineers</b><br/><i>Maintain Rules, Tiers, & Operators</i>"]
        P_PR["<b>Platform PR</b><br/>Security / Quota / Tier Updates"]
        P_CI["<b>Platform CI/CD Pipeline</b><br/>1. Linter & Typecheck (Ruff/Mypy)<br/>2. Guardrail Tests (Security/Quotas)<br/>3. Plugin Registration Test"]
        P_GCS_Sync["<b>GCS Plugins Sync</b><br/><code>gs://$BUCKET/plugins/</code>"]
        P_Registry["<b>Google Cloud Artifact Registry</b><br/><i>(Optional Enterprise PyPI Wheel)</i>"]
    end

    subgraph DAGRepo["💼 Domain Team Repos: analytics-dags (data_team_repo)"]
        D_Dev["<b>Data Engineers / DAG Authors</b><br/><i>Write Business Data Pipelines</i>"]
        D_Local["<b>Local Fast Development</b><br/>Zero-Install PYTHONPATH Linking (<0.01s)"]
        D_PR["<b>Domain DAG PR</b><br/>New / Modified Airflow DAGs"]
        D_CI["<b>DAG CI/CD Pipeline</b><br/>1. DagBag Parsing & Integrity Tests<br/>2. Platform Policy Compliance Audit<br/>3. Transformation Unit Tests"]
        D_Merge["<b>Merge to Main Branch</b>"]
    end

    subgraph DeploymentTargets["☁️ Managed Service for Apache Airflow (formerly Cloud Composer) Environments"]
        GCS_Dev["<b>Dev Airflow GCS Bucket</b><br/><code>gs://composer-dev/plugins/ & dags/</code>"]
        GCS_Prod["<b>Prod Airflow GCS Bucket</b><br/><code>gs://composer-prod/plugins/ & dags/</code>"]
        ComposerRuntime["<b>Managed Airflow Runtime</b><br/>Executes Governed Dataproc Workloads"]
    end

    P_Dev --> P_PR
    P_PR --> P_CI
    P_CI -->|"PR Approved & Merged"| P_GCS_Sync
    P_CI -.->|"Optional Build"| P_Registry
    P_GCS_Sync -->|"Auto-Sync Plugins"| GCS_Dev
    P_GCS_Sync -.->|"Promote via Release Tag"| GCS_Prod

    P_Dev -.->|"Zero-Install PYTHONPATH"| D_Local
    D_Dev --> D_Local
    D_Local --> D_PR
    D_PR --> D_CI
    P_Registry -.->|"Resolves PyPI Dependency"| D_CI
    D_CI -->|"PR Approved & Merged"| D_Merge
    D_Merge -->|"Deploy DAGs to Dev"| GCS_Dev
    D_Merge -.->|"Deploy DAGs to Prod"| GCS_Prod

    GCS_Dev --> ComposerRuntime
    GCS_Prod --> ComposerRuntime

    %% Color Coding & Styling (Optimized for Dark & Light Themes)
    classDef platformRepo fill:#1e1b4b,stroke:#c084fc,stroke-width:2px,color:#f8fafc;
    classDef dagRepo fill:#0f172a,stroke:#38bdf8,stroke-width:2px,color:#f8fafc;
    classDef deployTargets fill:#172554,stroke:#60a5fa,stroke-width:2px,color:#f8fafc;
    classDef runtimeTarget fill:#042f2e,stroke:#2dd4bf,stroke-width:2px,color:#f8fafc;

    class P_Dev,P_PR,P_CI,P_GCS_Sync,P_Registry platformRepo;
    class D_Dev,D_Local,D_PR,D_CI,D_Merge dagRepo;
    class GCS_Dev,GCS_Prod deployTargets;
    class ComposerRuntime runtimeTarget;

    style PlatformRepo fill:none,stroke:#c084fc,stroke-width:2px,stroke-dasharray: 5 5;
    style DAGRepo fill:none,stroke:#38bdf8,stroke-width:2px,stroke-dasharray: 5 5;
    style DeploymentTargets fill:none,stroke:#60a5fa,stroke-width:2px,stroke-dasharray: 5 5;

    linkStyle default stroke:#94a3b8,stroke-width:2px;