Add tags and description fields to the logs nested pipeline type LogsPipelineProcessor (#3850)

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

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

.generator/schemas/v1/openapi.yaml

@@ -6236,6 +6236,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:
@@ -6250,6 +6253,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:

api/datadogV1/model_logs_pipeline_processor.go

@@ -16,6 +16,8 @@ import (
 //
 // A pipeline can contain Nested Pipelines and Processors whereas a Nested Pipeline can only contain Processors.
 type LogsPipelineProcessor struct {
+	// A description of the pipeline.
+	Description *string `json:"description,omitempty"`
 	// Filter for logs.
 	Filter *LogsFilter `json:"filter,omitempty"`
 	// Whether or not the processor is enabled.
@@ -24,6 +26,8 @@ type LogsPipelineProcessor struct {
 	Name *string `json:"name,omitempty"`
 	// Ordered list of processors in this pipeline.
 	Processors []LogsProcessor `json:"processors,omitempty"`
+	// A list of tags associated with the pipeline.
+	Tags []string `json:"tags,omitempty"`
 	// Type of logs pipeline processor.
 	Type LogsPipelineProcessorType `json:"type"`
 	// UnparsedObject contains the raw value of the object if there was an error when deserializing into the struct
@@ -55,6 +59,34 @@ func NewLogsPipelineProcessorWithDefaults() *LogsPipelineProcessor {
 	return &this
 }
 
+// GetDescription returns the Description field value if set, zero value otherwise.
+func (o *LogsPipelineProcessor) GetDescription() string {
+	if o == nil || o.Description == nil {
+		var ret string
+		return ret
+	}
+	return *o.Description
+}
+
+// GetDescriptionOk returns a tuple with the Description field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *LogsPipelineProcessor) GetDescriptionOk() (*string, bool) {
+	if o == nil || o.Description == nil {
+		return nil, false
+	}
+	return o.Description, true
+}
+
+// HasDescription returns a boolean if a field has been set.
+func (o *LogsPipelineProcessor) HasDescription() bool {
+	return o != nil && o.Description != nil
+}
+
+// SetDescription gets a reference to the given string and assigns it to the Description field.
+func (o *LogsPipelineProcessor) SetDescription(v string) {
+	o.Description = &v
+}
+
 // GetFilter returns the Filter field value if set, zero value otherwise.
 func (o *LogsPipelineProcessor) GetFilter() LogsFilter {
 	if o == nil || o.Filter == nil {
@@ -167,6 +199,34 @@ func (o *LogsPipelineProcessor) SetProcessors(v []LogsProcessor) {
 	o.Processors = v
 }
 
+// GetTags returns the Tags field value if set, zero value otherwise.
+func (o *LogsPipelineProcessor) GetTags() []string {
+	if o == nil || o.Tags == nil {
+		var ret []string
+		return ret
+	}
+	return o.Tags
+}
+
+// GetTagsOk returns a tuple with the Tags field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *LogsPipelineProcessor) GetTagsOk() (*[]string, bool) {
+	if o == nil || o.Tags == nil {
+		return nil, false
+	}
+	return &o.Tags, true
+}
+
+// HasTags returns a boolean if a field has been set.
+func (o *LogsPipelineProcessor) HasTags() bool {
+	return o != nil && o.Tags != nil
+}
+
+// SetTags gets a reference to the given []string and assigns it to the Tags field.
+func (o *LogsPipelineProcessor) SetTags(v []string) {
+	o.Tags = v
+}
+
 // GetType returns the Type field value.
 func (o *LogsPipelineProcessor) GetType() LogsPipelineProcessorType {
 	if o == nil {
@@ -196,6 +256,9 @@ func (o LogsPipelineProcessor) MarshalJSON() ([]byte, error) {
 	if o.UnparsedObject != nil {
 		return datadog.Marshal(o.UnparsedObject)
 	}
+	if o.Description != nil {
+		toSerialize["description"] = o.Description
+	}
 	if o.Filter != nil {
 		toSerialize["filter"] = o.Filter
 	}
@@ -208,6 +271,9 @@ func (o LogsPipelineProcessor) MarshalJSON() ([]byte, error) {
 	if o.Processors != nil {
 		toSerialize["processors"] = o.Processors
 	}
+	if o.Tags != nil {
+		toSerialize["tags"] = o.Tags
+	}
 	toSerialize["type"] = o.Type
 
 	for key, value := range o.AdditionalProperties {
@@ -219,11 +285,13 @@ func (o LogsPipelineProcessor) MarshalJSON() ([]byte, error) {
 // UnmarshalJSON deserializes the given payload.
 func (o *LogsPipelineProcessor) UnmarshalJSON(bytes []byte) (err error) {
 	all := struct {
-		Filter     *LogsFilter                `json:"filter,omitempty"`
-		IsEnabled  *bool                      `json:"is_enabled,omitempty"`
-		Name       *string                    `json:"name,omitempty"`
-		Processors []LogsProcessor            `json:"processors,omitempty"`
-		Type       *LogsPipelineProcessorType `json:"type"`
+		Description *string                    `json:"description,omitempty"`
+		Filter      *LogsFilter                `json:"filter,omitempty"`
+		IsEnabled   *bool                      `json:"is_enabled,omitempty"`
+		Name        *string                    `json:"name,omitempty"`
+		Processors  []LogsProcessor            `json:"processors,omitempty"`
+		Tags        []string                   `json:"tags,omitempty"`
+		Type        *LogsPipelineProcessorType `json:"type"`
 	}{}
 	if err = datadog.Unmarshal(bytes, &all); err != nil {
 		return datadog.Unmarshal(bytes, &o.UnparsedObject)
@@ -233,19 +301,21 @@ func (o *LogsPipelineProcessor) UnmarshalJSON(bytes []byte) (err error) {
 	}
 	additionalProperties := make(map[string]interface{})
 	if err = datadog.Unmarshal(bytes, &additionalProperties); err == nil {
-		datadog.DeleteKeys(additionalProperties, &[]string{"filter", "is_enabled", "name", "processors", "type"})
+		datadog.DeleteKeys(additionalProperties, &[]string{"description", "filter", "is_enabled", "name", "processors", "tags", "type"})
 	} else {
 		return err
 	}
 
 	hasInvalidField := false
+	o.Description = all.Description
 	if all.Filter != nil && all.Filter.UnparsedObject != nil && o.UnparsedObject == nil {
 		hasInvalidField = true
 	}
 	o.Filter = all.Filter
 	o.IsEnabled = all.IsEnabled
 	o.Name = all.Name
 	o.Processors = all.Processors
+	o.Tags = all.Tags
 	if !all.Type.IsValid() {
 		hasInvalidField = true
 	} else {

examples/v1/logs-pipelines/CreateLogsPipeline_2599033345.go

@@ -0,0 +1,55 @@
+// Create a pipeline with nested pipeline processor returns "OK" response
+
+package main
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"os"
+
+	"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
+	"github.com/DataDog/datadog-api-client-go/v2/api/datadogV1"
+)
+
+func main() {
+	body := datadogV1.LogsPipeline{
+		Filter: &datadogV1.LogsFilter{
+			Query: datadog.PtrString("source:python"),
+		},
+		Name: "testPipelineWithNested",
+		Processors: []datadogV1.LogsProcessor{
+			datadogV1.LogsProcessor{
+				LogsPipelineProcessor: &datadogV1.LogsPipelineProcessor{
+					Type:      datadogV1.LOGSPIPELINEPROCESSORTYPE_PIPELINE,
+					IsEnabled: datadog.PtrBool(true),
+					Name:      datadog.PtrString("nested_pipeline_with_metadata"),
+					Filter: &datadogV1.LogsFilter{
+						Query: datadog.PtrString("env:production"),
+					},
+					Tags: []string{
+						"env:prod",
+						"type:nested",
+					},
+					Description: datadog.PtrString("This is a nested pipeline for production logs"),
+				}},
+		},
+		Tags: []string{
+			"team:test",
+		},
+		Description: datadog.PtrString("Pipeline containing nested processor with tags and description"),
+	}
+	ctx := datadog.NewDefaultContext(context.Background())
+	configuration := datadog.NewConfiguration()
+	apiClient := datadog.NewAPIClient(configuration)
+	api := datadogV1.NewLogsPipelinesApi(apiClient)
+	resp, r, err := api.CreateLogsPipeline(ctx, body)
+
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Error when calling `LogsPipelinesApi.CreateLogsPipeline`: %v\n", err)
+		fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
+	}
+
+	responseContent, _ := json.MarshalIndent(resp, "", "  ")
+	fmt.Fprintf(os.Stdout, "Response from `LogsPipelinesApi.CreateLogsPipeline`:\n%s\n", responseContent)
+}

tests/scenarios/cassettes/TestScenarios/v1/Feature_Logs_Pipelines/Scenario_Create_a_pipeline_with_nested_pipeline_processor_returns_OK_response.freeze

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

tests/scenarios/cassettes/TestScenarios/v1/Feature_Logs_Pipelines/Scenario_Create_a_pipeline_with_nested_pipeline_processor_returns_OK_response.yaml

@@ -0,0 +1,45 @@
+interactions:
+- request:
+    body: |
+      {"description":"Pipeline containing nested processor with tags and description","filter":{"query":"source:python"},"name":"testPipelineWithNested","processors":[{"description":"This is a nested pipeline for production logs","filter":{"query":"env:production"},"is_enabled":true,"name":"nested_pipeline_with_metadata","tags":["env:prod","type:nested"],"type":"pipeline"}],"tags":["team:test"]}
+    form: {}
+    headers:
+      Accept:
+      - application/json
+      Content-Type:
+      - application/json
+    id: 0
+    method: POST
+    url: https://api.datadoghq.com/api/v1/logs/config/pipelines
+  response:
+    body: '{"id":"GyYNpCrVQtOB3KhqJSpOOA","type":"pipeline","name":"testPipelineWithNested","is_enabled":false,"is_read_only":false,"filter":{"query":"source:python"},"processors":[{"type":"pipeline","name":"nested_pipeline_with_metadata","is_enabled":true,"filter":{"query":"env:production"},"processors":[],"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"}
+
+      '
+    code: 200
+    duration: 0ms
+    headers:
+      Content-Type:
+      - application/json
+    status: 200 OK
+- request:
+    body: ''
+    form: {}
+    headers:
+      Accept:
+      - '*/*'
+    id: 1
+    method: DELETE
+    url: https://api.datadoghq.com/api/v1/logs/config/pipelines/GyYNpCrVQtOB3KhqJSpOOA
+  response:
+    body: '{}
+
+      '
+    code: 200
+    duration: 0ms
+    headers:
+      Content-Type:
+      - application/json
+    status: 200 OK
+version: 2

tests/scenarios/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