Add traces pipeline type to Observability Pipelines

src/datadog_api_client/v2/model/observability_pipeline_config.py

@@ -103,18 +103,24 @@
     from datadog_api_client.v2.model.observability_pipeline_datadog_metrics_destination import (
         ObservabilityPipelineDatadogMetricsDestination,
     )
-    from datadog_api_client.v2.model.observability_pipeline_opentelemetry_metrics_destination import (
-        ObservabilityPipelineOpentelemetryMetricsDestination,
-    )
     from datadog_api_client.v2.model.observability_pipeline_prometheus_remote_write_destination import (
         ObservabilityPipelinePrometheusRemoteWriteDestination,
     )
     from datadog_api_client.v2.model.observability_pipeline_splunk_hec_metrics_destination import (
         ObservabilityPipelineSplunkHecMetricsDestination,
     )
+    from datadog_api_client.v2.model.observability_pipeline_opentelemetry_destination import (
+        ObservabilityPipelineOpentelemetryDestination,
+    )
+    from datadog_api_client.v2.model.observability_pipeline_datadog_traces_destination import (
+        ObservabilityPipelineDatadogTracesDestination,
+    )
     from datadog_api_client.v2.model.observability_pipeline_datadog_agent_source import (
         ObservabilityPipelineDatadogAgentSource,
     )
+    from datadog_api_client.v2.model.observability_pipeline_opentelemetry_source import (
+        ObservabilityPipelineOpentelemetrySource,
+    )
     from datadog_api_client.v2.model.observability_pipeline_amazon_data_firehose_source import (
         ObservabilityPipelineAmazonDataFirehoseSource,
     )
@@ -147,9 +153,6 @@
     )
     from datadog_api_client.v2.model.observability_pipeline_syslog_ng_source import ObservabilityPipelineSyslogNgSource
     from datadog_api_client.v2.model.observability_pipeline_websocket_source import ObservabilityPipelineWebsocketSource
-    from datadog_api_client.v2.model.observability_pipeline_opentelemetry_source import (
-        ObservabilityPipelineOpentelemetrySource,
-    )
     from datadog_api_client.v2.model.observability_pipeline_prometheus_remote_write_source import (
         ObservabilityPipelinePrometheusRemoteWriteSource,
     )
