This is an automated email from the ASF dual-hosted git repository. dimuthuupe pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/airavata-mft.git
commit 5161d90f2d2800dc10cbb71a45139de3187eccae Author: Dimuthu Wannipurage <[email protected]> AuthorDate: Thu Feb 2 13:16:58 2023 -0500 Prioritizing local agent if no agent is specified in the request --- .../java/org/apache/airavata/mft/api/handler/MFTApiHandler.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/api/service/src/main/java/org/apache/airavata/mft/api/handler/MFTApiHandler.java b/api/service/src/main/java/org/apache/airavata/mft/api/handler/MFTApiHandler.java index 69c7262..371bab3 100644 --- a/api/service/src/main/java/org/apache/airavata/mft/api/handler/MFTApiHandler.java +++ b/api/service/src/main/java/org/apache/airavata/mft/api/handler/MFTApiHandler.java @@ -512,7 +512,11 @@ public class MFTApiHandler extends MFTTransferServiceGrpc.MFTTransferServiceImpl if (liveAgentIds.isEmpty()) { throw new Exception("No agent is available to perform the operation"); } - targetAgent = liveAgentIds.get(0); + if (liveAgentIds.stream().anyMatch(id -> id.equals("local-agent"))) { + targetAgent = "local-agent"; + } else { + targetAgent = liveAgentIds.get(0); + } logger.info("Using agent {} for processing the operation", targetAgent); } else { Optional<AgentInfo> agentInfo = mftConsulClient.getAgentInfo(targetAgent);
