[test] Add DatadogTagsProcessor to observability pipelines spec

.generated-info

@@ -1,4 +1,4 @@
 {
-  "spec_repo_commit": "0f24b8e",
-  "generated": "2025-07-18 16:54:43.860"
+  "spec_repo_commit": "5b64e98",
+  "generated": "2025-07-18 21:24:34.609"
 }

.generator/schemas/v2/openapi.yaml

@@ -25557,6 +25557,7 @@ components:
       - $ref: '#/components/schemas/ObservabilityPipelineEnrichmentTableProcessor'
       - $ref: '#/components/schemas/ObservabilityPipelineReduceProcessor'
       - $ref: '#/components/schemas/ObservabilityPipelineThrottleProcessor'
+      - $ref: '#/components/schemas/ObservabilityPipelineDatadogTagsProcessor'
     ObservabilityPipelineConfigSourceItem:
       description: A data source for the pipeline.
       oneOf:
@@ -25666,6 +25667,80 @@ components:
       type: string
       x-enum-varnames:
       - DATADOG_LOGS
+    ObservabilityPipelineDatadogTagsProcessor:
+      description: The `datadog_tags` processor includes or excludes specific Datadog
+        tags in your logs.
+      properties:
+        action:
+          $ref: '#/components/schemas/ObservabilityPipelineDatadogTagsProcessorAction'
+        id:
+          description: The unique identifier for this component. Used to reference
+            this component in other parts of the pipeline (for example, as the `input`
+            to downstream components).
+          example: datadog-tags-processor
+          type: string
+        include:
+          description: A Datadog search query used to determine which logs this processor
+            targets.
+          example: service:my-service
+          type: string
+        inputs:
+          description: A list of component IDs whose output is used as the `input`
+            for this component.
+          example:
+          - datadog-agent-source
+          items:
+            type: string
+          type: array
+        keys:
+          description: A list of tag keys.
+          example:
+          - env
+          - service
+          - version
+          items:
+            type: string
+          type: array
+        mode:
+          $ref: '#/components/schemas/ObservabilityPipelineDatadogTagsProcessorMode'
+        type:
+          $ref: '#/components/schemas/ObservabilityPipelineDatadogTagsProcessorType'
+      required:
+      - id
+      - type
+      - include
+      - mode
+      - action
+      - keys
+      - inputs
+      type: object
+    ObservabilityPipelineDatadogTagsProcessorAction:
+      description: The action to take on tags with matching keys.
+      enum:
+      - include
+      - exclude
+      example: include
+      type: string
+      x-enum-varnames:
+      - INCLUDE
+      - EXCLUDE
+    ObservabilityPipelineDatadogTagsProcessorMode:
+      description: The processing mode.
+      enum:
+      - filter
+      example: filter
+      type: string
+      x-enum-varnames:
+      - FILTER
+    ObservabilityPipelineDatadogTagsProcessorType:
+      default: datadog_tags
+      description: The processor type. The value should always be `datadog_tags`.
+      enum:
+      - datadog_tags
+      example: datadog_tags
+      type: string
+      x-enum-varnames:
+      - DATADOG_TAGS
     ObservabilityPipelineDecoding:
       description: The decoding format used to interpret incoming logs.
       enum:

api/datadogV2/model_observability_pipeline_config_processor_item.go

@@ -26,6 +26,7 @@ type ObservabilityPipelineConfigProcessorItem struct {
 	ObservabilityPipelineEnrichmentTableProcessor      *ObservabilityPipelineEnrichmentTableProcessor
 	ObservabilityPipelineReduceProcessor               *ObservabilityPipelineReduceProcessor
 	ObservabilityPipelineThrottleProcessor             *ObservabilityPipelineThrottleProcessor
+	ObservabilityPipelineDatadogTagsProcessor          *ObservabilityPipelineDatadogTagsProcessor
 
 	// UnparsedObject contains the raw value of the object if there was an error when deserializing into the struct
 	UnparsedObject interface{}
@@ -111,6 +112,11 @@ func ObservabilityPipelineThrottleProcessorAsObservabilityPipelineConfigProcesso
 	return ObservabilityPipelineConfigProcessorItem{ObservabilityPipelineThrottleProcessor: v}
 }
 
