Collibra Capabilities

Searches the Alation data catalog for tables and columns matching a query.

naftiko: "0.5"
info:
  label: "Alation Catalog Search"
  description: "Searches the Alation data catalog for tables and columns matching a query."
  tags:
    - data-catalog
    - alation
capability:
  exposes:
    - type: mcp
      namespace: data-catalog
      port: 8080
      tools:
        - name: get-data
          description: "Searches the Alation data catalog for tables and columns matching a query."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "alation.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: alation
      baseUri: "https://api.collibra.com/data-catalog/v1"
      authentication:
        type: bearer
        token: "$secrets.alation_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Executes an analytics query against Collibra's Amazon Redshift cluster for customer usage analytics and product telemetry.

naftiko: "0.5"
info:
  label: "Amazon Redshift Data Warehouse Query"
  description: "Executes an analytics query against Collibra's Amazon Redshift cluster for customer usage analytics and product telemetry."
  tags:
    - data-warehouse
    - amazon-redshift
    - analytics
    - usage-metrics
capability:
  exposes:
    - type: mcp
      namespace: redshift-analytics
      port: 8080
      tools:
        - name: run-usage-query
          description: "Execute a query against Amazon Redshift."
          inputParameters:
            - name: sql
              in: body
              type: string
              description: "The SQL query."
          call: "redshift.execute-statement"
          with:
            ClusterIdentifier: "collibra-analytics"
            Sql: "{{sql}}"
            Database: "product_telemetry"
  consumes:
    - type: http
      namespace: redshift
      baseUri: "https://redshift-data.us-east-1.amazonaws.com"
      authentication:
        type: aws-sigv4
        access_key: "$secrets.aws_access_key"
        secret_key: "$secrets.aws_secret_key"
      resources:
        - name: statements
          path: "/execute-statement"
          operations:
            - name: execute-statement
              method: POST

Lists files in Collibra's Amazon S3 data lake for data engineering pipelines.

naftiko: "0.5"
info:
  label: "Amazon S3 Data Lake File Listing"
  description: "Lists files in Collibra's Amazon S3 data lake for data engineering pipelines."
  tags:
    - data-lake
    - amazon-s3
    - data-engineering
    - storage
capability:
  exposes:
    - type: mcp
      namespace: data-lake
      port: 8080
      tools:
        - name: list-data-lake-files
          description: "List files in an S3 data lake prefix."
          inputParameters:
            - name: bucket
              in: body
              type: string
              description: "The S3 bucket name."
            - name: prefix
              in: body
              type: string
              description: "The S3 key prefix."
          call: "s3.list-objects"
          with:
            Bucket: "{{bucket}}"
            Prefix: "{{prefix}}"
  consumes:
    - type: http
      namespace: s3
      baseUri: "https://s3.us-east-1.amazonaws.com"
      authentication:
        type: aws-sigv4
        access_key: "$secrets.aws_access_key"
        secret_key: "$secrets.aws_secret_key"
      resources:
        - name: objects
          path: "/{{Bucket}}"
          inputParameters:
            - name: Bucket
              in: path
            - name: Prefix
              in: query
          operations:
            - name: list-objects
              method: GET

Detects data anomalies by running Databricks ML models, enriching with Collibra business context, and creating investigation tickets in Jira.

naftiko: "0.5"
info:
  label: "Anomaly Detection Governance Pipeline"
  description: "Detects data anomalies by running Databricks ML models, enriching with Collibra business context, and creating investigation tickets in Jira."
  tags:
    - data-quality
    - databricks
    - collibra
    - jira
capability:
  exposes:
    - type: mcp
      namespace: anomaly-detection-governance
      port: 8080
      tools:
        - name: run-anomaly-detection-governance-pipeli
          description: "Detects data anomalies by running Databricks ML models, enriching with Collibra business context, and creating investigation tickets in Jira."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "databricks.invoke-model"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "jira.create-issue"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: databricks
      baseUri: "https://collibra.cloud.databricks.com/serving-endpoints"
      authentication:
        type: bearer
        token: "$secrets.databricks_token"
      resources:
        - name: endpoints
          path: "/invocations"
          operations:
            - name: invoke-model
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: jira
      baseUri: "https://collibra.atlassian.net/rest/api/3"
      authentication:
        type: bearer
        token: "$secrets.jira_token"
      resources:
        - name: issues
          path: "/issue"
          operations:
            - name: create-issue
              method: POST

Checks the status of Apache Airflow DAG runs for Collibra data pipeline orchestration.

naftiko: "0.5"
info:
  label: "Apache Airflow DAG Status Check"
  description: "Checks the status of Apache Airflow DAG runs for Collibra data pipeline orchestration."
  tags:
    - orchestration
    - apache-airflow
    - data-pipeline
    - scheduling
capability:
  exposes:
    - type: mcp
      namespace: pipeline-orchestration
      port: 8080
      tools:
        - name: get-dag-status
          description: "Retrieve Apache Airflow DAG run status."
          inputParameters:
            - name: dag_id
              in: body
              type: string
              description: "The Airflow DAG ID."
          call: "airflow.get-dag-runs"
          with:
            dag_id: "{{dag_id}}"
  consumes:
    - type: http
      namespace: airflow
      baseUri: "https://collibra-airflow.internal.com/api/v1"
      authentication:
        type: basic
        username: "$secrets.airflow_user"
        password: "$secrets.airflow_password"
      resources:
        - name: dag-runs
          path: "/dags/{{dag_id}}/dagRuns"
          inputParameters:
            - name: dag_id
              in: path
          operations:
            - name: get-dag-runs
              method: GET

Queries Apache Kafka topic metadata for Collibra data event streaming, returning partition counts, consumer lag, and throughput metrics.

naftiko: "0.5"
info:
  label: "Apache Kafka Data Event Consumer"
  description: "Queries Apache Kafka topic metadata for Collibra data event streaming, returning partition counts, consumer lag, and throughput metrics."
  tags:
    - streaming
    - apache-kafka
    - data-events
    - event-driven
capability:
  exposes:
    - type: mcp
      namespace: event-streaming
      port: 8080
      tools:
        - name: get-topic-metadata
          description: "Retrieve Kafka topic metadata and consumer lag."
          inputParameters:
            - name: topic_name
              in: body
              type: string
              description: "The Kafka topic name."
          call: "kafka.get-topic"
          with:
            topic: "{{topic_name}}"
  consumes:
    - type: http
      namespace: kafka
      baseUri: "https://collibra-kafka.confluent.cloud/kafka/v3"
      authentication:
        type: basic
        username: "$secrets.kafka_api_key"
        password: "$secrets.kafka_api_secret"
      resources:
        - name: topics
          path: "/clusters/{{cluster_id}}/topics/{{topic}}"
          inputParameters:
            - name: topic
              in: path
          operations:
            - name: get-topic
              method: GET

Synchronizes API specifications with the data catalog by importing OpenAPI specs from GitHub, registering endpoints in Collibra, and notifying the platform team.

naftiko: "0.5"
info:
  label: "API Data Catalog Sync Pipeline"
  description: "Synchronizes API specifications with the data catalog by importing OpenAPI specs from GitHub, registering endpoints in Collibra, and notifying the platform team."
  tags:
    - api-governance
    - github
    - collibra
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: api-data-catalog-sync
      port: 8080
      tools:
        - name: run-api-data-catalog-sync-pipeline
          description: "Synchronizes API specifications with the data catalog by importing OpenAPI specs from GitHub, registering endpoints in Collibra, and notifying the platform team."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "github.get-repo"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: github
      baseUri: "https://api.github.com"
      authentication:
        type: bearer
        token: "$secrets.github_token"
      resources:
        - name: repos
          path: "/repos"
          operations:
            - name: get-repo
              method: GET
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Retrieves Asana project task status for Collibra cross-functional initiative tracking.

naftiko: "0.5"
info:
  label: "Asana Project Task Tracker"
  description: "Retrieves Asana project task status for Collibra cross-functional initiative tracking."
  tags:
    - project-management
    - asana
    - task-tracking
capability:
  exposes:
    - type: mcp
      namespace: project-tracking
      port: 8080
      tools:
        - name: get-project-tasks
          description: "Retrieve Asana project tasks."
          inputParameters:
            - name: project_id
              in: body
              type: string
              description: "The Asana project ID."
          call: "asana.get-tasks"
          with:
            project_id: "{{project_id}}"
  consumes:
    - type: http
      namespace: asana
      baseUri: "https://app.asana.com/api/1.0"
      authentication:
        type: bearer
        token: "$secrets.asana_token"
      resources:
        - name: tasks
          path: "/projects/{{project_id}}/tasks"
          inputParameters:
            - name: project_id
              in: path
          operations:
            - name: get-tasks
              method: GET

Searches Atlan for metadata assets by keyword for cross-catalog reference.

naftiko: "0.5"
info:
  label: "Atlan Metadata Search"
  description: "Searches Atlan for metadata assets by keyword for cross-catalog reference."
  tags:
    - metadata
    - atlan
capability:
  exposes:
    - type: mcp
      namespace: metadata
      port: 8080
      tools:
        - name: get-data
          description: "Searches Atlan for metadata assets by keyword for cross-catalog reference."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "atlan.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: atlan
      baseUri: "https://api.collibra.com/metadata/v1"
      authentication:
        type: bearer
        token: "$secrets.atlan_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Suggests business glossary terms by analyzing column names in Snowflake, matching patterns via Databricks ML, and creating draft terms in Collibra.

naftiko: "0.5"
info:
  label: "Automated Glossary Term Suggestion Pipeline"
  description: "Suggests business glossary terms by analyzing column names in Snowflake, matching patterns via Databricks ML, and creating draft terms in Collibra."
  tags:
    - data-governance
    - snowflake
    - databricks
    - collibra
capability:
  exposes:
    - type: mcp
      namespace: automated-glossary-term-suggestion
      port: 8080
      tools:
        - name: run-automated-glossary-term-suggestion-
          description: "Suggests business glossary terms by analyzing column names in Snowflake, matching patterns via Databricks ML, and creating draft terms in Collibra."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "databricks.invoke-model"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: databricks
      baseUri: "https://collibra.cloud.databricks.com/serving-endpoints"
      authentication:
        type: bearer
        token: "$secrets.databricks_token"
      resources:
        - name: endpoints
          path: "/invocations"
          operations:
            - name: invoke-model
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET

Retrieves Azure Active Directory user details for Collibra identity and access governance.

naftiko: "0.5"
info:
  label: "Azure Active Directory User Lookup"
  description: "Retrieves Azure Active Directory user details for Collibra identity and access governance."
  tags:
    - identity
    - azure-active-directory
    - access-governance
    - security
capability:
  exposes:
    - type: mcp
      namespace: identity-mgmt
      port: 8080
      tools:
        - name: get-user-details
          description: "Retrieve Azure AD user details by UPN."
          inputParameters:
            - name: user_upn
              in: body
              type: string
              description: "The user principal name."
          call: "azuread.get-user"
          with:
            user_upn: "{{user_upn}}"
  consumes:
    - type: http
      namespace: azuread
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: users
          path: "/users/{{user_upn}}"
          inputParameters:
            - name: user_upn
              in: path
          operations:
            - name: get-user
              method: GET

Triggers an Azure Data Factory pipeline for Collibra data integration workflows.

naftiko: "0.5"
info:
  label: "Azure Data Factory ETL Pipeline Trigger"
  description: "Triggers an Azure Data Factory pipeline for Collibra data integration workflows."
  tags:
    - data-integration
    - azure-data-factory
    - etl
    - data-pipeline
capability:
  exposes:
    - type: mcp
      namespace: data-pipelines
      port: 8080
      tools:
        - name: trigger-adf-pipeline
          description: "Trigger an Azure Data Factory pipeline run."
          inputParameters:
            - name: pipeline_name
              in: body
              type: string
              description: "The ADF pipeline name."
          call: "adf.create-pipeline-run"
          with:
            pipeline_name: "{{pipeline_name}}"
  consumes:
    - type: http
      namespace: adf
      baseUri: "https://management.azure.com/subscriptions/{{sub_id}}/resourceGroups/{{rg}}/providers/Microsoft.DataFactory/factories/collibra-adf"
      authentication:
        type: bearer
        token: "$secrets.azure_token"
      resources:
        - name: pipelines
          path: "/pipelines/{{pipeline_name}}/createRun"
          inputParameters:
            - name: pipeline_name
              in: path
          operations:
            - name: create-pipeline-run
              method: POST

Invokes an Azure ML endpoint for automatic data classification and sensitivity detection for Collibra data governance.

naftiko: "0.5"
info:
  label: "Azure Machine Learning Data Classification"
  description: "Invokes an Azure ML endpoint for automatic data classification and sensitivity detection for Collibra data governance."
  tags:
    - machine-learning
    - azure-machine-learning
    - data-classification
    - privacy
capability:
  exposes:
    - type: mcp
      namespace: data-classification
      port: 8080
      tools:
        - name: classify-data-asset
          description: "Run automatic data classification on a data asset."
          inputParameters:
            - name: data_asset_id
              in: body
              type: string
              description: "The data asset ID."
            - name: sample_size
              in: body
              type: integer
              description: "Number of records to sample for classification."
          call: "azureml.invoke-endpoint"
          with:
            endpoint: "data_classifier"
            inputs: "{data_asset_id: '{{data_asset_id}}', sample_size: {{sample_size}}}"
  consumes:
    - type: http
      namespace: azureml
      baseUri: "https://collibra-ml.eastus.inference.ml.azure.com"
      authentication:
        type: bearer
        token: "$secrets.azure_ml_token"
      resources:
        - name: endpoints
          path: "/score"
          operations:
            - name: invoke-endpoint
              method: POST

