diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/PipelineRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/PipelineRepository.java index 8684fed27e82..c9901191f7d7 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/PipelineRepository.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/PipelineRepository.java @@ -727,7 +727,12 @@ public void storeEntities(List pipelines) { @Override protected void entitySpecificCleanup(Pipeline pipeline) { - // When a pipeline is removed , the linege needs to be removed + // Delete pipeline execution history from time series + daoCollection + .entityExtensionTimeSeriesDao() + .delete(pipeline.getFullyQualifiedName(), PIPELINE_STATUS_EXTENSION); + + // When a pipeline is removed, the lineage needs to be removed daoCollection .relationshipDAO() .deleteLineageBySourcePipeline(