Regenerate client from commit f47923e of spec repo

Author: ci.datadog-api-spec

.generator/schemas/v2/openapi.yaml

@@ -3025,7 +3025,9 @@ def overrides
           "v2.observability_pipeline_aws_auth" => "ObservabilityPipelineAwsAuth",
           "v2.observability_pipeline_config" => "ObservabilityPipelineConfig",
           "v2.observability_pipeline_config_destination_item" => "ObservabilityPipelineConfigDestinationItem",
+          "v2.observability_pipeline_config_processor_group" => "ObservabilityPipelineConfigProcessorGroup",
           "v2.observability_pipeline_config_processor_item" => "ObservabilityPipelineConfigProcessorItem",
+          "v2.observability_pipeline_config_processors" => "ObservabilityPipelineConfigProcessors",
           "v2.observability_pipeline_config_source_item" => "ObservabilityPipelineConfigSourceItem",
           "v2.observability_pipeline_crowd_strike_next_gen_siem_destination" => "ObservabilityPipelineCrowdStrikeNextGenSiemDestination",
           "v2.observability_pipeline_crowd_strike_next_gen_siem_destination_compression" => "ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression",

lib/datadog_api_client/inflector.rb

@@ -21,14 +21,17 @@ module DatadogAPIClient::V2
   class ObservabilityPipelineAddEnvVarsProcessor
     include BaseGenericModel
 
+    # Whether this processor is enabled.
+    attr_accessor :enabled
+
     # The unique identifier for this component. Used to reference this processor in the pipeline.
     attr_reader :id
 
     # A Datadog search query used to determine which logs this processor targets.
     attr_reader :include
 
-    # A list of component IDs whose output is used as the input for this processor.
-    attr_reader :inputs
+    # A list of component IDs whose output is used as input for this processor. Required when used as a standalone processor, omit when used within a processor group.
+    attr_accessor :inputs
 
     # The processor type. The value should always be `add_env_vars`.
     attr_reader :type
