From aa79bcb9230b54a27b7ef2b3b37be259edb2b088 Mon Sep 17 00:00:00 2001
From: Pere Miquel Brull <peremiquelbrull@gmail.com>
Date: Sat, 6 Jan 2024 18:31:29 +0100
Subject: [PATCH] #14471 - Clean up ingestion status when deleting the
 ingestion pipeline (#14592)

---
 .../service/jdbi3/IngestionPipelineRepository.java           | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/IngestionPipelineRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/IngestionPipelineRepository.java
index 0f4c9bbbe17..9fa07390302 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/IngestionPipelineRepository.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/IngestionPipelineRepository.java
@@ -141,7 +141,12 @@ public class IngestionPipelineRepository extends EntityRepository<IngestionPipel
 
   @Override
   protected void postDelete(IngestionPipeline entity) {
+    // Delete deployed pipeline in the Pipeline Service Client
     pipelineServiceClient.deletePipeline(entity);
+    // Clean pipeline status
+    daoCollection
+        .entityExtensionTimeSeriesDao()
+        .delete(entity.getFullyQualifiedName(), PIPELINE_STATUS_EXTENSION);
   }
 
   @Override