Retrieves data classification labels from Azure Purview for a given data asset.

naftiko: "0.5"
info:
  label: "Azure Purview Classification Lookup"
  description: "Retrieves data classification labels from Azure Purview for a given data asset."
  tags:
    - data-governance
    - azure-purview
    - classification
capability:
  exposes:
    - type: mcp
      namespace: data-governance
      port: 8080
      tools:
        - name: get-data
          description: "Retrieves data classification labels from Azure Purview for a given data asset."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "classification.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: classification
      baseUri: "https://api.collibra.com/data-governance/v1"
      authentication:
        type: bearer
        token: "$secrets.classification_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Retrieves documents from Box for Collibra governance and compliance documentation.

naftiko: "0.5"
info:
  label: "Box Document Retrieval"
  description: "Retrieves documents from Box for Collibra governance and compliance documentation."
  tags:
    - document-management
    - box
    - compliance
capability:
  exposes:
    - type: mcp
      namespace: doc-management
      port: 8080
      tools:
        - name: get-document
          description: "Retrieve a Box document by file ID."
          inputParameters:
            - name: file_id
              in: body
              type: string
              description: "The Box file ID."
          call: "box.get-file"
          with:
            file_id: "{{file_id}}"
  consumes:
    - type: http
      namespace: box
      baseUri: "https://api.box.com/2.0"
      authentication:
        type: bearer
        token: "$secrets.box_token"
      resources:
        - name: files
          path: "/files/{{file_id}}"
          inputParameters:
            - name: file_id
              in: path
          operations:
            - name: get-file
              method: GET

Governs cloud data migration by cataloging source assets in Collibra, validating targets in Snowflake, and tracking progress in Jira.

naftiko: "0.5"
info:
  label: "Cloud Data Migration Governance Pipeline"
  description: "Governs cloud data migration by cataloging source assets in Collibra, validating targets in Snowflake, and tracking progress in Jira."
  tags:
    - data-governance
    - collibra
    - snowflake
    - jira
capability:
  exposes:
    - type: mcp
      namespace: cloud-data-migration-governance
      port: 8080
      tools:
        - name: run-cloud-data-migration-governance-pip
          description: "Governs cloud data migration by cataloging source assets in Collibra, validating targets in Snowflake, and tracking progress in Jira."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "jira.create-issue"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: jira
      baseUri: "https://collibra.atlassian.net/rest/api/3"
      authentication:
        type: bearer
        token: "$secrets.jira_token"
      resources:
        - name: issues
          path: "/issue"
          operations:
            - name: create-issue
              method: POST

Retrieves Cloudflare CDN analytics for Collibra's web properties.

naftiko: "0.5"
info:
  label: "Cloudflare CDN Performance Check"
  description: "Retrieves Cloudflare CDN analytics for Collibra's web properties."
  tags:
    - infrastructure
    - cloudflare
    - cdn
    - performance
capability:
  exposes:
    - type: mcp
      namespace: cdn-analytics
      port: 8080
      tools:
        - name: get-cdn-analytics
          description: "Retrieve Cloudflare CDN analytics."
          inputParameters:
            - name: zone_id
              in: body
              type: string
              description: "The Cloudflare zone ID."
          call: "cloudflare.get-zone-analytics"
          with:
            zone_id: "{{zone_id}}"
  consumes:
    - type: http
      namespace: cloudflare
      baseUri: "https://api.cloudflare.com/client/v4"
      authentication:
        type: bearer
        token: "$secrets.cloudflare_token"
      resources:
        - name: analytics
          path: "/zones/{{zone_id}}/analytics/dashboard"
          inputParameters:
            - name: zone_id
              in: path
          operations:
            - name: get-zone-analytics
              method: GET

Searches the Collibra business glossary for terms matching a keyword query.

naftiko: "0.5"
info:
  label: "Collibra Business Glossary Search"
  description: "Searches the Collibra business glossary for terms matching a keyword query."
  tags:
    - data-governance
    - collibra
    - glossary
capability:
  exposes:
    - type: mcp
      namespace: data-governance
      port: 8080
      tools:
        - name: get-data
          description: "Searches the Collibra business glossary for terms matching a keyword query."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "glossary.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: glossary
      baseUri: "https://api.collibra.com/data-governance/v1"
      authentication:
        type: bearer
        token: "$secrets.glossary_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Lists all communities in the Collibra Data Intelligence Cloud for organizational navigation.

naftiko: "0.5"
info:
  label: "Collibra Community Listing"
  description: "Lists all communities in the Collibra Data Intelligence Cloud for organizational navigation."
  tags:
    - data-governance
    - collibra
capability:
  exposes:
    - type: mcp
      namespace: data-governance
      port: 8080
      tools:
        - name: get-data
          description: "Lists all communities in the Collibra Data Intelligence Cloud for organizational navigation."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "collibra.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://api.collibra.com/data-governance/v1"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Retrieves data dictionary definitions for a business term from the Collibra Data Intelligence Cloud.

naftiko: "0.5"
info:
  label: "Collibra Data Dictionary Lookup"
  description: "Retrieves data dictionary definitions for a business term from the Collibra Data Intelligence Cloud."
  tags:
    - data-governance
    - collibra
capability:
  exposes:
    - type: mcp
      namespace: data-governance
      port: 8080
      tools:
        - name: get-data
          description: "Retrieves data dictionary definitions for a business term from the Collibra Data Intelligence Cloud."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "collibra.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://api.collibra.com/data-governance/v1"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Retrieves data quality rule definitions and pass/fail thresholds from Collibra.

naftiko: "0.5"
info:
  label: "Collibra Data Quality Rule Lookup"
  description: "Retrieves data quality rule definitions and pass/fail thresholds from Collibra."
  tags:
    - data-quality
    - collibra
capability:
  exposes:
    - type: mcp
      namespace: data-quality
      port: 8080
      tools:
        - name: get-data
          description: "Retrieves data quality rule definitions and pass/fail thresholds from Collibra."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "collibra.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://api.collibra.com/data-quality/v1"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Retrieves data governance policy details from Collibra including scope, owner, and compliance status.

naftiko: "0.5"
info:
  label: "Collibra Policy Lookup"
  description: "Retrieves data governance policy details from Collibra including scope, owner, and compliance status."
  tags:
    - data-governance
    - collibra
    - policy
capability:
  exposes:
    - type: mcp
      namespace: data-governance
      port: 8080
      tools:
        - name: get-data
          description: "Retrieves data governance policy details from Collibra including scope, owner, and compliance status."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "policy.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: policy
      baseUri: "https://api.collibra.com/data-governance/v1"
      authentication:
        type: bearer
        token: "$secrets.policy_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Retrieves data stewardship responsibilities assigned to a user in Collibra.

naftiko: "0.5"
info:
  label: "Collibra Responsibility Lookup"
  description: "Retrieves data stewardship responsibilities assigned to a user in Collibra."
  tags:
    - data-governance
    - collibra
    - stewardship
capability:
  exposes:
    - type: mcp
      namespace: data-governance
      port: 8080
      tools:
        - name: get-data
          description: "Retrieves data stewardship responsibilities assigned to a user in Collibra."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "stewardship.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: stewardship
      baseUri: "https://api.collibra.com/data-governance/v1"
      authentication:
        type: bearer
        token: "$secrets.stewardship_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Checks the status of a data governance workflow instance in Collibra.

naftiko: "0.5"
info:
  label: "Collibra Workflow Status Check"
  description: "Checks the status of a data governance workflow instance in Collibra."
  tags:
    - data-governance
    - collibra
    - workflows
capability:
  exposes:
    - type: mcp
      namespace: data-governance
      port: 8080
      tools:
        - name: get-data
          description: "Checks the status of a data governance workflow instance in Collibra."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "workflows.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: workflows
      baseUri: "https://api.collibra.com/data-governance/v1"
      authentication:
        type: bearer
        token: "$secrets.workflows_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Extracts column-level lineage by parsing SQL from Snowflake query history, mapping relationships, and updating lineage in Collibra.

naftiko: "0.5"
info:
  label: "Column-Level Lineage Extraction Pipeline"
  description: "Extracts column-level lineage by parsing SQL from Snowflake query history, mapping relationships, and updating lineage in Collibra."
  tags:
    - data-lineage
    - snowflake
    - collibra
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: column-level-lineage-extraction
      port: 8080
      tools:
        - name: run-column-level-lineage-extraction-pip
          description: "Extracts column-level lineage by parsing SQL from Snowflake query history, mapping relationships, and updating lineage in Collibra."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Collects compliance evidence by pulling policy attestations from Collibra, data quality results from Informatica, and packaging into ServiceNow audit records.

naftiko: "0.5"
info:
  label: "Compliance Evidence Collection Pipeline"
  description: "Collects compliance evidence by pulling policy attestations from Collibra, data quality results from Informatica, and packaging into ServiceNow audit records."
  tags:
    - compliance
    - collibra
    - informatica
    - servicenow
capability:
  exposes:
    - type: mcp
      namespace: compliance-evidence-collection
      port: 8080
      tools:
        - name: run-compliance-evidence-collection-pipe
          description: "Collects compliance evidence by pulling policy attestations from Collibra, data quality results from Informatica, and packaging into ServiceNow audit records."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "informatica.run-check"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "servicenow.create-incident"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: informatica
      baseUri: "https://informatica.collibra.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.informatica_token"
      resources:
        - name: quality
          path: "/data-quality"
          operations:
            - name: run-check
              method: POST
    - type: http
      namespace: servicenow
      baseUri: "https://collibra.service-now.com/api/now/table"
      authentication:
        type: bearer
        token: "$secrets.servicenow_token"
      resources:
        - name: incidents
          path: "/incident"
          operations:
            - name: create-incident
              method: POST

Searches Collibra's Confluence knowledge base for data governance frameworks, best practices, and product documentation.

naftiko: "0.5"
info:
  label: "Confluence Knowledge Base Search"
  description: "Searches Collibra's Confluence knowledge base for data governance frameworks, best practices, and product documentation."
  tags:
    - knowledge-management
    - confluence
    - documentation
    - governance
capability:
  exposes:
    - type: mcp
      namespace: knowledge-base
      port: 8080
      tools:
        - name: search-knowledge-base
          description: "Search Confluence for governance documentation."
          inputParameters:
            - name: query
              in: body
              type: string
              description: "The search query."
          call: "confluence.search-content"
          with:
            cql: "type=page AND text~'{{query}}'"
            limit: "10"
  consumes:
    - type: http
      namespace: confluence
      baseUri: "https://collibra.atlassian.net/wiki/rest/api"
      authentication:
        type: basic
        username: "$secrets.confluence_user"
        password: "$secrets.confluence_api_token"
      resources:
        - name: search
          path: "/search"
          inputParameters:
            - name: cql
              in: query
            - name: limit
              in: query
          operations:
            - name: search-content
              method: GET

Retrieves Coupa procurement request status for Collibra vendor management.

naftiko: "0.5"
info:
  label: "Coupa Procurement Request Status"
  description: "Retrieves Coupa procurement request status for Collibra vendor management."
  tags:
    - procurement
    - coupa
    - vendor-management
capability:
  exposes:
    - type: mcp
      namespace: procurement-mgmt
      port: 8080
      tools:
        - name: get-procurement-request
          description: "Retrieve a Coupa procurement request."
          inputParameters:
            - name: request_id
              in: body
              type: string
              description: "The Coupa requisition ID."
          call: "coupa.get-requisition"
          with:
            request_id: "{{request_id}}"
  consumes:
    - type: http
      namespace: coupa
      baseUri: "https://collibra.coupahost.com/api"
      authentication:
        type: bearer
        token: "$secrets.coupa_token"
      resources:
        - name: requisitions
          path: "/requisitions/{{request_id}}"
          inputParameters:
            - name: request_id
              in: path
          operations:
            - name: get-requisition
              method: GET

Reconciles data across systems by querying Snowflake and PostgreSQL, comparing results, and logging discrepancies in ServiceNow.

naftiko: "0.5"
info:
  label: "Cross-System Data Reconciliation Pipeline"
  description: "Reconciles data across systems by querying Snowflake and PostgreSQL, comparing results, and logging discrepancies in ServiceNow."
  tags:
    - data-quality
    - snowflake
    - postgresql
    - servicenow
capability:
  exposes:
    - type: mcp
      namespace: cross-system-data-reconciliation
      port: 8080
      tools:
        - name: run-cross-system-data-reconciliation-pi
          description: "Reconciles data across systems by querying Snowflake and PostgreSQL, comparing results, and logging discrepancies in ServiceNow."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "postgresql.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "servicenow.create-incident"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: postgresql
      baseUri: "https://postgresql.collibra.com/api/v1"
      authentication:
        type: bearer
        token: "$secrets.postgresql_token"
      resources:
        - name: queries
          path: "/query"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: servicenow
      baseUri: "https://collibra.service-now.com/api/now/table"
      authentication:
        type: bearer
        token: "$secrets.servicenow_token"
      resources:
        - name: incidents
          path: "/incident"
          operations:
            - name: create-incident
              method: POST

Checks a customer's data governance maturity by querying usage telemetry from Snowflake, computing a governance score via Databricks, updating the Salesforce account, and alerting the customer success team in Microsoft Teams.

