feat - Add data-jobs alert monitor type support (DataDog#3330)

Co-authored-by: ci.datadog-api-spec <packages@datadoghq.com>

Author: api-clients-generation-pipeline[bot]

.generator/schemas/v1/openapi.yaml

@@ -8069,6 +8069,36 @@ components:
         - data_source
         - query
       type: object
+    MonitorFormulaAndFunctionDataJobsQueryDefinition:
+      description: A formula and functions data jobs query.
+      properties:
+        job_type:
+          description: |-
+            The type of job being monitored. Valid values include:
+            `databricks.job`, `spark.application`, `airflow.dag`,
+            `dbt.job`, `dbt.model`, `dbt.test`, `glue.job`.
+            Custom job types are supported with the `custom.ol.` prefix.
+          example: "databricks.job"
+          type: string
+        jobs_query:
+          description: Filter expression used to select the jobs to monitor.
+          example: "job_name:smoke*"
+          type: string
+        name:
+          description: Name of the query for use in formulas. Must be `run_query`.
+          example: "run_query"
+          type: string
+        query_dialect:
+          description: |-
+            Query dialect for data jobs queries. Currently only `metric` is supported.
+          example: "metric"
+          type: string
+      required:
+        - name
+        - jobs_query
+        - job_type
+        - query_dialect
+      type: object
     MonitorFormulaAndFunctionDataQualityDataSource:
       description: Data source for data quality queries.
       enum:
@@ -8375,6 +8405,7 @@ components:
         - $ref: "#/components/schemas/MonitorFormulaAndFunctionEventQueryDefinition"
         - $ref: "#/components/schemas/MonitorFormulaAndFunctionCostQueryDefinition"
         - $ref: "#/components/schemas/MonitorFormulaAndFunctionDataQualityQueryDefinition"
+        - $ref: "#/components/schemas/MonitorFormulaAndFunctionDataJobsQueryDefinition"
         - $ref: "#/components/schemas/MonitorFormulaAndFunctionAggregateAugmentedQueryDefinition"
         - $ref: "#/components/schemas/MonitorFormulaAndFunctionAggregateFilteredQueryDefinition"
     MonitorFormulaAndFunctionReferenceTableColumn:
@@ -9207,6 +9238,7 @@ components:
         - "cost alert"
         - "data-quality alert"
         - "network-path alert"
+        - "data-jobs alert"
       example: "query alert"
       type: string
       x-enum-varnames:
@@ -9231,6 +9263,7 @@ components:
         - COST_ALERT
         - DATA_QUALITY_ALERT
         - NETWORK_PATH_ALERT
+        - DATA_JOBS_ALERT
     MonitorUpdateRequest:
       description: Object describing a monitor update request.
       properties:

cassettes/features/v1/monitors/Create-a-Data-Jobs-monitor-returns-OK-response.frozen

@@ -0,0 +1 @@
+2026-05-14T10:58:54.153Z

cassettes/features/v1/monitors/Create-a-Data-Jobs-monitor-returns-OK-response.yml

@@ -0,0 +1,29 @@
+# Create a Data Jobs monitor returns "OK" response
+
+require "datadog_api_client"
+api_instance = DatadogAPIClient::V1::MonitorsAPI.new
+
+body = DatadogAPIClient::V1::Monitor.new({
+  name: "Example-Monitor",
+  type: DatadogAPIClient::V1::MonitorType::DATA_JOBS_ALERT,
+  query: 'formula("failed_runs(run_query)").by(job_name,workspace_name).last(10d) > 0',
+  message: "Data jobs alert triggered",
+  tags: [
+    "test:examplemonitor",
+    "env:ci",
+  ],
+  options: DatadogAPIClient::V1::MonitorOptions.new({
+    thresholds: DatadogAPIClient::V1::MonitorThresholds.new({
+      critical: 0,
+    }),
+    variables: [
+      DatadogAPIClient::V1::MonitorFormulaAndFunctionDataJobsQueryDefinition.new({
+        name: "run_query",
+        jobs_query: "job_name:*",
+        job_type: "databricks.job",
+        query_dialect: "metric",
+      }),
+    ],
+  }),
+})
+p api_instance.create_monitor(body)

examples/v1/monitors/CreateMonitor_2589528326.rb

@@ -42,6 +42,15 @@ Feature: Monitors
     When the request is sent
     Then the response status is 200 OK
 
+  @team:DataDog/monitor-app
+  Scenario: Create a Data Jobs monitor returns "OK" response
+    Given new "CreateMonitor" request
+    And body with value {"name": "{{ unique }}", "type": "data-jobs alert", "query": "formula(\"failed_runs(run_query)\").by(job_name,workspace_name).last(10d) > 0", "message": "Data jobs alert triggered", "tags": ["test:{{ unique_lower_alnum }}", "env:ci"], "options": {"thresholds": {"critical": 0}, "variables": [{"name": "run_query", "jobs_query": "job_name:*", "job_type": "databricks.job", "query_dialect": "metric"}]}}
+    When the request is sent
+    Then the response status is 200 OK
+    And the response "name" is equal to "{{ unique }}"
+    And the response "type" is equal to "data-jobs alert"
+
   @team:DataDog/monitor-app
   Scenario: Create a Data Quality monitor returns "OK" response
     Given new "CreateMonitor" request

features/v1/monitors.feature

@@ -376,6 +376,7 @@ def overrides
           "v1.monitor_formula_and_function_cost_aggregator" => "MonitorFormulaAndFunctionCostAggregator",
           "v1.monitor_formula_and_function_cost_data_source" => "MonitorFormulaAndFunctionCostDataSource",
           "v1.monitor_formula_and_function_cost_query_definition" => "MonitorFormulaAndFunctionCostQueryDefinition",
+          "v1.monitor_formula_and_function_data_jobs_query_definition" => "MonitorFormulaAndFunctionDataJobsQueryDefinition",
           "v1.monitor_formula_and_function_data_quality_data_source" => "MonitorFormulaAndFunctionDataQualityDataSource",
           "v1.monitor_formula_and_function_data_quality_model_type_override" => "MonitorFormulaAndFunctionDataQualityModelTypeOverride",
           "v1.monitor_formula_and_function_data_quality_monitor_options" => "MonitorFormulaAndFunctionDataQualityMonitorOptions",

lib/datadog_api_client/inflector.rb

@@ -0,0 +1,189 @@
+=begin
+#Datadog API V1 Collection
+
+#Collection of all Datadog Public endpoints.
+
+The version of the OpenAPI document: 1.0
+Contact: support@datadoghq.com
+Generated by: https://github.com/DataDog/datadog-api-client-ruby/tree/master/.generator
+
+ Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ This product includes software developed at Datadog (https://www.datadoghq.com/).
+ Copyright 2020-Present Datadog, Inc.
+
+=end
+
+require 'date'
+require 'time'
+
+module DatadogAPIClient::V1
+  # A formula and functions data jobs query.
+  class MonitorFormulaAndFunctionDataJobsQueryDefinition
+    include BaseGenericModel
+
+    # The type of job being monitored. Valid values include:
+    # `databricks.job`, `spark.application`, `airflow.dag`,
+    # `dbt.job`, `dbt.model`, `dbt.test`, `glue.job`.
+    # Custom job types are supported with the `custom.ol.` prefix.
+    attr_reader :job_type
+
+    # Filter expression used to select the jobs to monitor.
+    attr_reader :jobs_query
+
+    # Name of the query for use in formulas. Must be `run_query`.
+    attr_reader :name
+
+    # Query dialect for data jobs queries. Currently only `metric` is supported.
+    attr_reader :query_dialect
+
+    attr_accessor :additional_properties
+
+    # Attribute mapping from ruby-style variable name to JSON key.
+    # @!visibility private
+    def self.attribute_map
+      {
+        :'job_type' => :'job_type',
+        :'jobs_query' => :'jobs_query',
+        :'name' => :'name',
+        :'query_dialect' => :'query_dialect'
+      }
+    end
+
+    # Attribute type mapping.
+    # @!visibility private
+    def self.openapi_types
+      {
+        :'job_type' => :'String',
+        :'jobs_query' => :'String',
+        :'name' => :'String',
+        :'query_dialect' => :'String'
+      }
+    end
+
+    # Initializes the object
+    # @param attributes [Hash] Model attributes in the form of hash
+    # @!visibility private
+    def initialize(attributes = {})
+      if (!attributes.is_a?(Hash))
+        fail ArgumentError, "The input argument (attributes) must be a hash in `DatadogAPIClient::V1::MonitorFormulaAndFunctionDataJobsQueryDefinition` initialize method"
+      end
+
+      self.additional_properties = {}
+      # check to see if the attribute exists and convert string to symbol for hash key
+      attributes = attributes.each_with_object({}) { |(k, v), h|
+        if (!self.class.attribute_map.key?(k.to_sym))
+          self.additional_properties[k.to_sym] = v
+        else
+          h[k.to_sym] = v
+        end
+      }
+
+      if attributes.key?(:'job_type')
+        self.job_type = attributes[:'job_type']
+      end
+
+      if attributes.key?(:'jobs_query')
+        self.jobs_query = attributes[:'jobs_query']
+      end
+
+      if attributes.key?(:'name')
+        self.name = attributes[:'name']
+      end
+
+      if attributes.key?(:'query_dialect')
+        self.query_dialect = attributes[:'query_dialect']
+      end
+    end
+
+    # Check to see if the all the properties in the model are valid
+    # @return true if the model is valid
+    # @!visibility private
+    def valid?
+      return false if @job_type.nil?
+      return false if @jobs_query.nil?
+      return false if @name.nil?
+      return false if @query_dialect.nil?
+      true
+    end
+
+    # Custom attribute writer method with validation
+    # @param job_type [Object] Object to be assigned
+    # @!visibility private
+    def job_type=(job_type)
+      if job_type.nil?
+        fail ArgumentError, 'invalid value for "job_type", job_type cannot be nil.'
+      end
+      @job_type = job_type
+    end
+
+    # Custom attribute writer method with validation
+    # @param jobs_query [Object] Object to be assigned
+    # @!visibility private
+    def jobs_query=(jobs_query)
+      if jobs_query.nil?
+        fail ArgumentError, 'invalid value for "jobs_query", jobs_query cannot be nil.'
+      end
+      @jobs_query = jobs_query
+    end
+
+    # Custom attribute writer method with validation
+    # @param name [Object] Object to be assigned
+    # @!visibility private
+    def name=(name)
+      if name.nil?
+        fail ArgumentError, 'invalid value for "name", name cannot be nil.'
+      end
+      @name = name
+    end
+
+    # Custom attribute writer method with validation
+    # @param query_dialect [Object] Object to be assigned
+    # @!visibility private
+    def query_dialect=(query_dialect)
+      if query_dialect.nil?
+        fail ArgumentError, 'invalid value for "query_dialect", query_dialect cannot be nil.'
+      end
+      @query_dialect = query_dialect
+    end
+
+    # Returns the object in the form of hash, with additionalProperties support.
+    # @return [Hash] Returns the object in the form of hash
+    # @!visibility private
+    def to_hash
+      hash = {}
+      self.class.attribute_map.each_pair do |attr, param|
+        value = self.send(attr)
+        if value.nil?
+          is_nullable = self.class.openapi_nullable.include?(attr)
+          next if !is_nullable || (is_nullable && !instance_variable_defined?(:"@#{attr}"))
+        end
+
+        hash[param] = _to_hash(value)
+      end
+      self.additional_properties.each_pair do |attr, value|
+        hash[attr] = value
+      end
+      hash
+    end
+
+    # Checks equality by comparing each attribute.
+    # @param o [Object] Object to be compared
+    # @!visibility private
+    def ==(o)
+      return true if self.equal?(o)
+      self.class == o.class &&
+          job_type == o.job_type &&
+          jobs_query == o.jobs_query &&
+          name == o.name &&
+          query_dialect == o.query_dialect &&
+          additional_properties == o.additional_properties
+    end
+
+    # Calculates hash code according to all attributes.
+    # @return [Integer] Hash code
+    # @!visibility private
+    def hash
+      [job_type, jobs_query, name, query_dialect, additional_properties].hash
+    end
+  end
+end

lib/datadog_api_client/v1/models/monitor_formula_and_function_data_jobs_query_definition.rb

@@ -29,6 +29,7 @@ def openapi_one_of
           :'MonitorFormulaAndFunctionEventQueryDefinition',
           :'MonitorFormulaAndFunctionCostQueryDefinition',
           :'MonitorFormulaAndFunctionDataQualityQueryDefinition',
+          :'MonitorFormulaAndFunctionDataJobsQueryDefinition',
           :'MonitorFormulaAndFunctionAggregateAugmentedQueryDefinition',
           :'MonitorFormulaAndFunctionAggregateFilteredQueryDefinition'
         ]

lib/datadog_api_client/v1/models/monitor_formula_and_function_query_definition.rb

@@ -42,5 +42,6 @@ class MonitorType
     COST_ALERT = "cost alert".freeze
     DATA_QUALITY_ALERT = "data-quality alert".freeze
     NETWORK_PATH_ALERT = "network-path alert".freeze
+    DATA_JOBS_ALERT = "data-jobs alert".freeze
   end
 end