Add tags and description fields to the logs nested pipeline type LogsPipelineProcessor

.generator/schemas/v1/openapi.yaml

@@ -6683,6 +6683,9 @@ components:
         A pipeline can contain Nested Pipelines and Processors whereas a Nested Pipeline
         can only contain Processors.'
       properties:
+        description:
+          description: A description of the pipeline.
+          type: string
         filter:
           $ref: '#/components/schemas/LogsFilter'
         is_enabled:
@@ -6697,6 +6700,12 @@ components:
           items:
             $ref: '#/components/schemas/LogsProcessor'
           type: array
+        tags:
+          description: A list of tags associated with the pipeline.
+          items:
+            description: A single tag using the format `key:value`.
+            type: string
+          type: array
         type:
           $ref: '#/components/schemas/LogsPipelineProcessorType'
       required:

.generator/schemas/v2/openapi.yaml

@@ -102212,6 +102212,13 @@ paths:
     get:
       description: Get the list of all critical assets.
       operationId: ListSecurityMonitoringCriticalAssets
+      parameters:
+      - description: Query string.
+        in: query
+        name: query
+        required: false
+        schema:
+          type: string
       responses:
         '200':
           content:

cassettes/features/v1/logs_pipelines/Create-a-pipeline-with-nested-pipeline-processor-returns-OK-response.frozen

@@ -0,0 +1 @@
+2026-03-18T17:10:40.108Z

examples/v1/logs-pipelines/CreateLogsPipeline_2599033345.rb

@@ -0,0 +1,31 @@
+# Create a pipeline with nested pipeline processor returns "OK" response
+
+require "datadog_api_client"
+api_instance = DatadogAPIClient::V1::LogsPipelinesAPI.new
+
+body = DatadogAPIClient::V1::LogsPipeline.new({
+  filter: DatadogAPIClient::V1::LogsFilter.new({
+    query: "source:python",
+  }),
+  name: "testPipelineWithNested",
+  processors: [
+    DatadogAPIClient::V1::LogsPipelineProcessor.new({
+      type: DatadogAPIClient::V1::LogsPipelineProcessorType::PIPELINE,
+      is_enabled: true,
+      name: "nested_pipeline_with_metadata",
+      filter: DatadogAPIClient::V1::LogsFilter.new({
+        query: "env:production",
+      }),
+      tags: [
+        "env:prod",
+        "type:nested",
+      ],
+      description: "This is a nested pipeline for production logs",
+    }),
+  ],
+  tags: [
+    "team:test",
+  ],
+  description: "Pipeline containing nested processor with tags and description",
+})
+p api_instance.create_logs_pipeline(body)

features/scenarios_model_mapping.rb

@@ -1607,6 +1607,9 @@
             "filter_operating_system_name" => "String",
             "filter_operating_system_version" => "String",
     },
+    "v2.ListSecurityMonitoringCriticalAssets" => {
+            "query" => "String",
+    },
     "v2.CreateSecurityMonitoringCriticalAsset" => {
             "body" => "SecurityMonitoringCriticalAssetCreateRequest",
     },

features/v1/logs_pipelines.feature

@@ -98,6 +98,13 @@ Feature: Logs Pipelines
     When the request is sent
     Then the response status is 200 OK
 
+  @team:DataDog/event-platform-experience
+  Scenario: Create a pipeline with nested pipeline processor returns "OK" response
+    Given new "CreateLogsPipeline" request
+    And body with value {"filter": {"query": "source:python"}, "name": "testPipelineWithNested", "processors": [{"type": "pipeline", "is_enabled": true, "name": "nested_pipeline_with_metadata", "filter": {"query": "env:production"}, "tags": ["env:prod", "type:nested"], "description": "This is a nested pipeline for production logs"}], "tags": ["team:test"], "description": "Pipeline containing nested processor with tags and description"}
+    When the request is sent
+    Then the response status is 200 OK
+
   @team:DataDog/event-platform-experience
   Scenario: Create a pipeline with schema processor
     Given new "CreateLogsPipeline" request

lib/datadog_api_client/v1/models/logs_pipeline_processor.rb

@@ -25,6 +25,9 @@ module DatadogAPIClient::V1
   class LogsPipelineProcessor
     include BaseGenericModel
 
+    # A description of the pipeline.
+    attr_accessor :description
+
     # Filter for logs.
     attr_accessor :filter
 
@@ -37,6 +40,9 @@ class LogsPipelineProcessor
     # Ordered list of processors in this pipeline.
     attr_accessor :processors
 
+    # A list of tags associated with the pipeline.
+    attr_accessor :tags
+
     # Type of logs pipeline processor.
     attr_reader :type
 
@@ -46,10 +52,12 @@ class LogsPipelineProcessor
     # @!visibility private
     def self.attribute_map
       {
+        :'description' => :'description',
         :'filter' => :'filter',
         :'is_enabled' => :'is_enabled',
         :'name' => :'name',
         :'processors' => :'processors',
+        :'tags' => :'tags',
         :'type' => :'type'
       }
     end
@@ -58,10 +66,12 @@ def self.attribute_map
     # @!visibility private
     def self.openapi_types
       {
+        :'description' => :'String',
         :'filter' => :'LogsFilter',
         :'is_enabled' => :'Boolean',
         :'name' => :'String',
         :'processors' => :'Array<LogsProcessor>',
+        :'tags' => :'Array<String>',
         :'type' => :'LogsPipelineProcessorType'
       }
     end
@@ -84,6 +94,10 @@ def initialize(attributes = {})
         end
       }
 
+      if attributes.key?(:'description')
+        self.description = attributes[:'description']
+      end
+
       if attributes.key?(:'filter')
         self.filter = attributes[:'filter']
       end
@@ -102,6 +116,12 @@ def initialize(attributes = {})
         end
       end
 
+      if attributes.key?(:'tags')
+        if (value = attributes[:'tags']).is_a?(Array)
+          self.tags = value
+        end
+      end
+
       if attributes.key?(:'type')
         self.type = attributes[:'type']
       end
@@ -151,10 +171,12 @@ def to_hash
     def ==(o)
       return true if self.equal?(o)
       self.class == o.class &&
+          description == o.description &&
           filter == o.filter &&
           is_enabled == o.is_enabled &&
           name == o.name &&
           processors == o.processors &&
+          tags == o.tags &&
           type == o.type &&
           additional_properties == o.additional_properties
     end
@@ -163,7 +185,7 @@ def ==(o)
     # @return [Integer] Hash code
     # @!visibility private
     def hash
-      [filter, is_enabled, name, processors, type, additional_properties].hash
+      [description, filter, is_enabled, name, processors, tags, type, additional_properties].hash
     end
   end
 end

lib/datadog_api_client/v2/api/security_monitoring_api.rb

@@ -4326,6 +4326,7 @@ def list_security_monitoring_critical_assets(opts = {})
     # Get the list of all critical assets.
     #
     # @param opts [Hash] the optional parameters
+    # @option opts [String] :query Query string.
     # @return [Array<(SecurityMonitoringCriticalAssetsResponse, Integer, Hash)>] SecurityMonitoringCriticalAssetsResponse data, response status code and response headers
     def list_security_monitoring_critical_assets_with_http_info(opts = {})
 
@@ -4337,6 +4338,7 @@ def list_security_monitoring_critical_assets_with_http_info(opts = {})
 
       # query parameters
       query_params = opts[:query_params] || {}
+      query_params[:'query'] = opts[:'query'] if !opts[:'query'].nil?
 
       # header parameters
       header_params = opts[:header_params] || {}