@@ -221,15 +224,17 @@ def __init__(
                 ObservabilityPipelineSyslogNgDestination,
                 ObservabilityPipelineDatabricksZerobusDestination,
                 ObservabilityPipelineDatadogMetricsDestination,
-                ObservabilityPipelineOpentelemetryMetricsDestination,
                 ObservabilityPipelinePrometheusRemoteWriteDestination,
                 ObservabilityPipelineSplunkHecMetricsDestination,
+                ObservabilityPipelineOpentelemetryDestination,
+                ObservabilityPipelineDatadogTracesDestination,
             ]
         ],
         sources: List[
             Union[
                 ObservabilityPipelineConfigSourceItem,
                 ObservabilityPipelineDatadogAgentSource,
+                ObservabilityPipelineOpentelemetrySource,
                 ObservabilityPipelineAmazonDataFirehoseSource,
                 ObservabilityPipelineAmazonS3Source,
                 ObservabilityPipelineFluentBitSource,
@@ -246,7 +251,6 @@ def __init__(
                 ObservabilityPipelineSumoLogicSource,
                 ObservabilityPipelineSyslogNgSource,
                 ObservabilityPipelineWebsocketSource,
-                ObservabilityPipelineOpentelemetrySource,
                 ObservabilityPipelinePrometheusRemoteWriteSource,
             ]
         ],
@@ -279,7 +283,7 @@ def __init__(
         :param use_legacy_search_syntax: Set to ``true`` to continue using the legacy search syntax while migrating filter queries. After migrating all queries to the new syntax, set to ``false``.
             The legacy syntax is deprecated and will eventually be removed.
             Requires Observability Pipelines Worker 2.11 or later.
-            Only applies to ``logs`` pipelines. This field is ignored for ``metrics`` pipelines.
+            Only applies to ``logs`` pipelines. This field is ignored for ``metrics`` and ``traces`` pipelines.
             See `Upgrade Your Filter Queries to the New Search Syntax <https://docs.datadoghq.com/observability_pipelines/guide/upgrade_your_filter_queries_to_the_new_search_syntax/>`_ for more information.
         :type use_legacy_search_syntax: bool, optional
         """

src/datadog_api_client/v2/model/observability_pipeline_config_destination_item.py

@@ -270,14 +270,14 @@ def __init__(self, **kwargs):
         :param unity_catalog_endpoint_key: Name of the environment variable or the secret identifier that references your Databricks workspace URL, which is used to communicate with the Unity Catalog API.
         :type unity_catalog_endpoint_key: str, optional
 
-        :param http_client_uri_key: Environment variable name containing the URI of the OTLP HTTP endpoint to send metrics to.
-        :type http_client_uri_key: str, optional
-
         :param default_namespace: The default namespace to add as a prefix to metric names that do not already have one.
         :type default_namespace: str, optional
 
         :param source: The Splunk source field value for metric events.
         :type source: str, optional
+
+        :param http_client_uri_key: Environment variable name containing the URI of the OTLP HTTP endpoint to send metrics or traces to.
+        :type http_client_uri_key: str, optional
         """
         super().__init__(kwargs)
 
@@ -367,15 +367,18 @@ def _composed_schemas(_):
         from datadog_api_client.v2.model.observability_pipeline_datadog_metrics_destination import (
             ObservabilityPipelineDatadogMetricsDestination,
         )
-        from datadog_api_client.v2.model.observability_pipeline_opentelemetry_metrics_destination import (
-            ObservabilityPipelineOpentelemetryMetricsDestination,
-        )
         from datadog_api_client.v2.model.observability_pipeline_prometheus_remote_write_destination import (
             ObservabilityPipelinePrometheusRemoteWriteDestination,
         )
         from datadog_api_client.v2.model.observability_pipeline_splunk_hec_metrics_destination import (
             ObservabilityPipelineSplunkHecMetricsDestination,
         )
+        from datadog_api_client.v2.model.observability_pipeline_opentelemetry_destination import (
+            ObservabilityPipelineOpentelemetryDestination,
+        )
+        from datadog_api_client.v2.model.observability_pipeline_datadog_traces_destination import (
+            ObservabilityPipelineDatadogTracesDestination,
+        )
 
         return {
             "oneOf": [
@@ -406,8 +409,9 @@ def _composed_schemas(_):
                 ObservabilityPipelineSyslogNgDestination,
                 ObservabilityPipelineDatabricksZerobusDestination,
                 ObservabilityPipelineDatadogMetricsDestination,
-                ObservabilityPipelineOpentelemetryMetricsDestination,
                 ObservabilityPipelinePrometheusRemoteWriteDestination,
                 ObservabilityPipelineSplunkHecMetricsDestination,
+                ObservabilityPipelineOpentelemetryDestination,
+                ObservabilityPipelineDatadogTracesDestination,
             ],
         }

src/datadog_api_client/v2/model/observability_pipeline_config_pipeline_type.py

@@ -16,16 +16,18 @@ class ObservabilityPipelineConfigPipelineType(ModelSimple):
     """
     The type of data being ingested. Defaults to `logs` if not specified.
 
-    :param value: If omitted defaults to "logs". Must be one of ["logs", "metrics"].
+    :param value: If omitted defaults to "logs". Must be one of ["logs", "metrics", "traces"].
     :type value: str
     """
 
     allowed_values = {
         "logs",
         "metrics",
+        "traces",
     }
     LOGS: ClassVar["ObservabilityPipelineConfigPipelineType"]
     METRICS: ClassVar["ObservabilityPipelineConfigPipelineType"]
+    TRACES: ClassVar["ObservabilityPipelineConfigPipelineType"]
 
     @cached_property
     def openapi_types(_):
@@ -36,3 +38,4 @@ def openapi_types(_):
 
 ObservabilityPipelineConfigPipelineType.LOGS = ObservabilityPipelineConfigPipelineType("logs")
 ObservabilityPipelineConfigPipelineType.METRICS = ObservabilityPipelineConfigPipelineType("metrics")
+ObservabilityPipelineConfigPipelineType.TRACES = ObservabilityPipelineConfigPipelineType("traces")

src/datadog_api_client/v2/model/observability_pipeline_config_processor_group.py

@@ -27,7 +27,6 @@
     from datadog_api_client.v2.model.observability_pipeline_add_hostname_processor import (
         ObservabilityPipelineAddHostnameProcessor,
     )
-    from datadog_api_client.v2.model.observability_pipeline_custom_processor import ObservabilityPipelineCustomProcessor
     from datadog_api_client.v2.model.observability_pipeline_datadog_tags_processor import (
         ObservabilityPipelineDatadogTagsProcessor,
     )
@@ -38,9 +37,6 @@
     from datadog_api_client.v2.model.observability_pipeline_generate_metrics_processor import (
         ObservabilityPipelineGenerateMetricsProcessor,
     )
-    from datadog_api_client.v2.model.observability_pipeline_generate_metrics_v2_processor import (
-        ObservabilityPipelineGenerateMetricsV2Processor,
-    )
     from datadog_api_client.v2.model.observability_pipeline_ocsf_mapper_processor import (
         ObservabilityPipelineOcsfMapperProcessor,
     )
@@ -61,16 +57,20 @@
     from datadog_api_client.v2.model.observability_pipeline_rename_fields_processor import (
         ObservabilityPipelineRenameFieldsProcessor,
     )
-    from datadog_api_client.v2.model.observability_pipeline_sample_processor import ObservabilityPipelineSampleProcessor
-    from datadog_api_client.v2.model.observability_pipeline_sensitive_data_scanner_processor import (
-        ObservabilityPipelineSensitiveDataScannerProcessor,
-    )
     from datadog_api_client.v2.model.observability_pipeline_split_array_processor import (
         ObservabilityPipelineSplitArrayProcessor,
     )
     from datadog_api_client.v2.model.observability_pipeline_throttle_processor import (
         ObservabilityPipelineThrottleProcessor,
     )
+    from datadog_api_client.v2.model.observability_pipeline_custom_processor import ObservabilityPipelineCustomProcessor
+    from datadog_api_client.v2.model.observability_pipeline_generate_metrics_v2_processor import (
+        ObservabilityPipelineGenerateMetricsV2Processor,
+    )
+    from datadog_api_client.v2.model.observability_pipeline_sample_processor import ObservabilityPipelineSampleProcessor
+    from datadog_api_client.v2.model.observability_pipeline_sensitive_data_scanner_processor import (
+        ObservabilityPipelineSensitiveDataScannerProcessor,
+    )
     from datadog_api_client.v2.model.observability_pipeline_add_metric_tags_processor import (
         ObservabilityPipelineAddMetricTagsProcessor,
     )
@@ -129,12 +129,10 @@ def __init__(
                 ObservabilityPipelineAddEnvVarsProcessor,
                 ObservabilityPipelineAddFieldsProcessor,
                 ObservabilityPipelineAddHostnameProcessor,
-                ObservabilityPipelineCustomProcessor,
                 ObservabilityPipelineDatadogTagsProcessor,
                 ObservabilityPipelineDedupeProcessor,
                 ObservabilityPipelineEnrichmentTableProcessor,
                 ObservabilityPipelineGenerateMetricsProcessor,
-                ObservabilityPipelineGenerateMetricsV2Processor,
                 ObservabilityPipelineOcsfMapperProcessor,
                 ObservabilityPipelineParseGrokProcessor,
                 ObservabilityPipelineParseJSONProcessor,
@@ -143,10 +141,12 @@ def __init__(
                 ObservabilityPipelineReduceProcessor,
                 ObservabilityPipelineRemoveFieldsProcessor,
                 ObservabilityPipelineRenameFieldsProcessor,
-                ObservabilityPipelineSampleProcessor,
-                ObservabilityPipelineSensitiveDataScannerProcessor,
                 ObservabilityPipelineSplitArrayProcessor,
                 ObservabilityPipelineThrottleProcessor,
+                ObservabilityPipelineCustomProcessor,
+                ObservabilityPipelineGenerateMetricsV2Processor,
+                ObservabilityPipelineSampleProcessor,
+                ObservabilityPipelineSensitiveDataScannerProcessor,
                 ObservabilityPipelineAddMetricTagsProcessor,
                 ObservabilityPipelineAggregateProcessor,
                 ObservabilityPipelineMetricEnrichmentTableProcessor,

src/datadog_api_client/v2/model/observability_pipeline_config_processor_item.py

@@ -24,7 +24,7 @@ def __init__(self, **kwargs):
         :param id: The unique identifier for this component. Used in other parts of the pipeline to reference this component (for example, as the `input` to downstream components).
         :type id: str
 
-        :param include: A Datadog search query used to determine which logs/metrics should pass through the filter. Logs/metrics that match this query continue to downstream components; others are dropped.
+        :param include: A Datadog search query used to determine which events should pass through the filter. Events that match this query continue to downstream components; others are dropped.
         :type include: str
 
         :param type: The processor type. The value should always be `filter`.
@@ -36,9 +36,6 @@ def __init__(self, **kwargs):
         :param fields: A list of static fields (key-value pairs) that is added to each log event processed by this component.
         :type fields: [ObservabilityPipelineFieldValue]
 
-        :param remaps: Array of VRL remap rules.
-        :type remaps: [ObservabilityPipelineCustomProcessorRemap]
-
         :param action: The action to take on tags with matching keys.
         :type action: ObservabilityPipelineDatadogTagsProcessorAction
 
@@ -66,9 +63,6 @@ def __init__(self, **kwargs):
         :param metrics: Configuration for generating individual metrics.
         :type metrics: [ObservabilityPipelineGeneratedMetric], optional
 
-        :param enabled_metric_aggregation: [Recommended] Indicates whether generated metrics are automatically aggregated and enriched with the `worker_uuid` tag before being sent to the metric destination.
-        :type enabled_metric_aggregation: bool, optional
-
         :param keep_unmatched: Whether to keep an event that does not match any of the mapping filters.
         :type keep_unmatched: bool, optional
 
@@ -145,9 +139,6 @@ def __init__(self, **kwargs):
         :param merge_strategies: List of merge strategies defining how values from grouped events should be combined.
         :type merge_strategies: [ObservabilityPipelineReduceProcessorMergeStrategy]
 
-        :param percentage: The percentage of logs to sample.
-        :type percentage: float
-
         :param arrays: A list of array split configurations.
         :type arrays: [ObservabilityPipelineSplitArrayProcessorArrayConfig]
 
@@ -157,6 +148,15 @@ def __init__(self, **kwargs):
         :param window: The time window in seconds over which the threshold applies.
         :type window: float
 
+        :param remaps: Array of VRL remap rules.
+        :type remaps: [ObservabilityPipelineCustomProcessorRemap]
+
+        :param enabled_metric_aggregation: [Recommended] Indicates whether generated metrics are automatically aggregated and enriched with the `worker_uuid` tag before being sent to the metric destination.
+        :type enabled_metric_aggregation: bool, optional
+
+        :param percentage: The percentage of events to sample.
+        :type percentage: float
+
         :param tags: A list of static tags (key-value pairs) added to each metric processed by this component.
         :type tags: [ObservabilityPipelineFieldValue]
 
@@ -201,9 +201,6 @@ def _composed_schemas(_):
         from datadog_api_client.v2.model.observability_pipeline_add_hostname_processor import (
             ObservabilityPipelineAddHostnameProcessor,
         )
-        from datadog_api_client.v2.model.observability_pipeline_custom_processor import (
-            ObservabilityPipelineCustomProcessor,
-        )
         from datadog_api_client.v2.model.observability_pipeline_datadog_tags_processor import (
             ObservabilityPipelineDatadogTagsProcessor,
         )
@@ -216,9 +213,6 @@ def _composed_schemas(_):
         from datadog_api_client.v2.model.observability_pipeline_generate_metrics_processor import (
             ObservabilityPipelineGenerateMetricsProcessor,
         )
-        from datadog_api_client.v2.model.observability_pipeline_generate_metrics_v2_processor import (
-            ObservabilityPipelineGenerateMetricsV2Processor,
-        )
         from datadog_api_client.v2.model.observability_pipeline_ocsf_mapper_processor import (
             ObservabilityPipelineOcsfMapperProcessor,
         )
@@ -243,18 +237,24 @@ def _composed_schemas(_):
         from datadog_api_client.v2.model.observability_pipeline_rename_fields_processor import (
             ObservabilityPipelineRenameFieldsProcessor,
         )
-        from datadog_api_client.v2.model.observability_pipeline_sample_processor import (
-            ObservabilityPipelineSampleProcessor,
-        )
-        from datadog_api_client.v2.model.observability_pipeline_sensitive_data_scanner_processor import (
-            ObservabilityPipelineSensitiveDataScannerProcessor,
-        )
         from datadog_api_client.v2.model.observability_pipeline_split_array_processor import (
             ObservabilityPipelineSplitArrayProcessor,
         )
         from datadog_api_client.v2.model.observability_pipeline_throttle_processor import (
             ObservabilityPipelineThrottleProcessor,
         )
+        from datadog_api_client.v2.model.observability_pipeline_custom_processor import (
+            ObservabilityPipelineCustomProcessor,
+        )
+        from datadog_api_client.v2.model.observability_pipeline_generate_metrics_v2_processor import (
+            ObservabilityPipelineGenerateMetricsV2Processor,
+        )
+        from datadog_api_client.v2.model.observability_pipeline_sample_processor import (
+            ObservabilityPipelineSampleProcessor,
+        )
+        from datadog_api_client.v2.model.observability_pipeline_sensitive_data_scanner_processor import (
+            ObservabilityPipelineSensitiveDataScannerProcessor,
+        )
         from datadog_api_client.v2.model.observability_pipeline_add_metric_tags_processor import (
             ObservabilityPipelineAddMetricTagsProcessor,
         )
@@ -280,12 +280,10 @@ def _composed_schemas(_):
                 ObservabilityPipelineAddEnvVarsProcessor,
                 ObservabilityPipelineAddFieldsProcessor,
                 ObservabilityPipelineAddHostnameProcessor,
-                ObservabilityPipelineCustomProcessor,
                 ObservabilityPipelineDatadogTagsProcessor,
                 ObservabilityPipelineDedupeProcessor,
                 ObservabilityPipelineEnrichmentTableProcessor,
                 ObservabilityPipelineGenerateMetricsProcessor,
-                ObservabilityPipelineGenerateMetricsV2Processor,
                 ObservabilityPipelineOcsfMapperProcessor,
                 ObservabilityPipelineParseGrokProcessor,
                 ObservabilityPipelineParseJSONProcessor,
@@ -294,10 +292,12 @@ def _composed_schemas(_):
                 ObservabilityPipelineReduceProcessor,
                 ObservabilityPipelineRemoveFieldsProcessor,
                 ObservabilityPipelineRenameFieldsProcessor,
-                ObservabilityPipelineSampleProcessor,
-                ObservabilityPipelineSensitiveDataScannerProcessor,
                 ObservabilityPipelineSplitArrayProcessor,
                 ObservabilityPipelineThrottleProcessor,
+                ObservabilityPipelineCustomProcessor,
+                ObservabilityPipelineGenerateMetricsV2Processor,
+                ObservabilityPipelineSampleProcessor,
+                ObservabilityPipelineSensitiveDataScannerProcessor,
                 ObservabilityPipelineAddMetricTagsProcessor,
                 ObservabilityPipelineAggregateProcessor,
                 ObservabilityPipelineMetricEnrichmentTableProcessor,