naftiko: "0.5"
info:
  label: "Customer Data Governance Health Pipeline"
  description: "Checks a customer's data governance maturity by querying usage telemetry from Snowflake, computing a governance score via Databricks, updating the Salesforce account, and alerting the customer success team in Microsoft Teams."
  tags:
    - customer-success
    - snowflake
    - databricks
    - salesforce
    - microsoft-teams
    - governance-maturity
capability:
  exposes:
    - type: mcp
      namespace: governance-health
      port: 8080
      tools:
        - name: assess-governance-health
          description: "Assess a customer's data governance health and update CRM."
          inputParameters:
            - name: account_id
              in: body
              type: string
              description: "The Salesforce account ID."
            - name: tenant_id
              in: body
              type: string
              description: "The Collibra tenant ID."
          steps:
            - name: get-usage-telemetry
              type: call
              call: "snowflake.execute-statement"
              with:
                statement: "SELECT active_users, assets_cataloged, policies_defined, stewards_assigned FROM tenant_telemetry WHERE tenant_id = '{{tenant_id}}'"
            - name: compute-governance-score
              type: call
              call: "databricks.invoke-endpoint"
              with:
                endpoint: "governance_scorer"
                inputs: "{tenant_id: '{{tenant_id}}', active_users: {{get-usage-telemetry.active_users}}, assets: {{get-usage-telemetry.assets_cataloged}}}"
            - name: update-salesforce
              type: call
              call: "salesforce.update-account"
              with:
                account_id: "{{account_id}}"
                governance_score: "{{compute-governance-score.score}}"
                governance_tier: "{{compute-governance-score.tier}}"
            - name: alert-cs-team
              type: call
              call: "msteams.send-channel-message"
              with:
                team_id: "customer_success"
                channel_id: "governance_health"
                text: "Governance health for tenant {{tenant_id}}: Score {{compute-governance-score.score}}/100 ({{compute-governance-score.tier}}). Assets: {{get-usage-telemetry.assets_cataloged}}, Users: {{get-usage-telemetry.active_users}}."
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-statement
              method: POST
    - type: http
      namespace: databricks
      baseUri: "https://collibra.cloud.databricks.com/serving-endpoints"
      authentication:
        type: bearer
        token: "$secrets.databricks_token"
      resources:
        - name: serving-endpoints
          path: "/{{endpoint}}/invocations"
          inputParameters:
            - name: endpoint
              in: path
          operations:
            - name: invoke-endpoint
              method: POST
    - type: http
      namespace: salesforce
      baseUri: "https://collibra.my.salesforce.com/services/data/v58.0"
      authentication:
        type: bearer
        token: "$secrets.salesforce_token"
      resources:
        - name: accounts
          path: "/sobjects/Account/{{account_id}}"
          inputParameters:
            - name: account_id
              in: path
          operations:
            - name: update-account
              method: PATCH
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/{{team_id}}/channels/{{channel_id}}/messages"
          inputParameters:
            - name: team_id
              in: path
            - name: channel_id
              in: path
          operations:
            - name: send-channel-message
              method: POST

Processes data access requests by validating entitlements in Collibra, provisioning access in Snowflake, and logging in ServiceNow.

naftiko: "0.5"
info:
  label: "Data Access Request Pipeline"
  description: "Processes data access requests by validating entitlements in Collibra, provisioning access in Snowflake, and logging in ServiceNow."
  tags:
    - access-governance
    - collibra
    - snowflake
    - servicenow
capability:
  exposes:
    - type: mcp
      namespace: data-access-request
      port: 8080
      tools:
        - name: run-data-access-request-pipeline
          description: "Processes data access requests by validating entitlements in Collibra, provisioning access in Snowflake, and logging in ServiceNow."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "servicenow.create-incident"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: servicenow
      baseUri: "https://collibra.service-now.com/api/now/table"
      authentication:
        type: bearer
        token: "$secrets.servicenow_token"
      resources:
        - name: incidents
          path: "/incident"
          operations:
            - name: create-incident
              method: POST

Enriches a data asset by fetching schema from Snowflake, classifying sensitivity using Azure ML, computing quality scores via Databricks, and notifying the data steward via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Data Catalog Enrichment Pipeline"
  description: "Enriches a data asset by fetching schema from Snowflake, classifying sensitivity using Azure ML, computing quality scores via Databricks, and notifying the data steward via Microsoft Teams."
  tags:
    - data-catalog
    - snowflake
    - azure-machine-learning
    - databricks
    - microsoft-teams
    - metadata-enrichment
capability:
  exposes:
    - type: mcp
      namespace: catalog-enrichment
      port: 8080
      tools:
        - name: enrich-data-asset
          description: "Run the data asset enrichment pipeline for classification, quality scoring, and notification."
          inputParameters:
            - name: data_asset_id
              in: body
              type: string
              description: "The data asset identifier."
            - name: table_name
              in: body
              type: string
              description: "The fully qualified table name."
          steps:
            - name: get-schema
              type: call
              call: "snowflake.execute-statement"
              with:
                statement: "DESCRIBE TABLE {{table_name}}"
            - name: classify-sensitivity
              type: call
              call: "azureml.invoke-endpoint"
              with:
                endpoint: "data_classifier"
                inputs: "{data_asset_id: '{{data_asset_id}}', table_name: '{{table_name}}'}"
            - name: compute-quality-score
              type: call
              call: "databricks.invoke-endpoint"
              with:
                endpoint: "quality_scorer"
                inputs: "{data_asset_id: '{{data_asset_id}}', table_name: '{{table_name}}'}"
            - name: notify-steward
              type: call
              call: "msteams.send-channel-message"
              with:
                team_id: "data_governance"
                channel_id: "catalog_updates"
                text: "Data asset {{data_asset_id}} enriched: Sensitivity {{classify-sensitivity.classification}}, Quality score {{compute-quality-score.score}}/100. Columns: {{get-schema.column_count}}."
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-statement
              method: POST
    - type: http
      namespace: azureml
      baseUri: "https://collibra-ml.eastus.inference.ml.azure.com"
      authentication:
        type: bearer
        token: "$secrets.azure_ml_token"
      resources:
        - name: endpoints
          path: "/score"
          operations:
            - name: invoke-endpoint
              method: POST
    - type: http
      namespace: databricks
      baseUri: "https://collibra.cloud.databricks.com/serving-endpoints"
      authentication:
        type: bearer
        token: "$secrets.databricks_token"
      resources:
        - name: serving-endpoints
          path: "/{{endpoint}}/invocations"
          inputParameters:
            - name: endpoint
              in: path
          operations:
            - name: invoke-endpoint
              method: POST
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/{{team_id}}/channels/{{channel_id}}/messages"
          inputParameters:
            - name: team_id
              in: path
            - name: channel_id
              in: path
          operations:
            - name: send-channel-message
              method: POST

Onboards new data sources by discovering schemas in Snowflake, registering assets in Collibra, and assigning stewards via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Data Catalog Onboarding Pipeline"
  description: "Onboards new data sources by discovering schemas in Snowflake, registering assets in Collibra, and assigning stewards via Microsoft Teams."
  tags:
    - data-catalog
    - snowflake
    - collibra
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: data-catalog-onboarding
      port: 8080
      tools:
        - name: run-data-catalog-onboarding-pipeline
          description: "Onboards new data sources by discovering schemas in Snowflake, registering assets in Collibra, and assigning stewards via Microsoft Teams."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Runs data certification workflows by triggering quality checks in Informatica, updating certification status in Collibra, and notifying owners via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Data Certification Workflow Pipeline"
  description: "Runs data certification workflows by triggering quality checks in Informatica, updating certification status in Collibra, and notifying owners via Microsoft Teams."
  tags:
    - data-governance
    - informatica
    - collibra
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: data-certification-workflow
      port: 8080
      tools:
        - name: run-data-certification-workflow-pipelin
          description: "Runs data certification workflows by triggering quality checks in Informatica, updating certification status in Collibra, and notifying owners via Microsoft Teams."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "informatica.run-check"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: informatica
      baseUri: "https://informatica.collibra.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.informatica_token"
      resources:
        - name: quality
          path: "/data-quality"
          operations:
            - name: run-check
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Automates data classification by scanning schemas in Snowflake, classifying via Azure Machine Learning, and updating Collibra assets.

naftiko: "0.5"
info:
  label: "Data Classification Automation Pipeline"
  description: "Automates data classification by scanning schemas in Snowflake, classifying via Azure Machine Learning, and updating Collibra assets."
  tags:
    - data-governance
    - snowflake
    - azure-machine-learning
    - collibra
capability:
  exposes:
    - type: mcp
      namespace: data-classification-automation
      port: 8080
      tools:
        - name: run-data-classification-automation-pipe
          description: "Automates data classification by scanning schemas in Snowflake, classifying via Azure Machine Learning, and updating Collibra assets."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "azureml.invoke-model"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: azureml
      baseUri: "https://collibra-ml.eastus.inference.ml.azure.com"
      authentication:
        type: bearer
        token: "$secrets.azure_ml_token"
      resources:
        - name: endpoints
          path: "/score"
          operations:
            - name: invoke-model
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET

Validates data contracts by comparing actual schemas in Snowflake against contracts in Collibra and alerting owners via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Data Contract Validation Pipeline"
  description: "Validates data contracts by comparing actual schemas in Snowflake against contracts in Collibra and alerting owners via Microsoft Teams."
  tags:
    - data-governance
    - snowflake
    - collibra
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: data-contract-validation
      port: 8080
      tools:
        - name: run-data-contract-validation-pipeline
          description: "Validates data contracts by comparing actual schemas in Snowflake against contracts in Collibra and alerting owners via Microsoft Teams."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Checks data domain health by pulling asset counts from Collibra, quality metrics from Informatica, and publishing results in Power BI.

naftiko: "0.5"
info:
  label: "Data Domain Health Check Pipeline"
  description: "Checks data domain health by pulling asset counts from Collibra, quality metrics from Informatica, and publishing results in Power BI."
  tags:
    - data-governance
    - collibra
    - informatica
    - power-bi
capability:
  exposes:
    - type: mcp
      namespace: data-domain-health-check
      port: 8080
      tools:
        - name: run-data-domain-health-check-pipeline
          description: "Checks data domain health by pulling asset counts from Collibra, quality metrics from Informatica, and publishing results in Power BI."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "informatica.run-check"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "powerbi.refresh-dataset"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: informatica
      baseUri: "https://informatica.collibra.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.informatica_token"
      resources:
        - name: quality
          path: "/data-quality"
          operations:
            - name: run-check
              method: POST
    - type: http
      namespace: powerbi
      baseUri: "https://api.powerbi.com/v1.0/myorg"
      authentication:
        type: bearer
        token: "$secrets.powerbi_token"
      resources:
        - name: datasets
          path: "/datasets/refresh"
          operations:
            - name: refresh-dataset
              method: POST

Conducts data ethics reviews by pulling data usage patterns from Snowflake, checking against ethical policies in Collibra, and creating review tasks in Jira.

naftiko: "0.5"
info:
  label: "Data Ethics Review Pipeline"
  description: "Conducts data ethics reviews by pulling data usage patterns from Snowflake, checking against ethical policies in Collibra, and creating review tasks in Jira."
  tags:
    - data-governance
    - snowflake
    - collibra
    - jira
capability:
  exposes:
    - type: mcp
      namespace: data-ethics-review
      port: 8080
      tools:
        - name: run-data-ethics-review-pipeline
          description: "Conducts data ethics reviews by pulling data usage patterns from Snowflake, checking against ethical policies in Collibra, and creating review tasks in Jira."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "jira.create-issue"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: jira
      baseUri: "https://collibra.atlassian.net/rest/api/3"
      authentication:
        type: bearer
        token: "$secrets.jira_token"
      resources:
        - name: issues
          path: "/issue"
          operations:
            - name: create-issue
              method: POST

Generates governance KPI dashboards by pulling metrics from Collibra, computing trends in Snowflake, and refreshing Tableau dashboards.

naftiko: "0.5"
info:
  label: "Data Governance KPI Dashboard Pipeline"
  description: "Generates governance KPI dashboards by pulling metrics from Collibra, computing trends in Snowflake, and refreshing Tableau dashboards."
  tags:
    - data-governance
    - collibra
    - snowflake
    - tableau
capability:
  exposes:
    - type: mcp
      namespace: data-governance-kpi-dashboard
      port: 8080
      tools:
        - name: run-data-governance-kpi-dashboard-pipel
          description: "Generates governance KPI dashboards by pulling metrics from Collibra, computing trends in Snowflake, and refreshing Tableau dashboards."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "tableau.refresh-workbook"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: tableau
      baseUri: "https://collibra.online.tableau.com/api/3.19"
      authentication:
        type: bearer
        token: "$secrets.tableau_token"
      resources:
        - name: workbooks
          path: "/refresh"
          operations:
            - name: refresh-workbook
              method: POST

When a data quality violation is detected, creates a ServiceNow incident, logs the violation in Snowflake for audit, notifies the data steward via Microsoft Teams, and creates a Jira ticket for remediation.

naftiko: "0.5"
info:
  label: "Data Governance Policy Violation Pipeline"
  description: "When a data quality violation is detected, creates a ServiceNow incident, logs the violation in Snowflake for audit, notifies the data steward via Microsoft Teams, and creates a Jira ticket for remediation."
  tags:
    - data-governance
    - servicenow
    - snowflake
    - microsoft-teams
    - jira
    - compliance
