Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
26 changes: 17 additions & 9 deletions .generator/schemas/v1/openapi.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -1317,7 +1317,7 @@ components:
tabs:
description: List of tabs for organizing dashboard widgets into groups.
items:
$ref: '#/components/schemas/DashboardTab'
$ref: "#/components/schemas/DashboardTab"
maxItems: 100
nullable: true
type: array
Expand Down Expand Up @@ -1596,7 +1596,7 @@ components:
properties:
id:
description: UUID of the tab.
example: ''
example: ""
format: uuid
type: string
name:
Expand All @@ -1606,20 +1606,19 @@ components:
minLength: 1
type: string
widget_ids:
description: List of widget IDs belonging to this tab. The backend also
accepts positional references in @N format (1-indexed) as a convenience
for Terraform and other declarative tools.
description: >-
List of widget IDs belonging to this tab. The backend also accepts positional references in @N format (1-indexed) as a convenience for Terraform and other declarative tools.
example:
- 0
- 0
items:
description: Widget ID.
format: int64
type: integer
type: array
required:
- id
- name
- widget_ids
- id
- name
- widget_ids
type: object
DashboardTemplateVariable:
description: Template variable.
Expand Down Expand Up @@ -6237,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:
Expand All @@ -6251,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:
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
2026-03-18T17:10:40.108Z

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

31 changes: 31 additions & 0 deletions examples/v1/logs-pipelines/CreateLogsPipeline_2599033345.rb
Original file line number Diff line number Diff line change
@@ -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)
7 changes: 7 additions & 0 deletions features/v1/logs_pipelines.feature
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
24 changes: 23 additions & 1 deletion lib/datadog_api_client/v1/models/logs_pipeline_processor.rb
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand All @@ -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

Expand All @@ -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
Expand All @@ -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
Expand All @@ -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
Expand All @@ -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
Expand Down Expand Up @@ -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
Expand All @@ -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
Loading