From 89c18292ada4591e2e8520426774c9a7309efc45 Mon Sep 17 00:00:00 2001 From: sondermanish Date: Mon, 10 Mar 2025 19:41:45 +0530 Subject: [PATCH] modified reactive chain consumption for the detach remote --- .../server/git/central/CentralGitServiceCEImpl.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/app/server/appsmith-server/src/main/java/com/appsmith/server/git/central/CentralGitServiceCEImpl.java b/app/server/appsmith-server/src/main/java/com/appsmith/server/git/central/CentralGitServiceCEImpl.java index c8d18a3279..7e34fcf78d 100644 --- a/app/server/appsmith-server/src/main/java/com/appsmith/server/git/central/CentralGitServiceCEImpl.java +++ b/app/server/appsmith-server/src/main/java/com/appsmith/server/git/central/CentralGitServiceCEImpl.java @@ -1669,7 +1669,15 @@ public class CentralGitServiceCEImpl implements CentralGitServiceCE { .filter(artifact -> { return artifact.getId().equals(baseArtifactId); }) - .next(); + .collectList() + .flatMap(filteredBaseArtifact -> { + if (!filteredBaseArtifact.isEmpty()) { + return Mono.just(filteredBaseArtifact.get(0)); + } + + return Mono.error(new AppsmithException( + AppsmithError.GIT_GENERIC_ERROR, GitCommandConstants.DELETE)); + }); return Mono.zip(deleteAllBranchesExceptBase, removeRepoMono).map(Tuple2::getT1); })