capability:
  exposes:
    - type: mcp
      namespace: governance-violations
      port: 8080
      tools:
        - name: escalate-policy-violation
          description: "Escalate a data governance policy violation through incident creation, logging, and remediation."
          inputParameters:
            - name: violation_type
              in: body
              type: string
              description: "The type of data governance violation."
            - name: data_asset
              in: body
              type: string
              description: "The affected data asset name."
            - name: severity
              in: body
              type: string
              description: "The violation severity (critical, high, medium, low)."
            - name: description
              in: body
              type: string
              description: "Detailed description of the violation."
          steps:
            - name: create-incident
              type: call
              call: "servicenow.create-incident"
              with:
                short_description: "DATA GOVERNANCE: {{violation_type}} on {{data_asset}}"
                urgency: "{{severity}}"
                category: "data_governance"
                description: "{{description}}"
            - name: log-violation
              type: call
              call: "snowflake.execute-statement"
              with:
                statement: "INSERT INTO governance_violations (violation_type, data_asset, severity, ticket_number, detected_at) VALUES ('{{violation_type}}', '{{data_asset}}', '{{severity}}', '{{create-incident.number}}', CURRENT_TIMESTAMP())"
            - name: notify-steward
              type: call
              call: "msteams.send-channel-message"
              with:
                team_id: "data_governance"
                channel_id: "violations"
                text: "DATA GOVERNANCE ALERT ({{severity}}): {{violation_type}} on {{data_asset}}. Ticket: {{create-incident.number}}."
            - name: create-remediation-ticket
              type: call
              call: "jira.create-issue"
              with:
                project: "DG"
                issuetype: "Bug"
                summary: "Remediate: {{violation_type}} on {{data_asset}}"
                description: "ServiceNow ticket: {{create-incident.number}}. {{description}}"
                priority: "{{severity}}"
  consumes:
    - type: http
      namespace: servicenow
      baseUri: "https://collibra.service-now.com/api/now"
      authentication:
        type: basic
        username: "$secrets.servicenow_user"
        password: "$secrets.servicenow_password"
      resources:
        - name: incidents
          path: "/table/incident"
          operations:
            - name: create-incident
              method: POST
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-statement
              method: POST
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/{{team_id}}/channels/{{channel_id}}/messages"
          inputParameters:
            - name: team_id
              in: path
            - name: channel_id
              in: path
          operations:
            - name: send-channel-message
              method: POST
    - type: http
      namespace: jira
      baseUri: "https://collibra.atlassian.net/rest/api/3"
      authentication:
        type: basic
        username: "$secrets.jira_user"
        password: "$secrets.jira_api_token"
      resources:
        - name: issues
          path: "/issue"
          operations:
            - name: create-issue
              method: POST

Analyzes data lineage impact by tracing dependencies in Collibra, checking downstream quality in Snowflake, and notifying data stewards via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Data Lineage Impact Analysis Pipeline"
  description: "Analyzes data lineage impact by tracing dependencies in Collibra, checking downstream quality in Snowflake, and notifying data stewards via Microsoft Teams."
  tags:
    - data-governance
    - collibra
    - snowflake
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: data-lineage-impact-analysis
      port: 8080
      tools:
        - name: run-data-lineage-impact-analysis-pipeli
          description: "Analyzes data lineage impact by tracing dependencies in Collibra, checking downstream quality in Snowflake, and notifying data stewards via Microsoft Teams."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Assigns data literacy training by identifying skill gaps from Collibra stewardship metrics, creating courses in Pluralsight, and notifying via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Data Literacy Training Assignment Pipeline"
  description: "Assigns data literacy training by identifying skill gaps from Collibra stewardship metrics, creating courses in Pluralsight, and notifying via Microsoft Teams."
  tags:
    - training
    - collibra
    - pluralsight
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: data-literacy-training-assignment
      port: 8080
      tools:
        - name: run-data-literacy-training-assignment-p
          description: "Assigns data literacy training by identifying skill gaps from Collibra stewardship metrics, creating courses in Pluralsight, and notifying via Microsoft Teams."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "pluralsight.assign-course"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: pluralsight
      baseUri: "https://api.pluralsight.com/v1"
      authentication:
        type: bearer
        token: "$secrets.pluralsight_token"
      resources:
        - name: courses
          path: "/courses"
          operations:
            - name: assign-course
              method: POST
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Registers data mesh domains by creating domain assets in Collibra, provisioning Snowflake schemas, and notifying domain owners via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Data Mesh Domain Registration Pipeline"
  description: "Registers data mesh domains by creating domain assets in Collibra, provisioning Snowflake schemas, and notifying domain owners via Microsoft Teams."
  tags:
    - data-mesh
    - collibra
    - snowflake
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: data-mesh-domain-registration
      port: 8080
      tools:
        - name: run-data-mesh-domain-registration-pipel
          description: "Registers data mesh domains by creating domain assets in Collibra, provisioning Snowflake schemas, and notifying domain owners via Microsoft Teams."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Handles data observability alerts from Monte Carlo by enriching with Collibra metadata and creating investigation tickets in Jira.

naftiko: "0.5"
info:
  label: "Data Observability Alert Pipeline"
  description: "Handles data observability alerts from Monte Carlo by enriching with Collibra metadata and creating investigation tickets in Jira."
  tags:
    - data-observability
    - monte-carlo
    - collibra
    - jira
capability:
  exposes:
    - type: mcp
      namespace: data-observability-alert
      port: 8080
      tools:
        - name: run-data-observability-alert-pipeline
          description: "Handles data observability alerts from Monte Carlo by enriching with Collibra metadata and creating investigation tickets in Jira."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "montecarlo.get-incident"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "jira.create-issue"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: montecarlo
      baseUri: "https://api.getmontecarlo.com/v1"
      authentication:
        type: bearer
        token: "$secrets.montecarlo_token"
      resources:
        - name: incidents
          path: "/incidents"
          operations:
            - name: get-incident
              method: GET
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: jira
      baseUri: "https://collibra.atlassian.net/rest/api/3"
      authentication:
        type: bearer
        token: "$secrets.jira_token"
      resources:
        - name: issues
          path: "/issue"
          operations:
            - name: create-issue
              method: POST

Manages data product lifecycle by registering products in Collibra, setting up delivery in Snowflake, and publishing documentation in Confluence.

naftiko: "0.5"
info:
  label: "Data Product Lifecycle Pipeline"
  description: "Manages data product lifecycle by registering products in Collibra, setting up delivery in Snowflake, and publishing documentation in Confluence."
  tags:
    - data-products
    - collibra
    - snowflake
    - confluence
capability:
  exposes:
    - type: mcp
      namespace: data-product-lifecycle
      port: 8080
      tools:
        - name: run-data-product-lifecycle-pipeline
          description: "Manages data product lifecycle by registering products in Collibra, setting up delivery in Snowflake, and publishing documentation in Confluence."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "confluence.create-page"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: confluence
      baseUri: "https://collibra.atlassian.net/wiki/rest/api"
      authentication:
        type: bearer
        token: "$secrets.confluence_token"
      resources:
        - name: content
          path: "/content"
          operations:
            - name: create-page
              method: POST

Monitors data quality by running Informatica checks, comparing against Collibra rules, and creating ServiceNow incidents for failures.

naftiko: "0.5"
info:
  label: "Data Quality Monitoring Pipeline"
  description: "Monitors data quality by running Informatica checks, comparing against Collibra rules, and creating ServiceNow incidents for failures."
  tags:
    - data-quality
    - informatica
    - collibra
    - servicenow
capability:
  exposes:
    - type: mcp
      namespace: data-quality-monitoring
      port: 8080
      tools:
        - name: run-data-quality-monitoring-pipeline
          description: "Monitors data quality by running Informatica checks, comparing against Collibra rules, and creating ServiceNow incidents for failures."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "informatica.run-check"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "servicenow.create-incident"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: informatica
      baseUri: "https://informatica.collibra.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.informatica_token"
      resources:
        - name: quality
          path: "/data-quality"
          operations:
            - name: run-check
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: servicenow
      baseUri: "https://collibra.service-now.com/api/now/table"
      authentication:
        type: bearer
        token: "$secrets.servicenow_token"
      resources:
        - name: incidents
          path: "/incident"
          operations:
            - name: create-incident
              method: POST

Generates data quality scorecards by aggregating scores from Collibra, computing trends in Snowflake, and refreshing dashboards in Tableau.

naftiko: "0.5"
info:
  label: "Data Quality Scorecard Pipeline"
  description: "Generates data quality scorecards by aggregating scores from Collibra, computing trends in Snowflake, and refreshing dashboards in Tableau."
  tags:
    - data-quality
    - collibra
    - snowflake
    - tableau
capability:
  exposes:
    - type: mcp
      namespace: data-quality-scorecard
      port: 8080
      tools:
        - name: run-data-quality-scorecard-pipeline
          description: "Generates data quality scorecards by aggregating scores from Collibra, computing trends in Snowflake, and refreshing dashboards in Tableau."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "tableau.refresh-workbook"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: tableau
      baseUri: "https://collibra.online.tableau.com/api/3.19"
      authentication:
        type: bearer
        token: "$secrets.tableau_token"
      resources:
        - name: workbooks
          path: "/refresh"
          operations:
            - name: refresh-workbook
              method: POST

Enforces data retention policies by checking expiration dates in Collibra, archiving data in S3, and updating audit records in ServiceNow.

naftiko: "0.5"
info:
  label: "Data Retention Policy Enforcement Pipeline"
  description: "Enforces data retention policies by checking expiration dates in Collibra, archiving data in S3, and updating audit records in ServiceNow."
  tags:
    - data-governance
    - collibra
    - amazon-s3
    - servicenow
capability:
  exposes:
    - type: mcp
      namespace: data-retention-policy-enforcement
      port: 8080
      tools:
        - name: run-data-retention-policy-enforcement-p
          description: "Enforces data retention policies by checking expiration dates in Collibra, archiving data in S3, and updating audit records in ServiceNow."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "s3.list-objects"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "servicenow.create-incident"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: s3
      baseUri: "https://s3.amazonaws.com"
      authentication:
        type: bearer
        token: "$secrets.aws_s3_token"
      resources:
        - name: objects
          path: "/collibra-data"
          operations:
            - name: list-objects
              method: GET
    - type: http
      namespace: servicenow
      baseUri: "https://collibra.service-now.com/api/now/table"
      authentication:
        type: bearer
        token: "$secrets.servicenow_token"
      resources:
        - name: incidents
          path: "/incident"
          operations:
            - name: create-incident
              method: POST

Manages data sharing agreements by creating contracts in Collibra, provisioning secure shares in Snowflake, and notifying parties via Microsoft Outlook.

naftiko: "0.5"
info:
  label: "Data Sharing Agreement Pipeline"
  description: "Manages data sharing agreements by creating contracts in Collibra, provisioning secure shares in Snowflake, and notifying parties via Microsoft Outlook."
  tags:
    - data-governance
    - collibra
    - snowflake
    - microsoft-outlook
capability:
  exposes:
    - type: mcp
      namespace: data-sharing-agreement
      port: 8080
      tools:
        - name: run-data-sharing-agreement-pipeline
          description: "Manages data sharing agreements by creating contracts in Collibra, provisioning secure shares in Snowflake, and notifying parties via Microsoft Outlook."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "outlook.send-email"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: outlook
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: mail
          path: "/me/sendMail"
          operations:
            - name: send-email
              method: POST

Assigns data stewardship tasks by identifying unowned assets in Collibra, matching stewards from Azure AD, and creating tasks in Jira.

naftiko: "0.5"
info:
  label: "Data Steward Task Assignment Pipeline"
  description: "Assigns data stewardship tasks by identifying unowned assets in Collibra, matching stewards from Azure AD, and creating tasks in Jira."
  tags:
    - data-governance
    - collibra
    - azure-active-directory
    - jira
capability:
  exposes:
    - type: mcp
      namespace: data-steward-task-assignment
      port: 8080
      tools:
        - name: run-data-steward-task-assignment-pipeli
          description: "Assigns data stewardship tasks by identifying unowned assets in Collibra, matching stewards from Azure AD, and creating tasks in Jira."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "azuread.get-user"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "jira.create-issue"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: azuread
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: users
          path: "/users"
          operations:
            - name: get-user
              method: GET
    - type: http
      namespace: jira
      baseUri: "https://collibra.atlassian.net/rest/api/3"
      authentication:
        type: bearer
        token: "$secrets.jira_token"
      resources:
        - name: issues
          path: "/issue"
          operations:
            - name: create-issue
              method: POST

Invokes a Databricks ML endpoint for Collibra data lineage analysis, tracing data flows across systems and identifying transformation dependencies.

naftiko: "0.5"
info:
  label: "Databricks Data Lineage Analyzer"
  description: "Invokes a Databricks ML endpoint for Collibra data lineage analysis, tracing data flows across systems and identifying transformation dependencies."
  tags:
    - data-lineage
    - databricks
    - data-governance
    - data-science
capability:
  exposes:
    - type: mcp
      namespace: lineage-analysis
      port: 8080
      tools:
        - name: analyze-data-lineage
          description: "Run data lineage analysis via Databricks."
          inputParameters:
            - name: data_asset_id
              in: body
              type: string
              description: "The data asset identifier."
            - name: depth
              in: body
              type: integer
              description: "The lineage trace depth."
          call: "databricks.invoke-endpoint"
          with:
            endpoint: "lineage_analyzer"
            inputs: "{data_asset_id: '{{data_asset_id}}', depth: {{depth}}}"
  consumes:
    - type: http
      namespace: databricks
      baseUri: "https://collibra.cloud.databricks.com/serving-endpoints"
      authentication:
        type: bearer
        token: "$secrets.databricks_token"
      resources:
        - name: serving-endpoints
          path: "/{{endpoint}}/invocations"
          inputParameters:
            - name: endpoint
              in: path
          operations:
            - name: invoke-endpoint
              method: POST

