Observability Pipelines API is GA now

.generator/schemas/v2/openapi.yaml

@@ -83957,8 +83957,6 @@ paths:
         operator: OR
         permissions:
         - observability_pipelines_read
-      x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
-        to request access.'
     post:
       description: Create a new pipeline.
       operationId: CreatePipeline
@@ -83990,8 +83988,6 @@ paths:
         operator: OR
         permissions:
         - observability_pipelines_deploy
-      x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
-        to request access.'
   /api/v2/obs-pipelines/pipelines/validate:
     post:
       description: 'Validates a pipeline configuration without creating or updating
@@ -84025,8 +84021,6 @@ paths:
         operator: OR
         permissions:
         - observability_pipelines_read
-      x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
-        to request access.'
   /api/v2/obs-pipelines/pipelines/{pipeline_id}:
     delete:
       description: Delete a pipeline.
@@ -84068,8 +84062,6 @@ paths:
         operator: OR
         permissions:
         - observability_pipelines_delete
-      x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
-        to request access.'
     get:
       description: Get a specific pipeline by its ID.
       operationId: GetPipeline
@@ -84102,8 +84094,6 @@ paths:
         operator: OR
         permissions:
         - observability_pipelines_read
-      x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
-        to request access.'
     put:
       description: Update a pipeline.
       operationId: UpdatePipeline
@@ -84144,8 +84134,6 @@ paths:
         operator: OR
         permissions:
         - observability_pipelines_deploy
-      x-unstable: '**Note**: This endpoint is in Preview. Fill out this [form](https://www.datadoghq.com/product-preview/observability-pipelines-api-and-terraform-support/)
-        to request access.'
   /api/v2/on-call/escalation-policies:
     post:
       description: Create a new On-Call escalation policy

examples/v2/observability-pipelines/CreatePipeline.java