@@ -42,6 +45,7 @@ class ObservabilityPipelineAddEnvVarsProcessor
     # @!visibility private
     def self.attribute_map
       {
+        :'enabled' => :'enabled',
         :'id' => :'id',
         :'include' => :'include',
         :'inputs' => :'inputs',
@@ -54,6 +58,7 @@ def self.attribute_map
     # @!visibility private
     def self.openapi_types
       {
+        :'enabled' => :'Boolean',
         :'id' => :'String',
         :'include' => :'String',
         :'inputs' => :'Array<String>',
@@ -80,6 +85,10 @@ def initialize(attributes = {})
         end
       }
 
+      if attributes.key?(:'enabled')
+        self.enabled = attributes[:'enabled']
+      end
+
       if attributes.key?(:'id')
         self.id = attributes[:'id']
       end
@@ -111,7 +120,6 @@ def initialize(attributes = {})
     def valid?
       return false if @id.nil?
       return false if @include.nil?
-      return false if @inputs.nil?
       return false if @type.nil?
       return false if @variables.nil?
       true
@@ -137,16 +145,6 @@ def include=(include)
       @include = include
     end
 
-    # Custom attribute writer method with validation
-    # @param inputs [Object] Object to be assigned
-    # @!visibility private
-    def inputs=(inputs)
-      if inputs.nil?
-        fail ArgumentError, 'invalid value for "inputs", inputs cannot be nil.'
-      end
-      @inputs = inputs
-    end
-
     # Custom attribute writer method with validation
     # @param type [Object] Object to be assigned
     # @!visibility private
@@ -193,6 +191,7 @@ def to_hash
     def ==(o)
       return true if self.equal?(o)
       self.class == o.class &&
+          enabled == o.enabled &&
           id == o.id &&
           include == o.include &&
           inputs == o.inputs &&
@@ -205,7 +204,7 @@ def ==(o)
     # @return [Integer] Hash code
     # @!visibility private
     def hash
-      [id, include, inputs, type, variables, additional_properties].hash
+      [enabled, id, include, inputs, type, variables, additional_properties].hash
     end
   end
 end

lib/datadog_api_client/v2/models/observability_pipeline_add_env_vars_processor.rb

@@ -21,6 +21,9 @@ module DatadogAPIClient::V2
   class ObservabilityPipelineAddFieldsProcessor
     include BaseGenericModel
 
+    # Whether this processor is enabled.
+    attr_accessor :enabled
+
     # A list of static fields (key-value pairs) that is added to each log event processed by this component.
     attr_reader :fields
 
@@ -30,8 +33,8 @@ class ObservabilityPipelineAddFieldsProcessor
     # A Datadog search query used to determine which logs this processor targets.
     attr_reader :include
 
-    # A list of component IDs whose output is used as the `input` for this component.
-    attr_reader :inputs
+    # A list of component IDs whose output is used as input for this processor. Required when used as a standalone processor, omit when used within a processor group.
+    attr_accessor :inputs
 
     # The processor type. The value should always be `add_fields`.
     attr_reader :type
@@ -42,6 +45,7 @@ class ObservabilityPipelineAddFieldsProcessor
     # @!visibility private
     def self.attribute_map
       {
+        :'enabled' => :'enabled',
         :'fields' => :'fields',
         :'id' => :'id',
         :'include' => :'include',
@@ -54,6 +58,7 @@ def self.attribute_map
     # @!visibility private
     def self.openapi_types
       {
+        :'enabled' => :'Boolean',
         :'fields' => :'Array<ObservabilityPipelineFieldValue>',
         :'id' => :'String',
         :'include' => :'String',
@@ -80,6 +85,10 @@ def initialize(attributes = {})
         end
       }
 
+      if attributes.key?(:'enabled')
+        self.enabled = attributes[:'enabled']
+      end
+
       if attributes.key?(:'fields')
         if (value = attributes[:'fields']).is_a?(Array)
           self.fields = value
@@ -112,7 +121,6 @@ def valid?
       return false if @fields.nil?
       return false if @id.nil?
       return false if @include.nil?
-      return false if @inputs.nil?
       return false if @type.nil?
       true
     end
@@ -147,16 +155,6 @@ def include=(include)
       @include = include
     end
 
-    # Custom attribute writer method with validation
-    # @param inputs [Object] Object to be assigned
-    # @!visibility private
-    def inputs=(inputs)
-      if inputs.nil?
-        fail ArgumentError, 'invalid value for "inputs", inputs cannot be nil.'
-      end
-      @inputs = inputs
-    end
-
     # Custom attribute writer method with validation
     # @param type [Object] Object to be assigned
     # @!visibility private
@@ -193,6 +191,7 @@ def to_hash
     def ==(o)
       return true if self.equal?(o)
       self.class == o.class &&
+          enabled == o.enabled &&
           fields == o.fields &&
           id == o.id &&
           include == o.include &&
@@ -205,7 +204,7 @@ def ==(o)
     # @return [Integer] Hash code
     # @!visibility private
     def hash
-      [fields, id, include, inputs, type, additional_properties].hash
+      [enabled, fields, id, include, inputs, type, additional_properties].hash
     end
   end
 end

lib/datadog_api_client/v2/models/observability_pipeline_add_fields_processor.rb

@@ -24,7 +24,7 @@ class ObservabilityPipelineConfig
     # A list of destination components where processed logs are sent.
     attr_reader :destinations
 
-    # A list of processors that transform or enrich log data.
+    # A list of processors that transform or enrich log data, or a list of grouped processor configurations.
     attr_accessor :processors
 
     # A list of configured data sources for the pipeline.
@@ -47,7 +47,7 @@ def self.attribute_map
     def self.openapi_types
       {
         :'destinations' => :'Array<ObservabilityPipelineConfigDestinationItem>',
-        :'processors' => :'Array<ObservabilityPipelineConfigProcessorItem>',
+        :'processors' => :'ObservabilityPipelineConfigProcessors',
         :'sources' => :'Array<ObservabilityPipelineConfigSourceItem>'
       }
     end
@@ -77,9 +77,7 @@ def initialize(attributes = {})
       end
 
       if attributes.key?(:'processors')
-        if (value = attributes[:'processors']).is_a?(Array)
-          self.processors = value
-        end
+        self.processors = attributes[:'processors']
       end
 
       if attributes.key?(:'sources')