Queries Datadog for Collibra platform health metrics including API response times, throughput, and error rates.

naftiko: "0.5"
info:
  label: "Datadog Platform Health Monitor"
  description: "Queries Datadog for Collibra platform health metrics including API response times, throughput, and error rates."
  tags:
    - monitoring
    - datadog
    - platform-health
    - saas
capability:
  exposes:
    - type: mcp
      namespace: platform-monitoring
      port: 8080
      tools:
        - name: get-platform-metrics
          description: "Retrieve Datadog platform health metrics."
          inputParameters:
            - name: service_name
              in: body
              type: string
              description: "The Datadog service name."
          call: "datadog.query-metrics"
          with:
            query: "avg:trace.servlet.request.duration{service:{{service_name}}}"
            from: "now-1h"
            to: "now"
  consumes:
    - type: http
      namespace: datadog
      baseUri: "https://api.datadoghq.com/api/v1"
      authentication:
        type: apikey
        key: "$secrets.datadog_api_key"
        app_key: "$secrets.datadog_app_key"
      resources:
        - name: metrics
          path: "/query"
          inputParameters:
            - name: query
              in: query
            - name: from
              in: query
            - name: to
              in: query
          operations:
            - name: query-metrics
              method: GET

Queries Collibra's Elasticsearch cluster for data asset metadata, business glossary terms, and governance policy documents.

naftiko: "0.5"
info:
  label: "Elasticsearch Metadata Search"
  description: "Queries Collibra's Elasticsearch cluster for data asset metadata, business glossary terms, and governance policy documents."
  tags:
    - search
    - elasticsearch
    - metadata
    - data-catalog
capability:
  exposes:
    - type: mcp
      namespace: metadata-search
      port: 8080
      tools:
        - name: search-metadata
          description: "Search Elasticsearch for data asset metadata and governance documents."
          inputParameters:
            - name: query
              in: body
              type: string
              description: "The search query string."
            - name: index
              in: body
              type: string
              description: "The Elasticsearch index (data_assets, glossary, policies)."
          call: "elasticsearch.search"
          with:
            index: "{{index}}"
            q: "{{query}}"
            size: "20"
  consumes:
    - type: http
      namespace: elasticsearch
      baseUri: "https://collibra-es.elastic-cloud.com"
      authentication:
        type: basic
        username: "$secrets.elasticsearch_user"
        password: "$secrets.elasticsearch_password"
      resources:
        - name: search
          path: "/{{index}}/_search"
          inputParameters:
            - name: index
              in: path
            - name: q
              in: query
            - name: size
              in: query
          operations:
            - name: search
              method: GET

On new hire creation in Workday, opens a ServiceNow onboarding ticket, provisions a SharePoint folder, and sends a Microsoft Teams welcome message to the new data governance specialist.

naftiko: "0.5"
info:
  label: "Employee Onboarding Orchestrator"
  description: "On new hire creation in Workday, opens a ServiceNow onboarding ticket, provisions a SharePoint folder, and sends a Microsoft Teams welcome message to the new data governance specialist."
  tags:
    - hr
    - onboarding
    - workday
    - servicenow
    - sharepoint
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: hr-onboarding
      port: 8080
      tools:
        - name: trigger-onboarding
          description: "Given a Workday employee ID and start date, orchestrate the full onboarding sequence."
          inputParameters:
            - name: workday_employee_id
              in: body
              type: string
              description: "The Workday worker ID for the new hire."
            - name: start_date
              in: body
              type: string
              description: "The employee start date in YYYY-MM-DD format."
            - name: department
              in: body
              type: string
              description: "The department the new hire is joining."
          steps:
            - name: get-employee
              type: call
              call: "workday.get-worker"
              with:
                worker_id: "{{workday_employee_id}}"
            - name: open-ticket
              type: call
              call: "servicenow.create-incident"
              with:
                short_description: "New hire onboarding: {{get-employee.full_name}}"
                category: "hr_onboarding"
                assigned_group: "IT_Onboarding"
                description: "Onboarding for {{get-employee.full_name}} starting {{start_date}} in {{department}}."
            - name: provision-folder
              type: call
              call: "sharepoint.create-folder"
              with:
                site_id: "collibra_onboarding_site"
                folder_path: "OnboardingDocs/{{department}}/{{get-employee.full_name}}_{{start_date}}"
            - name: send-welcome
              type: call
              call: "msteams.send-message"
              with:
                recipient_upn: "{{get-employee.work_email}}"
                text: "Welcome to Collibra, {{get-employee.first_name}}! Your onboarding ticket is {{open-ticket.number}}. Documents are at {{provision-folder.url}}."
  consumes:
    - type: http
      namespace: workday
      baseUri: "https://wd2-impl-services1.workday.com/ccx/api/v1"
      authentication:
        type: bearer
        token: "$secrets.workday_token"
      resources:
        - name: workers
          path: "/workers/{{worker_id}}"
          inputParameters:
            - name: worker_id
              in: path
          operations:
            - name: get-worker
              method: GET
    - type: http
      namespace: servicenow
      baseUri: "https://collibra.service-now.com/api/now"
      authentication:
        type: basic
        username: "$secrets.servicenow_user"
        password: "$secrets.servicenow_password"
      resources:
        - name: incidents
          path: "/table/incident"
          operations:
            - name: create-incident
              method: POST
    - type: http
      namespace: sharepoint
      baseUri: "https://graph.microsoft.com/v1.0/sites"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: drive-items
          path: "/{{site_id}}/drive/root:/{{folder_path}}"
          inputParameters:
            - name: site_id
              in: path
            - name: folder_path
              in: path
          operations:
            - name: create-folder
              method: POST
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: messages
          path: "/users/{{recipient_upn}}/sendMail"
          inputParameters:
            - name: recipient_upn
              in: path
          operations:
            - name: send-message
              method: POST

Retrieves Figma design file metadata for Collibra product UX/UI design.

naftiko: "0.5"
info:
  label: "Figma Product Design Asset Lookup"
  description: "Retrieves Figma design file metadata for Collibra product UX/UI design."
  tags:
    - design
    - figma
    - product-design
    - ux
capability:
  exposes:
    - type: mcp
      namespace: design-assets
      port: 8080
      tools:
        - name: get-figma-file
          description: "Retrieve Figma design file metadata."
          inputParameters:
            - name: file_key
              in: body
              type: string
              description: "The Figma file key."
          call: "figma.get-file"
          with:
            file_key: "{{file_key}}"
  consumes:
    - type: http
      namespace: figma
      baseUri: "https://api.figma.com/v1"
      authentication:
        type: bearer
        token: "$secrets.figma_token"
      resources:
        - name: files
          path: "/files/{{file_key}}"
          inputParameters:
            - name: file_key
              in: path
          operations:
            - name: get-file
              method: GET

Processes GDPR data subject requests by locating personal data in Collibra catalog, executing deletion in Snowflake, and confirming via Microsoft Outlook.

naftiko: "0.5"
info:
  label: "GDPR Data Subject Request Pipeline"
  description: "Processes GDPR data subject requests by locating personal data in Collibra catalog, executing deletion in Snowflake, and confirming via Microsoft Outlook."
  tags:
    - privacy
    - gdpr
    - collibra
    - snowflake
    - microsoft-outlook
capability:
  exposes:
    - type: mcp
      namespace: gdpr-data-subject-request
      port: 8080
      tools:
        - name: run-gdpr-data-subject-request-pipeline
          description: "Processes GDPR data subject requests by locating personal data in Collibra catalog, executing deletion in Snowflake, and confirming via Microsoft Outlook."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "outlook.send-email"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: outlook
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: mail
          path: "/me/sendMail"
          operations:
            - name: send-email
              method: POST

Triggers a GitHub Actions workflow for Collibra application builds.

naftiko: "0.5"
info:
  label: "GitHub Actions CI Workflow Trigger"
  description: "Triggers a GitHub Actions workflow for Collibra application builds."
  tags:
    - ci-cd
    - github-actions
    - development
    - automation
capability:
  exposes:
    - type: mcp
      namespace: ci-workflows
      port: 8080
      tools:
        - name: trigger-github-workflow
          description: "Trigger a GitHub Actions workflow dispatch event."
          inputParameters:
            - name: repo
              in: body
              type: string
              description: "The repository name."
            - name: workflow_id
              in: body
              type: string
              description: "The workflow file name or ID."
            - name: ref
              in: body
              type: string
              description: "The git reference."
          call: "github.dispatch-workflow"
          with:
            repo: "{{repo}}"
            workflow_id: "{{workflow_id}}"
            ref: "{{ref}}"
  consumes:
    - type: http
      namespace: github
      baseUri: "https://api.github.com"
      authentication:
        type: bearer
        token: "$secrets.github_token"
      resources:
        - name: workflow-dispatches
          path: "/repos/{{repo}}/actions/workflows/{{workflow_id}}/dispatches"
          inputParameters:
            - name: repo
              in: path
            - name: workflow_id
              in: path
          operations:
            - name: dispatch-workflow
              method: POST

Retrieves open pull request details for a Collibra GitHub repository.

naftiko: "0.5"
info:
  label: "GitHub Repository PR Status"
  description: "Retrieves open pull request details for a Collibra GitHub repository."
  tags:
    - development
    - github
    - code-review
capability:
  exposes:
    - type: mcp
      namespace: dev-workflow
      port: 8080
      tools:
        - name: get-repo-prs
          description: "List open pull requests for a GitHub repository."
          inputParameters:
            - name: repo_name
              in: body
              type: string
              description: "The repository name (org/repo format)."
          call: "github.list-prs"
          with:
            repo: "{{repo_name}}"
            state: "open"
  consumes:
    - type: http
      namespace: github
      baseUri: "https://api.github.com"
      authentication:
        type: bearer
        token: "$secrets.github_token"
      resources:
        - name: pull-requests
          path: "/repos/{{repo}}/pulls"
          inputParameters:
            - name: repo
              in: path
            - name: state
              in: query
          operations:
            - name: list-prs
              method: GET

Uploads documents to Google Drive for Collibra team collaboration.

naftiko: "0.5"
info:
  label: "Google Drive Document Upload"
  description: "Uploads documents to Google Drive for Collibra team collaboration."
  tags:
    - document-management
    - google-drive
    - collaboration
capability:
  exposes:
    - type: mcp
      namespace: file-storage
      port: 8080
      tools:
        - name: upload-to-drive
          description: "Upload a file to Google Drive."
          inputParameters:
            - name: folder_id
              in: body
              type: string
              description: "The Google Drive folder ID."
            - name: file_name
              in: body
              type: string
              description: "The file name."
          call: "gdrive.upload-file"
          with:
            folder_id: "{{folder_id}}"
            name: "{{file_name}}"
  consumes:
    - type: http
      namespace: gdrive
      baseUri: "https://www.googleapis.com/upload/drive/v3"
      authentication:
        type: bearer
        token: "$secrets.google_drive_token"
      resources:
        - name: files
          path: "/files"
          operations:
            - name: upload-file
              method: POST

Queries Grafana dashboards for Collibra infrastructure and application monitoring metrics.

naftiko: "0.5"
info:
  label: "Grafana Monitoring Dashboard Query"
  description: "Queries Grafana dashboards for Collibra infrastructure and application monitoring metrics."
  tags:
    - monitoring
    - grafana
    - dashboards
    - observability
capability:
  exposes:
    - type: mcp
      namespace: monitoring-dashboards
      port: 8080
      tools:
        - name: get-dashboard-data
          description: "Retrieve Grafana dashboard data."
          inputParameters:
            - name: dashboard_uid
              in: body
              type: string
              description: "The Grafana dashboard UID."
          call: "grafana.get-dashboard"
          with:
            uid: "{{dashboard_uid}}"
  consumes:
    - type: http
      namespace: grafana
      baseUri: "https://collibra-grafana.internal.com/api"
      authentication:
        type: bearer
        token: "$secrets.grafana_token"
      resources:
        - name: dashboards
          path: "/dashboards/uid/{{uid}}"
          inputParameters:
            - name: uid
              in: path
          operations:
            - name: get-dashboard
              method: GET

Retrieves validation results from a Great Expectations checkpoint run.

naftiko: "0.5"
info:
  label: "Great Expectations Validation Result Lookup"
  description: "Retrieves validation results from a Great Expectations checkpoint run."
  tags:
    - data-quality
    - great-expectations
capability:
  exposes:
    - type: mcp
      namespace: data-quality
      port: 8080
      tools:
        - name: get-data
          description: "Retrieves validation results from a Great Expectations checkpoint run."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "greatexpectations.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: greatexpectations
      baseUri: "https://api.collibra.com/data-quality/v1"
      authentication:
        type: bearer
        token: "$secrets.great_expectations_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Searches HubSpot for marketing leads for Collibra product marketing.

naftiko: "0.5"
info:
  label: "HubSpot Marketing Lead Search"
  description: "Searches HubSpot for marketing leads for Collibra product marketing."
  tags:
    - marketing
    - hubspot
    - lead-management
capability:
  exposes:
    - type: mcp
      namespace: marketing-leads
      port: 8080
      tools:
        - name: search-lead
          description: "Search for a HubSpot lead by email."
          inputParameters:
            - name: email
              in: body
              type: string
              description: "The email to search."
          call: "hubspot.search-contacts"
          with:
            filterGroups: "[{filters:[{propertyName:'email',operator:'EQ',value:'{{email}}'}]}]"
  consumes:
    - type: http
      namespace: hubspot
      baseUri: "https://api.hubapi.com/crm/v3"
      authentication:
        type: bearer
        token: "$secrets.hubspot_token"
      resources:
        - name: contacts-search
          path: "/objects/contacts/search"
          operations:
            - name: search-contacts
              method: POST

