diff --git a/metadata-service/services/src/main/java/com/linkedin/metadata/service/ViewService.java b/metadata-service/services/src/main/java/com/linkedin/metadata/service/ViewService.java index 77986a3bd90dca..43da02f990fb5e 100644 --- a/metadata-service/services/src/main/java/com/linkedin/metadata/service/ViewService.java +++ b/metadata-service/services/src/main/java/com/linkedin/metadata/service/ViewService.java @@ -11,12 +11,14 @@ import com.linkedin.metadata.entity.AspectUtils; import com.linkedin.metadata.key.DataHubViewKey; import com.linkedin.metadata.utils.EntityKeyUtils; +import com.linkedin.r2.RemoteInvocationException; import com.linkedin.view.DataHubViewDefinition; import com.linkedin.view.DataHubViewInfo; import com.linkedin.view.DataHubViewType; import io.datahubproject.metadata.context.OperationContext; import java.util.Objects; import java.util.UUID; +import java.util.concurrent.CompletableFuture; import javax.annotation.Nonnull; import javax.annotation.Nullable; import lombok.extern.slf4j.Slf4j; @@ -177,11 +179,11 @@ public void deleteView(@Nonnull OperationContext opContext, @Nonnull Urn viewUrn try { this.entityClient.deleteEntity( opContext, Objects.requireNonNull(viewUrn, "viewUrn must not be null")); - + // Asynchronously delete all references to the entity (to return quickly) CompletableFuture.runAsync( () -> { - try { + try {x this.entityClient.deleteEntityReferences(opContext, viewUrn); } catch (RemoteInvocationException e) { log.error(