1717 from datadog_api_client .v2 .model .observability_pipeline_config_destination_item import (
1818 ObservabilityPipelineConfigDestinationItem ,
1919 )
20- from datadog_api_client .v2 .model .observability_pipeline_config_processor_item import (
21- ObservabilityPipelineConfigProcessorItem ,
20+ from datadog_api_client .v2 .model .observability_pipeline_config_processor_group import (
21+ ObservabilityPipelineConfigProcessorGroup ,
2222 )
2323 from datadog_api_client .v2 .model .observability_pipeline_config_source_item import (
2424 ObservabilityPipelineConfigSourceItem ,
7676 from datadog_api_client .v2 .model .observability_pipeline_google_pub_sub_destination import (
7777 ObservabilityPipelineGooglePubSubDestination ,
7878 )
79- from datadog_api_client .v2 .model .observability_pipeline_filter_processor import ObservabilityPipelineFilterProcessor
80- from datadog_api_client .v2 .model .observability_pipeline_parse_json_processor import (
81- ObservabilityPipelineParseJSONProcessor ,
82- )
83- from datadog_api_client .v2 .model .observability_pipeline_quota_processor import ObservabilityPipelineQuotaProcessor
84- from datadog_api_client .v2 .model .observability_pipeline_add_fields_processor import (
85- ObservabilityPipelineAddFieldsProcessor ,
86- )
87- from datadog_api_client .v2 .model .observability_pipeline_remove_fields_processor import (
88- ObservabilityPipelineRemoveFieldsProcessor ,
89- )
90- from datadog_api_client .v2 .model .observability_pipeline_rename_fields_processor import (
91- ObservabilityPipelineRenameFieldsProcessor ,
92- )
93- from datadog_api_client .v2 .model .observability_pipeline_generate_metrics_processor import (
94- ObservabilityPipelineGenerateMetricsProcessor ,
95- )
96- from datadog_api_client .v2 .model .observability_pipeline_sample_processor import ObservabilityPipelineSampleProcessor
97- from datadog_api_client .v2 .model .observability_pipeline_parse_grok_processor import (
98- ObservabilityPipelineParseGrokProcessor ,
99- )
100- from datadog_api_client .v2 .model .observability_pipeline_sensitive_data_scanner_processor import (
101- ObservabilityPipelineSensitiveDataScannerProcessor ,
102- )
103- from datadog_api_client .v2 .model .observability_pipeline_ocsf_mapper_processor import (
104- ObservabilityPipelineOcsfMapperProcessor ,
105- )
106- from datadog_api_client .v2 .model .observability_pipeline_add_env_vars_processor import (
107- ObservabilityPipelineAddEnvVarsProcessor ,
108- )
109- from datadog_api_client .v2 .model .observability_pipeline_dedupe_processor import ObservabilityPipelineDedupeProcessor
110- from datadog_api_client .v2 .model .observability_pipeline_enrichment_table_processor import (
111- ObservabilityPipelineEnrichmentTableProcessor ,
112- )
113- from datadog_api_client .v2 .model .observability_pipeline_reduce_processor import ObservabilityPipelineReduceProcessor
114- from datadog_api_client .v2 .model .observability_pipeline_throttle_processor import (
115- ObservabilityPipelineThrottleProcessor ,
116- )
117- from datadog_api_client .v2 .model .observability_pipeline_custom_processor import ObservabilityPipelineCustomProcessor
118- from datadog_api_client .v2 .model .observability_pipeline_datadog_tags_processor import (
119- ObservabilityPipelineDatadogTagsProcessor ,
120- )
12179 from datadog_api_client .v2 .model .observability_pipeline_kafka_source import ObservabilityPipelineKafkaSource
12280 from datadog_api_client .v2 .model .observability_pipeline_datadog_agent_source import (
12381 ObservabilityPipelineDatadogAgentSource ,
@@ -160,16 +118,16 @@ def openapi_types(_):
160118 from datadog_api_client .v2 .model .observability_pipeline_config_destination_item import (
161119 ObservabilityPipelineConfigDestinationItem ,
162120 )
163- from datadog_api_client .v2 .model .observability_pipeline_config_processor_item import (
164- ObservabilityPipelineConfigProcessorItem ,
121+ from datadog_api_client .v2 .model .observability_pipeline_config_processor_group import (
122+ ObservabilityPipelineConfigProcessorGroup ,
165123 )
166124 from datadog_api_client .v2 .model .observability_pipeline_config_source_item import (
167125 ObservabilityPipelineConfigSourceItem ,
168126 )
169127
170128 return {
171129 "destinations" : ([ObservabilityPipelineConfigDestinationItem ],),
172- "processors" : ([ObservabilityPipelineConfigProcessorItem ],),
130+ "processors" : ([ObservabilityPipelineConfigProcessorGroup ],),
173131 "sources" : ([ObservabilityPipelineConfigSourceItem ],),
174132 }
175133
@@ -226,32 +184,7 @@ def __init__(
226184 ObservabilityPipelineSocketSource ,
227185 ]
228186 ],
229- processors : Union [
230- List [
231- Union [
232- ObservabilityPipelineConfigProcessorItem ,
233- ObservabilityPipelineFilterProcessor ,
234- ObservabilityPipelineParseJSONProcessor ,
235- ObservabilityPipelineQuotaProcessor ,
236- ObservabilityPipelineAddFieldsProcessor ,
237- ObservabilityPipelineRemoveFieldsProcessor ,
238- ObservabilityPipelineRenameFieldsProcessor ,
239- ObservabilityPipelineGenerateMetricsProcessor ,
240- ObservabilityPipelineSampleProcessor ,
241- ObservabilityPipelineParseGrokProcessor ,
242- ObservabilityPipelineSensitiveDataScannerProcessor ,
243- ObservabilityPipelineOcsfMapperProcessor ,
244- ObservabilityPipelineAddEnvVarsProcessor ,
245- ObservabilityPipelineDedupeProcessor ,
246- ObservabilityPipelineEnrichmentTableProcessor ,
247- ObservabilityPipelineReduceProcessor ,
248- ObservabilityPipelineThrottleProcessor ,
249- ObservabilityPipelineCustomProcessor ,
250- ObservabilityPipelineDatadogTagsProcessor ,
251- ]
252- ],
253- UnsetType ,
254- ] = unset ,
187+ processors : Union [List [ObservabilityPipelineConfigProcessorGroup ], UnsetType ] = unset ,
255188 ** kwargs ,
256189 ):
257190 """
@@ -260,8 +193,8 @@ def __init__(
260193 :param destinations: A list of destination components where processed logs are sent.
261194 :type destinations: [ObservabilityPipelineConfigDestinationItem]
262195
263- :param processors: A list of processors that transform or enrich log data.
264- :type processors: [ObservabilityPipelineConfigProcessorItem ], optional
196+ :param processors: A list of processor groups that transform or enrich log data.
197+ :type processors: [ObservabilityPipelineConfigProcessorGroup ], optional
265198
266199 :param sources: A list of configured data sources for the pipeline.
267200 :type sources: [ObservabilityPipelineConfigSourceItem]
0 commit comments