Triages data incident impact by correlating ServiceNow incidents with Collibra data assets and lineage, then notifying affected stewards via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Incident Data Impact Triage Pipeline"
  description: "Triages data incident impact by correlating ServiceNow incidents with Collibra data assets and lineage, then notifying affected stewards via Microsoft Teams."
  tags:
    - data-governance
    - servicenow
    - collibra
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: incident-data-impact-triage
      port: 8080
      tools:
        - name: run-incident-data-impact-triage-pipelin
          description: "Triages data incident impact by correlating ServiceNow incidents with Collibra data assets and lineage, then notifying affected stewards via Microsoft Teams."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "servicenow.create-incident"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: servicenow
      baseUri: "https://collibra.service-now.com/api/now/table"
      authentication:
        type: bearer
        token: "$secrets.servicenow_token"
      resources:
        - name: incidents
          path: "/incident"
          operations:
            - name: create-incident
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Checks the status of Informatica data integration pipelines for Collibra enterprise data flows.

naftiko: "0.5"
info:
  label: "Informatica Data Pipeline Status"
  description: "Checks the status of Informatica data integration pipelines for Collibra enterprise data flows."
  tags:
    - data-integration
    - informatica
    - etl
    - data-pipeline
capability:
  exposes:
    - type: mcp
      namespace: data-integration
      port: 8080
      tools:
        - name: get-pipeline-status
          description: "Retrieve Informatica pipeline job status."
          inputParameters:
            - name: job_id
              in: body
              type: string
              description: "The Informatica job ID."
          call: "informatica.get-job-status"
          with:
            job_id: "{{job_id}}"
  consumes:
    - type: http
      namespace: informatica
      baseUri: "https://dm-us.informaticacloud.com/saas/api/v2"
      authentication:
        type: bearer
        token: "$secrets.informatica_token"
      resources:
        - name: jobs
          path: "/job/{{job_id}}"
          inputParameters:
            - name: job_id
              in: path
          operations:
            - name: get-job-status
              method: GET

Retrieves the latest data quality score from Informatica Data Quality for a dataset.

naftiko: "0.5"
info:
  label: "Informatica Data Quality Score Lookup"
  description: "Retrieves the latest data quality score from Informatica Data Quality for a dataset."
  tags:
    - data-quality
    - informatica
capability:
  exposes:
    - type: mcp
      namespace: data-quality
      port: 8080
      tools:
        - name: get-data
          description: "Retrieves the latest data quality score from Informatica Data Quality for a dataset."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "informatica.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: informatica
      baseUri: "https://api.collibra.com/data-quality/v1"
      authentication:
        type: bearer
        token: "$secrets.informatica_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Retrieves Jira sprint progress for Collibra product and engineering teams.

naftiko: "0.5"
info:
  label: "Jira Sprint Progress Tracker"
  description: "Retrieves Jira sprint progress for Collibra product and engineering teams."
  tags:
    - project-management
    - jira
    - agile
    - sprint
capability:
  exposes:
    - type: mcp
      namespace: agile-tracking
      port: 8080
      tools:
        - name: get-sprint-progress
          description: "Retrieve Jira sprint progress."
          inputParameters:
            - name: board_id
              in: body
              type: string
              description: "The Jira board ID."
            - name: sprint_id
              in: body
              type: string
              description: "The sprint ID."
          call: "jira.get-sprint"
          with:
            board_id: "{{board_id}}"
            sprint_id: "{{sprint_id}}"
  consumes:
    - type: http
      namespace: jira
      baseUri: "https://collibra.atlassian.net/rest/agile/1.0"
      authentication:
        type: basic
        username: "$secrets.jira_user"
        password: "$secrets.jira_api_token"
      resources:
        - name: sprints
          path: "/board/{{board_id}}/sprint/{{sprint_id}}"
          inputParameters:
            - name: board_id
              in: path
            - name: sprint_id
              in: path
          operations:
            - name: get-sprint
              method: GET

Checks the health status of Kubernetes deployments in Azure Kubernetes Service for Collibra microservices.

naftiko: "0.5"
info:
  label: "Kubernetes Deployment Health Check"
  description: "Checks the health status of Kubernetes deployments in Azure Kubernetes Service for Collibra microservices."
  tags:
    - infrastructure
    - azure-kubernetes-service
    - kubernetes
    - container-management
capability:
  exposes:
    - type: mcp
      namespace: k8s-ops
      port: 8080
      tools:
        - name: check-deployment-health
          description: "Check AKS deployment health status."
          inputParameters:
            - name: namespace
              in: body
              type: string
              description: "The Kubernetes namespace."
            - name: deployment_name
              in: body
              type: string
              description: "The deployment name."
          call: "aks.get-deployment"
          with:
            namespace: "{{namespace}}"
            deployment: "{{deployment_name}}"
  consumes:
    - type: http
      namespace: aks
      baseUri: "https://collibra-aks.eastus.azmk8s.io"
      authentication:
        type: bearer
        token: "$secrets.aks_token"
      resources:
        - name: deployments
          path: "/apis/apps/v1/namespaces/{{namespace}}/deployments/{{deployment}}"
          inputParameters:
            - name: namespace
              in: path
            - name: deployment
              in: path
          operations:
            - name: get-deployment
              method: GET

Retrieves LinkedIn employer branding analytics for Collibra talent acquisition.

naftiko: "0.5"
info:
  label: "LinkedIn Employer Brand Analytics"
  description: "Retrieves LinkedIn employer branding analytics for Collibra talent acquisition."
  tags:
    - recruiting
    - linkedin
    - employer-branding
    - talent-acquisition
capability:
  exposes:
    - type: mcp
      namespace: employer-branding
      port: 8080
      tools:
        - name: get-employer-analytics
          description: "Retrieve LinkedIn employer brand analytics."
          inputParameters:
            - name: organization_id
              in: body
              type: string
              description: "The LinkedIn organization ID."
          call: "linkedin.get-org-analytics"
          with:
            organization_id: "{{organization_id}}"
  consumes:
    - type: http
      namespace: linkedin
      baseUri: "https://api.linkedin.com/v2"
      authentication:
        type: bearer
        token: "$secrets.linkedin_token"
      resources:
        - name: org-analytics
          path: "/organizationalEntityFollowerStatistics?q=organizationalEntity&organizationalEntity=urn:li:organization:{{organization_id}}"
          inputParameters:
            - name: organization_id
              in: path
          operations:
            - name: get-org-analytics
              method: GET

Matches master data records by querying Snowflake, running fuzzy matching in Databricks, and updating the golden record in Collibra.

naftiko: "0.5"
info:
  label: "Master Data Matching Pipeline"
  description: "Matches master data records by querying Snowflake, running fuzzy matching in Databricks, and updating the golden record in Collibra."
  tags:
    - master-data
    - snowflake
    - databricks
    - collibra
capability:
  exposes:
    - type: mcp
      namespace: master-data-matching
      port: 8080
      tools:
        - name: run-master-data-matching-pipeline
          description: "Matches master data records by querying Snowflake, running fuzzy matching in Databricks, and updating the golden record in Collibra."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "databricks.invoke-model"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: databricks
      baseUri: "https://collibra.cloud.databricks.com/serving-endpoints"
      authentication:
        type: bearer
        token: "$secrets.databricks_token"
      resources:
        - name: endpoints
          path: "/invocations"
          operations:
            - name: invoke-model
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET

Synchronizes metadata between Collibra and Snowflake by extracting schema changes, updating catalog assets, and notifying stewards via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Metadata Synchronization Pipeline"
  description: "Synchronizes metadata between Collibra and Snowflake by extracting schema changes, updating catalog assets, and notifying stewards via Microsoft Teams."
  tags:
    - metadata
    - collibra
    - snowflake
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: metadata-synchronization
      port: 8080
      tools:
        - name: run-metadata-synchronization-pipeline
          description: "Synchronizes metadata between Collibra and Snowflake by extracting schema changes, updating catalog assets, and notifying stewards via Microsoft Teams."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Triggers a Power Automate flow for Collibra business process automation.

naftiko: "0.5"
info:
  label: "Microsoft Power Automate Flow Trigger"
  description: "Triggers a Power Automate flow for Collibra business process automation."
  tags:
    - automation
    - microsoft-power-automate
    - business-process
capability:
  exposes:
    - type: mcp
      namespace: process-automation
      port: 8080
      tools:
        - name: trigger-power-automate-flow
          description: "Trigger a Power Automate flow."
          inputParameters:
            - name: flow_id
              in: body
              type: string
              description: "The Power Automate flow ID."
            - name: trigger_body
              in: body
              type: object
              description: "The JSON body for the flow trigger."
          call: "powerautomate.trigger-flow"
          with:
            flow_id: "{{flow_id}}"
            body: "{{trigger_body}}"
  consumes:
    - type: http
      namespace: powerautomate
      baseUri: "https://api.flow.microsoft.com/providers/Microsoft.ProcessSimple/environments"
      authentication:
        type: bearer
        token: "$secrets.powerautomate_token"
      resources:
        - name: flows
          path: "/{{environment_id}}/flows/{{flow_id}}/triggers/manual/run"
          inputParameters:
            - name: flow_id
              in: path
            - name: environment_id
              in: path
          operations:
            - name: trigger-flow
              method: POST

Sends a formatted notification to a Microsoft Teams channel for Collibra team communications.

naftiko: "0.5"
info:
  label: "Microsoft Teams Channel Notification"
  description: "Sends a formatted notification to a Microsoft Teams channel for Collibra team communications."
  tags:
    - communications
    - microsoft-teams
    - notifications
capability:
  exposes:
    - type: mcp
      namespace: team-comms
      port: 8080
      tools:
        - name: send-teams-notification
          description: "Send a notification to a Microsoft Teams channel."
          inputParameters:
            - name: team_id
              in: body
              type: string
              description: "The Teams team ID."
            - name: channel_id
              in: body
              type: string
              description: "The Teams channel ID."
            - name: message
              in: body
              type: string
              description: "The message text."
          call: "msteams.send-channel-message"
          with:
            team_id: "{{team_id}}"
            channel_id: "{{channel_id}}"
            text: "{{message}}"
  consumes:
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/{{team_id}}/channels/{{channel_id}}/messages"
          inputParameters:
            - name: team_id
              in: path
            - name: channel_id
              in: path
          operations:
            - name: send-channel-message
              method: POST

Retrieves data observability incident details from Monte Carlo including severity and affected tables.

naftiko: "0.5"
info:
  label: "Monte Carlo Data Incident Lookup"
  description: "Retrieves data observability incident details from Monte Carlo including severity and affected tables."
  tags:
    - data-observability
    - monte-carlo
capability:
  exposes:
    - type: mcp
      namespace: data-observability
      port: 8080
      tools:
        - name: get-data
          description: "Retrieves data observability incident details from Monte Carlo including severity and affected tables."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "montecarlo.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: montecarlo
      baseUri: "https://api.collibra.com/data-observability/v1"
      authentication:
        type: bearer
        token: "$secrets.monte_carlo_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Checks the status of MuleSoft API integrations for Collibra's enterprise API management.

naftiko: "0.5"
info:
  label: "MuleSoft API Integration Status"
  description: "Checks the status of MuleSoft API integrations for Collibra's enterprise API management."
  tags:
    - integration
    - mulesoft
    - api-management
capability:
  exposes:
    - type: mcp
      namespace: api-integration
      port: 8080
      tools:
        - name: get-api-status
          description: "Retrieve MuleSoft API deployment status."
          inputParameters:
            - name: environment_id
              in: body
              type: string
              description: "The Anypoint environment ID."
            - name: api_id
              in: body
              type: string
              description: "The API ID."
          call: "mulesoft.get-api-status"
          with:
            environment_id: "{{environment_id}}"
            api_id: "{{api_id}}"
  consumes:
    - type: http
      namespace: mulesoft
      baseUri: "https://anypoint.mulesoft.com/apimanager/api/v1"
      authentication:
        type: bearer
        token: "$secrets.mulesoft_token"
      resources:
        - name: apis
          path: "/organizations/{{org_id}}/environments/{{environment_id}}/apis/{{api_id}}"
          inputParameters:
            - name: environment_id
              in: path
            - name: api_id
              in: path
          operations:
            - name: get-api-status
              method: GET

Triggers n8n workflow automations for Collibra data governance process automation.

naftiko: "0.5"
info:
  label: "n8n Workflow Automation Trigger"
  description: "Triggers n8n workflow automations for Collibra data governance process automation."
  tags:
    - automation
    - n8n
    - workflow
    - data-governance
capability:
  exposes:
    - type: mcp
      namespace: workflow-automation
      port: 8080
      tools:
        - name: trigger-n8n-workflow
          description: "Trigger an n8n workflow via webhook."
          inputParameters:
            - name: webhook_id
              in: body
              type: string
              description: "The n8n webhook ID."
            - name: payload
              in: body
              type: object
              description: "The webhook payload."
          call: "n8n.trigger-webhook"
          with:
            webhook_id: "{{webhook_id}}"
            payload: "{{payload}}"
  consumes:
    - type: http
      namespace: n8n
      baseUri: "https://collibra-n8n.internal.com"
      authentication:
        type: bearer
        token: "$secrets.n8n_token"
      resources:
        - name: webhooks
          path: "/webhook/{{webhook_id}}"
          inputParameters:
            - name: webhook_id
              in: path
          operations:
            - name: trigger-webhook
              method: POST