@@ -23,7 +23,6 @@
 public class Example {
   public static void main(String[] args) {
     ApiClient defaultClient = ApiClient.getDefaultApiClient();
-    defaultClient.setUnstableOperationEnabled("v2.createPipeline", true);
     ObservabilityPipelinesApi apiInstance = new ObservabilityPipelinesApi(defaultClient);
 
     ObservabilityPipelineSpec body =

examples/v2/observability-pipelines/DeletePipeline.java

@@ -7,7 +7,6 @@
 public class Example {
   public static void main(String[] args) {
     ApiClient defaultClient = ApiClient.getDefaultApiClient();
-    defaultClient.setUnstableOperationEnabled("v2.deletePipeline", true);
     ObservabilityPipelinesApi apiInstance = new ObservabilityPipelinesApi(defaultClient);
 
     // there is a valid "pipeline" in the system

examples/v2/observability-pipelines/GetPipeline.java

@@ -8,7 +8,6 @@
 public class Example {
   public static void main(String[] args) {
     ApiClient defaultClient = ApiClient.getDefaultApiClient();
-    defaultClient.setUnstableOperationEnabled("v2.getPipeline", true);
     ObservabilityPipelinesApi apiInstance = new ObservabilityPipelinesApi(defaultClient);
 
     // there is a valid "pipeline" in the system

examples/v2/observability-pipelines/ListPipelines.java

@@ -8,7 +8,6 @@
 public class Example {
   public static void main(String[] args) {
     ApiClient defaultClient = ApiClient.getDefaultApiClient();
-    defaultClient.setUnstableOperationEnabled("v2.listPipelines", true);
     ObservabilityPipelinesApi apiInstance = new ObservabilityPipelinesApi(defaultClient);
 
     try {

examples/v2/observability-pipelines/UpdatePipeline.java

@@ -22,7 +22,6 @@
 public class Example {
   public static void main(String[] args) {
     ApiClient defaultClient = ApiClient.getDefaultApiClient();
-    defaultClient.setUnstableOperationEnabled("v2.updatePipeline", true);
     ObservabilityPipelinesApi apiInstance = new ObservabilityPipelinesApi(defaultClient);
 
     // there is a valid "pipeline" in the system

examples/v2/observability-pipelines/ValidatePipeline.java

@@ -23,7 +23,6 @@
 public class Example {
   public static void main(String[] args) {
     ApiClient defaultClient = ApiClient.getDefaultApiClient();
-    defaultClient.setUnstableOperationEnabled("v2.validatePipeline", true);
     ObservabilityPipelinesApi apiInstance = new ObservabilityPipelinesApi(defaultClient);
 
     ObservabilityPipelineSpec body =

src/main/java/com/datadog/api/client/ApiClient.java

@@ -889,12 +889,6 @@ public class ApiClient {
           put("v2.updateMonitorUserTemplate", false);
           put("v2.validateExistingMonitorUserTemplate", false);
           put("v2.validateMonitorUserTemplate", false);
-          put("v2.createPipeline", false);
-          put("v2.deletePipeline", false);
-          put("v2.getPipeline", false);
-          put("v2.listPipelines", false);
-          put("v2.updatePipeline", false);
-          put("v2.validatePipeline", false);
           put("v2.listRoleTemplates", false);
           put("v2.createConnection", false);
           put("v2.deleteConnection", false);

src/main/java/com/datadog/api/client/v2/api/ObservabilityPipelinesApi.java

@@ -96,13 +96,6 @@ public CompletableFuture<ObservabilityPipeline> createPipelineAsync(
    */
   public ApiResponse<ObservabilityPipeline> createPipelineWithHttpInfo(
       ObservabilityPipelineSpec body) throws ApiException {
-    // Check if unstable operation is enabled
-    String operationId = "createPipeline";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      throw new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId));
-    }
     Object localVarPostBody = body;
 
     // verify the required parameter 'body' is set
@@ -145,16 +138,6 @@ public ApiResponse<ObservabilityPipeline> createPipelineWithHttpInfo(
    */
   public CompletableFuture<ApiResponse<ObservabilityPipeline>> createPipelineWithHttpInfoAsync(
       ObservabilityPipelineSpec body) {
-    // Check if unstable operation is enabled
-    String operationId = "createPipeline";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      CompletableFuture<ApiResponse<ObservabilityPipeline>> result = new CompletableFuture<>();
-      result.completeExceptionally(
-          new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId)));
-      return result;
-    }
     Object localVarPostBody = body;
 
     // verify the required parameter 'body' is set
@@ -243,13 +226,6 @@ public CompletableFuture<Void> deletePipelineAsync(String pipelineId) {
    *     </table>
    */
   public ApiResponse<Void> deletePipelineWithHttpInfo(String pipelineId) throws ApiException {
-    // Check if unstable operation is enabled
-    String operationId = "deletePipeline";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      throw new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId));
-    }
     Object localVarPostBody = null;
 
     // verify the required parameter 'pipelineId' is set
@@ -294,16 +270,6 @@ public ApiResponse<Void> deletePipelineWithHttpInfo(String pipelineId) throws Ap
    * @return CompletableFuture&lt;ApiResponse&lt;Void&gt;&gt;
    */
   public CompletableFuture<ApiResponse<Void>> deletePipelineWithHttpInfoAsync(String pipelineId) {
-    // Check if unstable operation is enabled
-    String operationId = "deletePipeline";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      CompletableFuture<ApiResponse<Void>> result = new CompletableFuture<>();
-      result.completeExceptionally(
-          new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId)));
-      return result;
-    }
     Object localVarPostBody = null;
 
     // verify the required parameter 'pipelineId' is set
@@ -395,13 +361,6 @@ public CompletableFuture<ObservabilityPipeline> getPipelineAsync(String pipeline
    */
   public ApiResponse<ObservabilityPipeline> getPipelineWithHttpInfo(String pipelineId)
       throws ApiException {
-    // Check if unstable operation is enabled
-    String operationId = "getPipeline";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      throw new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId));
-    }
     Object localVarPostBody = null;
 
     // verify the required parameter 'pipelineId' is set
@@ -447,16 +406,6 @@ public ApiResponse<ObservabilityPipeline> getPipelineWithHttpInfo(String pipelin
    */
   public CompletableFuture<ApiResponse<ObservabilityPipeline>> getPipelineWithHttpInfoAsync(
       String pipelineId) {
-    // Check if unstable operation is enabled
-    String operationId = "getPipeline";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      CompletableFuture<ApiResponse<ObservabilityPipeline>> result = new CompletableFuture<>();
-      result.completeExceptionally(
-          new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId)));
-      return result;
-    }
     Object localVarPostBody = null;
 
     // verify the required parameter 'pipelineId' is set
@@ -607,13 +556,6 @@ public CompletableFuture<ListPipelinesResponse> listPipelinesAsync(
    */
   public ApiResponse<ListPipelinesResponse> listPipelinesWithHttpInfo(
       ListPipelinesOptionalParameters parameters) throws ApiException {
-    // Check if unstable operation is enabled
-    String operationId = "listPipelines";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      throw new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId));
-    }
     Object localVarPostBody = null;
     Long pageSize = parameters.pageSize;
     Long pageNumber = parameters.pageNumber;
@@ -656,16 +598,6 @@ public ApiResponse<ListPipelinesResponse> listPipelinesWithHttpInfo(
    */
   public CompletableFuture<ApiResponse<ListPipelinesResponse>> listPipelinesWithHttpInfoAsync(
       ListPipelinesOptionalParameters parameters) {
-    // Check if unstable operation is enabled
-    String operationId = "listPipelines";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      CompletableFuture<ApiResponse<ListPipelinesResponse>> result = new CompletableFuture<>();
-      result.completeExceptionally(
-          new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId)));
-      return result;
-    }
     Object localVarPostBody = null;
     Long pageSize = parameters.pageSize;
     Long pageNumber = parameters.pageNumber;
@@ -759,13 +691,6 @@ public CompletableFuture<ObservabilityPipeline> updatePipelineAsync(
    */
   public ApiResponse<ObservabilityPipeline> updatePipelineWithHttpInfo(
       String pipelineId, ObservabilityPipeline body) throws ApiException {
-    // Check if unstable operation is enabled
-    String operationId = "updatePipeline";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      throw new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId));
-    }
     Object localVarPostBody = body;
 
     // verify the required parameter 'pipelineId' is set
@@ -818,16 +743,6 @@ public ApiResponse<ObservabilityPipeline> updatePipelineWithHttpInfo(
    */
   public CompletableFuture<ApiResponse<ObservabilityPipeline>> updatePipelineWithHttpInfoAsync(
       String pipelineId, ObservabilityPipeline body) {
-    // Check if unstable operation is enabled
-    String operationId = "updatePipeline";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      CompletableFuture<ApiResponse<ObservabilityPipeline>> result = new CompletableFuture<>();
-      result.completeExceptionally(
-          new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId)));
-      return result;
-    }
     Object localVarPostBody = body;
 
     // verify the required parameter 'pipelineId' is set
@@ -931,13 +846,6 @@ public CompletableFuture<ValidationResponse> validatePipelineAsync(
    */
   public ApiResponse<ValidationResponse> validatePipelineWithHttpInfo(
       ObservabilityPipelineSpec body) throws ApiException {
-    // Check if unstable operation is enabled
-    String operationId = "validatePipeline";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      throw new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId));
-    }
     Object localVarPostBody = body;
 
     // verify the required parameter 'body' is set
@@ -980,16 +888,6 @@ public ApiResponse<ValidationResponse> validatePipelineWithHttpInfo(
    */
   public CompletableFuture<ApiResponse<ValidationResponse>> validatePipelineWithHttpInfoAsync(
       ObservabilityPipelineSpec body) {
-    // Check if unstable operation is enabled
-    String operationId = "validatePipeline";
-    if (apiClient.isUnstableOperationEnabled("v2." + operationId)) {
-      apiClient.getLogger().warning(String.format("Using unstable operation '%s'", operationId));
-    } else {
-      CompletableFuture<ApiResponse<ValidationResponse>> result = new CompletableFuture<>();
-      result.completeExceptionally(
-          new ApiException(0, String.format("Unstable operation '%s' is disabled", operationId)));
-      return result;
-    }
     Object localVarPostBody = body;
 
     // verify the required parameter 'body' is set

src/test/resources/cassettes/features/v2/Create_a_new_pipeline_returns_Bad_Request_response.freeze

@@ -1 +1 @@
-2026-01-09T15:42:36.842Z
+2026-01-30T16:23:40.491Z

src/test/resources/cassettes/features/v2/Create_a_new_pipeline_returns_OK_response.freeze

@@ -1 +1 @@
-2026-01-09T15:42:37.370Z
+2026-01-30T16:23:40.989Z

src/test/resources/cassettes/features/v2/Create_a_new_pipeline_returns_OK_response.json

@@ -12,7 +12,7 @@
       "secure": true
     },
     "httpResponse": {
-      "body": "{\"data\":{\"id\":\"d33cceac-ed71-11f0-bd8c-da7ad0900002\",\"type\":\"pipelines\",\"attributes\":{\"name\":\"Main Observability Pipeline\",\"config\":{\"destinations\":[{\"id\":\"datadog-logs-destination\",\"inputs\":[\"my-processor-group\"],\"type\":\"datadog_logs\"}],\"processor_groups\":[{\"enabled\":true,\"id\":\"my-processor-group\",\"include\":\"service:my-service\",\"inputs\":[\"datadog-agent-source\"],\"processors\":[{\"enabled\":true,\"id\":\"filter-processor\",\"include\":\"status:error\",\"type\":\"filter\"}]}],\"processors\":[{\"enabled\":true,\"id\":\"my-processor-group\",\"include\":\"service:my-service\",\"inputs\":[\"datadog-agent-source\"],\"processors\":[{\"enabled\":true,\"id\":\"filter-processor\",\"include\":\"status:error\",\"type\":\"filter\"}]}],\"sources\":[{\"id\":\"datadog-agent-source\",\"type\":\"datadog_agent\"}]}}}}\n",
+      "body": "{\"data\":{\"id\":\"0a44c8d2-fdf8-11f0-8d8c-da7ad0900002\",\"type\":\"pipelines\",\"attributes\":{\"name\":\"Main Observability Pipeline\",\"config\":{\"destinations\":[{\"id\":\"datadog-logs-destination\",\"inputs\":[\"my-processor-group\"],\"type\":\"datadog_logs\"}],\"processor_groups\":[{\"enabled\":true,\"id\":\"my-processor-group\",\"include\":\"service:my-service\",\"inputs\":[\"datadog-agent-source\"],\"processors\":[{\"enabled\":true,\"id\":\"filter-processor\",\"include\":\"status:error\",\"type\":\"filter\"}]}],\"processors\":[{\"enabled\":true,\"id\":\"my-processor-group\",\"include\":\"service:my-service\",\"inputs\":[\"datadog-agent-source\"],\"processors\":[{\"enabled\":true,\"id\":\"filter-processor\",\"include\":\"status:error\",\"type\":\"filter\"}]}],\"sources\":[{\"id\":\"datadog-agent-source\",\"type\":\"datadog_agent\"}]}}}}\n",
       "headers": {
         "Content-Type": [
           "application/vnd.api+json"
@@ -33,7 +33,7 @@
     "httpRequest": {
       "headers": {},
       "method": "DELETE",
-      "path": "/api/v2/obs-pipelines/pipelines/d33cceac-ed71-11f0-bd8c-da7ad0900002",
+      "path": "/api/v2/obs-pipelines/pipelines/0a44c8d2-fdf8-11f0-8d8c-da7ad0900002",
       "keepAlive": false,
       "secure": true
     },
@@ -52,6 +52,6 @@
     "timeToLive": {
       "unlimited": true
     },
-    "id": "3b2d4718-4969-f434-f3c5-2d3f4052b254"
+    "id": "c2ff691a-c324-dd48-107b-004daf64453c"
   }
 ]

src/test/resources/cassettes/features/v2/Delete_a_pipeline_returns_Not_Found_response.freeze

@@ -1 +1 @@
-2026-01-09T15:42:38.750Z
+2026-01-30T16:23:42.608Z

src/test/resources/cassettes/features/v2/Delete_a_pipeline_returns_OK_response.freeze

@@ -1 +1 @@
-2026-01-09T15:42:39.305Z
+2026-01-30T16:23:43.204Z