+// ObservabilityPipelineDatadogTagsProcessorAsObservabilityPipelineConfigProcessorItem is a convenience function that returns ObservabilityPipelineDatadogTagsProcessor wrapped in ObservabilityPipelineConfigProcessorItem.
+func ObservabilityPipelineDatadogTagsProcessorAsObservabilityPipelineConfigProcessorItem(v *ObservabilityPipelineDatadogTagsProcessor) ObservabilityPipelineConfigProcessorItem {
+	return ObservabilityPipelineConfigProcessorItem{ObservabilityPipelineDatadogTagsProcessor: v}
+}
+
 // UnmarshalJSON turns data into one of the pointers in the struct.
 func (obj *ObservabilityPipelineConfigProcessorItem) UnmarshalJSON(data []byte) error {
 	var err error
@@ -387,6 +393,23 @@ func (obj *ObservabilityPipelineConfigProcessorItem) UnmarshalJSON(data []byte)
 		obj.ObservabilityPipelineThrottleProcessor = nil
 	}
 
+	// try to unmarshal data into ObservabilityPipelineDatadogTagsProcessor
+	err = datadog.Unmarshal(data, &obj.ObservabilityPipelineDatadogTagsProcessor)
+	if err == nil {
+		if obj.ObservabilityPipelineDatadogTagsProcessor != nil && obj.ObservabilityPipelineDatadogTagsProcessor.UnparsedObject == nil {
+			jsonObservabilityPipelineDatadogTagsProcessor, _ := datadog.Marshal(obj.ObservabilityPipelineDatadogTagsProcessor)
+			if string(jsonObservabilityPipelineDatadogTagsProcessor) == "{}" { // empty struct
+				obj.ObservabilityPipelineDatadogTagsProcessor = nil
+			} else {
+				match++
+			}
+		} else {
+			obj.ObservabilityPipelineDatadogTagsProcessor = nil
+		}
+	} else {
+		obj.ObservabilityPipelineDatadogTagsProcessor = nil
+	}
+
 	if match != 1 { // more than 1 match
 		// reset to nil
 		obj.ObservabilityPipelineFilterProcessor = nil
@@ -405,6 +428,7 @@ func (obj *ObservabilityPipelineConfigProcessorItem) UnmarshalJSON(data []byte)
 		obj.ObservabilityPipelineEnrichmentTableProcessor = nil
 		obj.ObservabilityPipelineReduceProcessor = nil
 		obj.ObservabilityPipelineThrottleProcessor = nil
+		obj.ObservabilityPipelineDatadogTagsProcessor = nil
 		return datadog.Unmarshal(data, &obj.UnparsedObject)
 	}
 	return nil // exactly one match
@@ -476,6 +500,10 @@ func (obj ObservabilityPipelineConfigProcessorItem) MarshalJSON() ([]byte, error
 		return datadog.Marshal(&obj.ObservabilityPipelineThrottleProcessor)
 	}
 
+	if obj.ObservabilityPipelineDatadogTagsProcessor != nil {
+		return datadog.Marshal(&obj.ObservabilityPipelineDatadogTagsProcessor)
+	}
+
 	if obj.UnparsedObject != nil {
 		return datadog.Marshal(obj.UnparsedObject)
 	}
@@ -548,6 +576,10 @@ func (obj *ObservabilityPipelineConfigProcessorItem) GetActualInstance() interfa
 		return obj.ObservabilityPipelineThrottleProcessor
 	}
 
+	if obj.ObservabilityPipelineDatadogTagsProcessor != nil {
+		return obj.ObservabilityPipelineDatadogTagsProcessor
+	}
+
 	// all schemas are nil
 	return nil
 }