Queries New Relic for Collibra SaaS platform health metrics.

naftiko: "0.5"
info:
  label: "New Relic SaaS Platform Monitor"
  description: "Queries New Relic for Collibra SaaS platform health metrics."
  tags:
    - monitoring
    - new-relic
    - saas
    - platform-health
capability:
  exposes:
    - type: mcp
      namespace: apm-monitoring
      port: 8080
      tools:
        - name: get-app-health
          description: "Retrieve New Relic application health."
          inputParameters:
            - name: app_id
              in: body
              type: string
              description: "The New Relic application ID."
          call: "newrelic.get-app-metrics"
          with:
            app_id: "{{app_id}}"
  consumes:
    - type: http
      namespace: newrelic
      baseUri: "https://api.newrelic.com/v2"
      authentication:
        type: apikey
        key: "$secrets.newrelic_api_key"
      resources:
        - name: applications
          path: "/applications/{{app_id}}.json"
          inputParameters:
            - name: app_id
              in: path
          operations:
            - name: get-app-metrics
              method: GET

Retrieves user group membership from Okta for data access governance.

naftiko: "0.5"
info:
  label: "Okta User Group Lookup"
  description: "Retrieves user group membership from Okta for data access governance."
  tags:
    - identity
    - okta
    - access-governance
capability:
  exposes:
    - type: mcp
      namespace: identity
      port: 8080
      tools:
        - name: get-data
          description: "Retrieves user group membership from Okta for data access governance."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "accessgovernance.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: accessgovernance
      baseUri: "https://api.collibra.com/identity/v1"
      authentication:
        type: bearer
        token: "$secrets.access_governance_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Queries Oracle Database for table and column metadata for Collibra data cataloging integration.

naftiko: "0.5"
info:
  label: "Oracle Database Schema Discovery"
  description: "Queries Oracle Database for table and column metadata for Collibra data cataloging integration."
  tags:
    - database
    - oracle
    - metadata
    - schema-discovery
capability:
  exposes:
    - type: mcp
      namespace: oracle-discovery
      port: 8080
      tools:
        - name: discover-oracle-schema
          description: "Query Oracle for schema metadata."
          inputParameters:
            - name: schema_name
              in: body
              type: string
              description: "The Oracle schema name."
          call: "oracle-db.get-schema"
          with:
            schema_name: "{{schema_name}}"
  consumes:
    - type: http
      namespace: oracle-db
      baseUri: "https://collibra-ords.oracle.com/ords/v1"
      authentication:
        type: basic
        username: "$secrets.oracle_user"
        password: "$secrets.oracle_password"
      resources:
        - name: metadata
          path: "/metadata/schemas/{{schema_name}}/tables"
          inputParameters:
            - name: schema_name
              in: path
          operations:
            - name: get-schema
              method: GET

Retrieves active security alerts from Palo Alto Networks for Collibra's network perimeter.

naftiko: "0.5"
info:
  label: "Palo Alto Networks Security Alert Check"
  description: "Retrieves active security alerts from Palo Alto Networks for Collibra's network perimeter."
  tags:
    - security
    - palo-alto-networks
    - network
    - threat-detection
capability:
  exposes:
    - type: mcp
      namespace: network-security
      port: 8080
      tools:
        - name: get-security-alerts
          description: "Retrieve active security alerts."
          inputParameters:
            - name: severity
              in: body
              type: string
              description: "Alert severity filter."
          call: "paloalto.get-alerts"
          with:
            severity: "{{severity}}"
  consumes:
    - type: http
      namespace: paloalto
      baseUri: "https://collibra-fw.paloaltonetworks.com/restapi/v10.2"
      authentication:
        type: apikey
        key: "$secrets.paloalto_api_key"
      resources:
        - name: alerts
          path: "/Incidents"
          inputParameters:
            - name: severity
              in: query
          operations:
            - name: get-alerts
              method: GET

Assigns Pluralsight training courses to Collibra team members for data governance professional development.

naftiko: "0.5"
info:
  label: "Pluralsight Training Assignment"
  description: "Assigns Pluralsight training courses to Collibra team members for data governance professional development."
  tags:
    - training
    - pluralsight
    - learning
    - professional-development
capability:
  exposes:
    - type: mcp
      namespace: learning-mgmt
      port: 8080
      tools:
        - name: assign-training-course
          description: "Assign a Pluralsight training course."
          inputParameters:
            - name: user_email
              in: body
              type: string
              description: "The team member's email."
            - name: course_id
              in: body
              type: string
              description: "The Pluralsight course ID."
          call: "pluralsight.assign-course"
          with:
            email: "{{user_email}}"
            course_id: "{{course_id}}"
  consumes:
    - type: http
      namespace: pluralsight
      baseUri: "https://api.pluralsight.com/api/v1"
      authentication:
        type: bearer
        token: "$secrets.pluralsight_token"
      resources:
        - name: assignments
          path: "/assignments"
          operations:
            - name: assign-course
              method: POST

Queries PostgreSQL information_schema for table and column metadata for Collibra data cataloging and schema documentation.

naftiko: "0.5"
info:
  label: "PostgreSQL Database Schema Inspector"
  description: "Queries PostgreSQL information_schema for table and column metadata for Collibra data cataloging and schema documentation."
  tags:
    - database
    - postgresql
    - metadata
    - schema-discovery
capability:
  exposes:
    - type: mcp
      namespace: schema-discovery
      port: 8080
      tools:
        - name: inspect-schema
          description: "Query PostgreSQL information_schema for table and column metadata."
          inputParameters:
            - name: schema_name
              in: body
              type: string
              description: "The database schema name."
          call: "postgresql.query"
          with:
            sql: "SELECT table_name, column_name, data_type, is_nullable FROM information_schema.columns WHERE table_schema = '{{schema_name}}' ORDER BY table_name, ordinal_position"
  consumes:
    - type: http
      namespace: postgresql
      baseUri: "https://collibra-pgrest.internal.com"
      authentication:
        type: bearer
        token: "$secrets.pgrest_token"
      resources:
        - name: queries
          path: "/rpc/query"
          operations:
            - name: query
              method: POST

Triggers a Power BI dataset refresh for Collibra data governance and quality dashboards.

naftiko: "0.5"
info:
  label: "Power BI Governance Dashboard Refresh"
  description: "Triggers a Power BI dataset refresh for Collibra data governance and quality dashboards."
  tags:
    - analytics
    - power-bi
    - dashboards
    - data-governance
capability:
  exposes:
    - type: mcp
      namespace: bi-dashboards
      port: 8080
      tools:
        - name: refresh-governance-dashboard
          description: "Trigger a Power BI dataset refresh."
          inputParameters:
            - name: group_id
              in: body
              type: string
              description: "The Power BI workspace ID."
            - name: dataset_id
              in: body
              type: string
              description: "The dataset ID."
          call: "powerbi.refresh-dataset"
          with:
            group_id: "{{group_id}}"
            dataset_id: "{{dataset_id}}"
  consumes:
    - type: http
      namespace: powerbi
      baseUri: "https://api.powerbi.com/v1.0/myorg"
      authentication:
        type: bearer
        token: "$secrets.powerbi_token"
      resources:
        - name: datasets
          path: "/groups/{{group_id}}/datasets/{{dataset_id}}/refreshes"
          inputParameters:
            - name: group_id
              in: path
            - name: dataset_id
              in: path
          operations:
            - name: refresh-dataset
              method: POST

Conducts privacy impact assessments by scanning data assets in Collibra, classifying PII via Azure ML, and filing results in ServiceNow.

naftiko: "0.5"
info:
  label: "Privacy Impact Assessment Pipeline"
  description: "Conducts privacy impact assessments by scanning data assets in Collibra, classifying PII via Azure ML, and filing results in ServiceNow."
  tags:
    - privacy
    - collibra
    - azure-machine-learning
    - servicenow
capability:
  exposes:
    - type: mcp
      namespace: privacy-impact-assessment
      port: 8080
      tools:
        - name: run-privacy-impact-assessment-pipeline
          description: "Conducts privacy impact assessments by scanning data assets in Collibra, classifying PII via Azure ML, and filing results in ServiceNow."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "azureml.invoke-model"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "servicenow.create-incident"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: azureml
      baseUri: "https://collibra-ml.eastus.inference.ml.azure.com"
      authentication:
        type: bearer
        token: "$secrets.azure_ml_token"
      resources:
        - name: endpoints
          path: "/score"
          operations:
            - name: invoke-model
              method: POST
    - type: http
      namespace: servicenow
      baseUri: "https://collibra.service-now.com/api/now/table"
      authentication:
        type: bearer
        token: "$secrets.servicenow_token"
      resources:
        - name: incidents
          path: "/incident"
          operations:
            - name: create-incident
              method: POST

Validates reference data by comparing Collibra reference datasets against Snowflake actual values and reporting mismatches in Jira.

naftiko: "0.5"
info:
  label: "Reference Data Validation Pipeline"
  description: "Validates reference data by comparing Collibra reference datasets against Snowflake actual values and reporting mismatches in Jira."
  tags:
    - data-quality
    - collibra
    - snowflake
    - jira
capability:
  exposes:
    - type: mcp
      namespace: reference-data-validation
      port: 8080
      tools:
        - name: run-reference-data-validation-pipeline
          description: "Validates reference data by comparing Collibra reference datasets against Snowflake actual values and reporting mismatches in Jira."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "jira.create-issue"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: jira
      baseUri: "https://collibra.atlassian.net/rest/api/3"
      authentication:
        type: bearer
        token: "$secrets.jira_token"
      resources:
        - name: issues
          path: "/issue"
          operations:
            - name: create-issue
              method: POST

Maps regulatory requirements to data assets by querying Collibra policies, linking to Snowflake tables, and generating compliance reports in Power BI.

naftiko: "0.5"
info:
  label: "Regulatory Data Mapping Pipeline"
  description: "Maps regulatory requirements to data assets by querying Collibra policies, linking to Snowflake tables, and generating compliance reports in Power BI."
  tags:
    - compliance
    - collibra
    - snowflake
    - power-bi
capability:
  exposes:
    - type: mcp
      namespace: regulatory-data-mapping
      port: 8080
      tools:
        - name: run-regulatory-data-mapping-pipeline
          description: "Maps regulatory requirements to data assets by querying Collibra policies, linking to Snowflake tables, and generating compliance reports in Power BI."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "collibra.get-assets"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "snowflake.execute-query"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "powerbi.refresh-dataset"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: powerbi
      baseUri: "https://api.powerbi.com/v1.0/myorg"
      authentication:
        type: bearer
        token: "$secrets.powerbi_token"
      resources:
        - name: datasets
          path: "/datasets/refresh"
          operations:
            - name: refresh-dataset
              method: POST

Retrieves a Salesforce account record by ID for Collibra customer management.

naftiko: "0.5"
info:
  label: "Salesforce Account Lookup"
  description: "Retrieves a Salesforce account record by ID for Collibra customer management."
  tags:
    - crm
    - salesforce
    - account-management
capability:
  exposes:
    - type: mcp
      namespace: crm-accounts
      port: 8080
      tools:
        - name: get-account
          description: "Retrieve a Salesforce account by ID."
          inputParameters:
            - name: account_id
              in: body
              type: string
              description: "The Salesforce account ID."
          call: "salesforce.get-account"
          with:
            account_id: "{{account_id}}"
  consumes:
    - type: http
      namespace: salesforce
      baseUri: "https://collibra.my.salesforce.com/services/data/v58.0"
      authentication:
        type: bearer
        token: "$secrets.salesforce_token"
      resources:
        - name: accounts
          path: "/sobjects/Account/{{account_id}}"
          inputParameters:
            - name: account_id
              in: path
          operations:
            - name: get-account
              method: GET

Retrieves Salesforce Marketing Cloud campaign analytics for Collibra product marketing and customer engagement.

naftiko: "0.5"
info:
  label: "Salesforce Marketing Cloud Campaign Analytics"
  description: "Retrieves Salesforce Marketing Cloud campaign analytics for Collibra product marketing and customer engagement."
  tags:
    - marketing
    - salesforce-marketing-cloud
    - campaigns
    - customer-engagement
capability:
  exposes:
    - type: mcp
      namespace: marketing-analytics
      port: 8080
      tools:
        - name: get-campaign-analytics
          description: "Retrieve campaign analytics from Salesforce Marketing Cloud."
          inputParameters:
            - name: campaign_id
              in: body
              type: string
              description: "The campaign ID."
          call: "sfmc.get-campaign-stats"
          with:
            campaign_id: "{{campaign_id}}"
  consumes:
    - type: http
      namespace: sfmc
      baseUri: "https://collibra.rest.marketingcloudapis.com/interaction/v1"
      authentication:
        type: bearer
        token: "$secrets.sfmc_token"
      resources:
        - name: campaigns
          path: "/interactions/{{campaign_id}}/stats"
          inputParameters:
            - name: campaign_id
              in: path
          operations:
            - name: get-campaign-stats
              method: GET

Queries SAP HANA metadata catalog and returns table schemas, column definitions, and data lineage information for Collibra data governance integration.

naftiko: "0.5"
info:
  label: "SAP HANA Data Catalog Sync"
  description: "Queries SAP HANA metadata catalog and returns table schemas, column definitions, and data lineage information for Collibra data governance integration."
  tags:
    - data-governance
    - sap-hana
    - metadata
    - data-catalog
