From 65df8cd40efa81341fac96b5ed3870f2f626aa85 Mon Sep 17 00:00:00 2001
From: "brian.mulier" <bmmulier@hotmail.fr>
Date: Wed, 27 Mar 2024 11:30:07 +0100
Subject: [PATCH] fix(runner): add region to CloudWatch client

---
 .../io/kestra/plugin/aws/runner/AwsBatchScriptRunner.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/io/kestra/plugin/aws/runner/AwsBatchScriptRunner.java b/src/main/java/io/kestra/plugin/aws/runner/AwsBatchScriptRunner.java
index 717d930..6e5c461 100644
--- a/src/main/java/io/kestra/plugin/aws/runner/AwsBatchScriptRunner.java
+++ b/src/main/java/io/kestra/plugin/aws/runner/AwsBatchScriptRunner.java
@@ -190,9 +190,10 @@ public RunnerResult run(RunContext runContext, ScriptCommands commands, List<Str
         AbstractLogConsumer logConsumer = commands.getLogConsumer();
 
         String renderedRegion = runContext.render(this.region);
+        Region regionObject = Region.of(renderedRegion);
         BatchClientBuilder batchClientBuilder = BatchClient.builder()
             .credentialsProvider(ConnectionUtils.credentialsProvider(this.awsClientConfig(runContext)))
-            .region(Region.of(renderedRegion))
+            .region(regionObject)
             // Use the httpClientBuilder to delegate the lifecycle management of the HTTP client to the AWS SDK
             .httpClientBuilder(serviceDefaults -> ApacheHttpClient.builder().build());
 
@@ -415,6 +416,7 @@ public RunnerResult run(RunContext runContext, ScriptCommands commands, List<Str
         CloudWatchLogsAsyncClient cloudWatchLogsAsyncClient =
             CloudWatchLogsAsyncClient.builder()
                 .credentialsProvider(ConnectionUtils.credentialsProvider(this.awsClientConfig(runContext)))
+                .region(regionObject)
                 .build();
         try {
             String logGroupName = "/aws/batch/job";