Skip to content

Commit 9654da5

Browse files
committed
FIX - Missing service when preparing deploy during PATCH
1 parent ae54882 commit 9654da5

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/IngestionPipelineRepository.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -290,6 +290,13 @@ protected void deployPipelineBeforeUpdate(IngestionPipeline ingestionPipeline) {
290290
ingestionPipeline.getService() != null
291291
? ingestionPipeline.getService()
292292
: getContainer(ingestionPipeline.getId());
293+
if (serviceRef == null) {
294+
throw new IllegalStateException(
295+
String.format(
296+
"Cannot deploy pipeline '%s': no service reference found. "
297+
+ "The pipeline may have a broken service relationship.",
298+
ingestionPipeline.getName()));
299+
}
293300
decrypted.setService(serviceRef);
294301
}
295302

0 commit comments

Comments
 (0)