capability:
  exposes:
    - type: mcp
      namespace: catalog-sync
      port: 8080
      tools:
        - name: get-hana-metadata
          description: "Query SAP HANA metadata catalog for table and column definitions."
          inputParameters:
            - name: schema_name
              in: body
              type: string
              description: "The SAP HANA schema name."
          call: "sap-hana.get-schema-metadata"
          with:
            schema_name: "{{schema_name}}"
  consumes:
    - type: http
      namespace: sap-hana
      baseUri: "https://collibra-hana.sap.com/api/v1"
      authentication:
        type: basic
        username: "$secrets.sap_hana_user"
        password: "$secrets.sap_hana_password"
      resources:
        - name: metadata
          path: "/catalog/schemas/{{schema_name}}/tables"
          inputParameters:
            - name: schema_name
              in: path
          operations:
            - name: get-schema-metadata
              method: GET

Assesses schema change impact by detecting changes in Snowflake, tracing lineage in Collibra, and alerting affected teams via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Schema Change Impact Pipeline"
  description: "Assesses schema change impact by detecting changes in Snowflake, tracing lineage in Collibra, and alerting affected teams via Microsoft Teams."
  tags:
    - data-governance
    - snowflake
    - collibra
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: schema-change-impact
      port: 8080
      tools:
        - name: run-schema-change-impact-pipeline
          description: "Assesses schema change impact by detecting changes in Snowflake, tracing lineage in Collibra, and alerting affected teams via Microsoft Teams."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "msteams.send-notification"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/messages"
          operations:
            - name: send-notification
              method: POST

Discovers sensitive data by scanning Snowflake schemas, classifying with Azure ML, and registering findings in Collibra.

naftiko: "0.5"
info:
  label: "Sensitive Data Discovery Pipeline"
  description: "Discovers sensitive data by scanning Snowflake schemas, classifying with Azure ML, and registering findings in Collibra."
  tags:
    - data-governance
    - snowflake
    - azure-machine-learning
    - collibra
capability:
  exposes:
    - type: mcp
      namespace: sensitive-data-discovery
      port: 8080
      tools:
        - name: run-sensitive-data-discovery-pipeline
          description: "Discovers sensitive data by scanning Snowflake schemas, classifying with Azure ML, and registering findings in Collibra."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "azureml.invoke-model"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: azureml
      baseUri: "https://collibra-ml.eastus.inference.ml.azure.com"
      authentication:
        type: bearer
        token: "$secrets.azure_ml_token"
      resources:
        - name: endpoints
          path: "/score"
          operations:
            - name: invoke-model
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET

Fetches the current status of a ServiceNow incident for Collibra IT support.

naftiko: "0.5"
info:
  label: "ServiceNow Incident Status"
  description: "Fetches the current status of a ServiceNow incident for Collibra IT support."
  tags:
    - it-support
    - servicenow
    - incident-management
capability:
  exposes:
    - type: mcp
      namespace: itsm-incidents
      port: 8080
      tools:
        - name: get-incident-status
          description: "Retrieve a ServiceNow incident by number."
          inputParameters:
            - name: incident_number
              in: body
              type: string
              description: "The ServiceNow incident number."
          call: "servicenow.get-incident"
          with:
            number: "{{incident_number}}"
  consumes:
    - type: http
      namespace: servicenow
      baseUri: "https://collibra.service-now.com/api/now"
      authentication:
        type: basic
        username: "$secrets.servicenow_user"
        password: "$secrets.servicenow_password"
      resources:
        - name: incidents
          path: "/table/incident"
          inputParameters:
            - name: number
              in: query
          operations:
            - name: get-incident
              method: GET

Searches Collibra SharePoint for data governance policy documents and framework templates.

naftiko: "0.5"
info:
  label: "SharePoint Governance Policy Library"
  description: "Searches Collibra SharePoint for data governance policy documents and framework templates."
  tags:
    - document-management
    - sharepoint
    - governance-policies
capability:
  exposes:
    - type: mcp
      namespace: policy-library
      port: 8080
      tools:
        - name: search-policy-docs
          description: "Search SharePoint for governance policy documents."
          inputParameters:
            - name: query
              in: body
              type: string
              description: "The search query."
            - name: site_id
              in: body
              type: string
              description: "The SharePoint site ID."
          call: "sharepoint.search-docs"
          with:
            site_id: "{{site_id}}"
            query: "{{query}}"
  consumes:
    - type: http
      namespace: sharepoint
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: search
          path: "/sites/{{site_id}}/drive/root/search(q='{{query}}')"
          inputParameters:
            - name: site_id
              in: path
            - name: query
              in: path
          operations:
            - name: search-docs
              method: GET

Executes a data profiling query against Snowflake to retrieve column statistics and distributions.

naftiko: "0.5"
info:
  label: "Snowflake Data Profile Query"
  description: "Executes a data profiling query against Snowflake to retrieve column statistics and distributions."
  tags:
    - data-quality
    - snowflake
capability:
  exposes:
    - type: mcp
      namespace: data-quality
      port: 8080
      tools:
        - name: get-data
          description: "Executes a data profiling query against Snowflake to retrieve column statistics and distributions."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary identifier."
          call: "snowflake.get-data"
          with:
            input_id: "{{input_id}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://api.collibra.com/data-quality/v1"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: data
          path: "/{{input_id}}"
          inputParameters:
            - name: input_id
              in: path
          operations:
            - name: get-data
              method: GET

Executes a Snowflake SQL query against Collibra's analytics warehouse for data quality metrics, governance compliance scores, and metadata analysis.

naftiko: "0.5"
info:
  label: "Snowflake Data Quality Query"
  description: "Executes a Snowflake SQL query against Collibra's analytics warehouse for data quality metrics, governance compliance scores, and metadata analysis."
  tags:
    - data-warehouse
    - snowflake
    - data-quality
    - governance-analytics
capability:
  exposes:
    - type: mcp
      namespace: data-quality-warehouse
      port: 8080
      tools:
        - name: query-data-quality
          description: "Execute a Snowflake query for data quality analytics."
          inputParameters:
            - name: sql
              in: body
              type: string
              description: "The SQL query to execute."
          call: "snowflake.execute-statement"
          with:
            statement: "{{sql}}"
            warehouse: "COLLIBRA_ANALYTICS_WH"
            database: "COLLIBRA_GOVERNANCE"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-statement
              method: POST

Queries SolarWinds for network performance at Collibra data centers and office locations.

naftiko: "0.5"
info:
  label: "SolarWinds Network Performance Check"
  description: "Queries SolarWinds for network performance at Collibra data centers and office locations."
  tags:
    - network-monitoring
    - solarwinds
    - infrastructure
capability:
  exposes:
    - type: mcp
      namespace: network-monitoring
      port: 8080
      tools:
        - name: get-network-health
          description: "Retrieve SolarWinds network node performance."
          inputParameters:
            - name: node_id
              in: body
              type: string
              description: "The SolarWinds node ID."
          call: "solarwinds.get-node"
          with:
            node_id: "{{node_id}}"
  consumes:
    - type: http
      namespace: solarwinds
      baseUri: "https://collibra-solarwinds.com:17778/SolarWinds/InformationService/v3/Json"
      authentication:
        type: basic
        username: "$secrets.solarwinds_user"
        password: "$secrets.solarwinds_password"
      resources:
        - name: nodes
          path: "/Query"
          inputParameters:
            - name: node_id
              in: query
          operations:
            - name: get-node
              method: GET

Queries SQL Server information_schema for Collibra data catalog metadata discovery and profiling.

naftiko: "0.5"
info:
  label: "SQL Server Schema Inspector"
  description: "Queries SQL Server information_schema for Collibra data catalog metadata discovery and profiling."
  tags:
    - database
    - sql-server
    - metadata
    - data-profiling
capability:
  exposes:
    - type: mcp
      namespace: sqlserver-discovery
      port: 8080
      tools:
        - name: inspect-sqlserver-schema
          description: "Query SQL Server metadata for tables and columns."
          inputParameters:
            - name: database_name
              in: body
              type: string
              description: "The database name."
            - name: schema_name
              in: body
              type: string
              description: "The schema name."
          call: "sqlserver.query-metadata"
          with:
            database: "{{database_name}}"
            schema: "{{schema_name}}"
  consumes:
    - type: http
      namespace: sqlserver
      baseUri: "https://collibra-sqlrest.internal.com"
      authentication:
        type: bearer
        token: "$secrets.sqlserver_token"
      resources:
        - name: metadata
          path: "/databases/{{database}}/schemas/{{schema}}/tables"
          inputParameters:
            - name: database
              in: path
            - name: schema
              in: path
          operations:
            - name: query-metadata
              method: GET

Triggers a Tableau workbook refresh for Collibra data quality monitoring dashboards.

naftiko: "0.5"
info:
  label: "Tableau Data Quality Dashboard"
  description: "Triggers a Tableau workbook refresh for Collibra data quality monitoring dashboards."
  tags:
    - analytics
    - tableau
    - data-quality
    - monitoring
capability:
  exposes:
    - type: mcp
      namespace: analytics-dashboards
      port: 8080
      tools:
        - name: refresh-quality-dashboard
          description: "Trigger a Tableau workbook refresh."
          inputParameters:
            - name: workbook_id
              in: body
              type: string
              description: "The Tableau workbook ID."
          call: "tableau.refresh-workbook"
          with:
            workbook_id: "{{workbook_id}}"
  consumes:
    - type: http
      namespace: tableau
      baseUri: "https://collibra.online.tableau.com/api/3.19"
      authentication:
        type: bearer
        token: "$secrets.tableau_token"
      resources:
        - name: workbooks
          path: "/sites/{{site_id}}/workbooks/{{workbook_id}}/refresh"
          inputParameters:
            - name: workbook_id
              in: path
            - name: site_id
              in: path
          operations:
            - name: refresh-workbook
              method: POST

Assesses third-party data sources by profiling in Snowflake, evaluating quality in Informatica, and recording findings in Collibra.

naftiko: "0.5"
info:
  label: "Third-Party Data Assessment Pipeline"
  description: "Assesses third-party data sources by profiling in Snowflake, evaluating quality in Informatica, and recording findings in Collibra."
  tags:
    - data-governance
    - snowflake
    - informatica
    - collibra
capability:
  exposes:
    - type: mcp
      namespace: third-party-data-assessment
      port: 8080
      tools:
        - name: run-third-party-data-assessment-pipelin
          description: "Assesses third-party data sources by profiling in Snowflake, evaluating quality in Informatica, and recording findings in Collibra."
          inputParameters:
            - name: input_id
              in: body
              type: string
              description: "The primary input identifier."
            - name: scope
              in: body
              type: string
              description: "The processing scope."
          steps:
            - name: fetch-data
              type: call
              call: "snowflake.execute-query"
              with:
                input_id: "{{input_id}}"
            - name: process-data
              type: call
              call: "informatica.run-check"
              with:
                data: "{{fetch-data.result}}"
            - name: deliver-results
              type: call
              call: "collibra.get-assets"
              with:
                data: "{{process-data.result}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://collibra.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: informatica
      baseUri: "https://informatica.collibra.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.informatica_token"
      resources:
        - name: quality
          path: "/data-quality"
          operations:
            - name: run-check
              method: POST
    - type: http
      namespace: collibra
      baseUri: "https://collibra.com/rest/2.0"
      authentication:
        type: bearer
        token: "$secrets.collibra_token"
      resources:
        - name: assets
          path: "/assets"
          operations:
            - name: get-assets
              method: GET

Retrieves a Workday employee profile by worker ID for Collibra HR operations.

naftiko: "0.5"
info:
  label: "Workday Employee Profile Lookup"
  description: "Retrieves a Workday employee profile by worker ID for Collibra HR operations."
  tags:
    - hr
    - workday
    - employee-management
capability:
  exposes:
    - type: mcp
      namespace: hr-employees
      port: 8080
      tools:
        - name: get-employee-profile
          description: "Retrieve a Workday employee profile."
          inputParameters:
            - name: worker_id
              in: body
              type: string
              description: "The Workday worker ID."
          call: "workday.get-worker"
          with:
            worker_id: "{{worker_id}}"
  consumes:
    - type: http
      namespace: workday
      baseUri: "https://wd2-impl-services1.workday.com/ccx/api/v1"
      authentication:
        type: bearer
        token: "$secrets.workday_token"
      resources:
        - name: workers
          path: "/workers/{{worker_id}}"
          inputParameters:
            - name: worker_id
              in: path
          operations:
            - name: get-worker
              method: GET

Creates Zoom webinars for Collibra customer education and product training sessions.

naftiko: "0.5"
info:
  label: "Zoom Customer Webinar Scheduler"
  description: "Creates Zoom webinars for Collibra customer education and product training sessions."
  tags:
    - communications
    - zoom
    - webinars
    - customer-education
capability:
  exposes:
    - type: mcp
      namespace: webinar-mgmt
      port: 8080
      tools:
        - name: create-zoom-webinar
          description: "Create a Zoom webinar."
          inputParameters:
            - name: topic
              in: body
              type: string
              description: "The webinar topic."
            - name: start_time
              in: body
              type: string
              description: "Start time in ISO 8601 format."
            - name: duration
              in: body
              type: integer
              description: "Duration in minutes."
          call: "zoom.create-webinar"
          with:
            topic: "{{topic}}"
            start_time: "{{start_time}}"
            duration: "{{duration}}"
  consumes:
    - type: http
      namespace: zoom
      baseUri: "https://api.zoom.us/v2"
      authentication:
        type: bearer
        token: "$secrets.zoom_token"
      resources:
        - name: webinars
          path: "/users/me/webinars"
          operations:
            - name: create-webinar
              method: POST