From 83e7b99e60d23b94df5140671f40b067f9856cbe Mon Sep 17 00:00:00 2001
From: SunnyCapt <sunny.capt@tuta.io>
Date: Thu, 30 May 2024 17:16:44 +0200
Subject: [PATCH] fix: config for aws in processing (#861)

---
 processing/processing/config.py            | 1 +
 processing/processing/utils/minio_utils.py | 9 ++++++++-
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/processing/processing/config.py b/processing/processing/config.py
index 4ef033eb9..c991cc460 100644
--- a/processing/processing/config.py
+++ b/processing/processing/config.py
@@ -49,6 +49,7 @@ class Settings(BaseSettings):
     keycloak_host: str
     pipelines_service_host: str
 
+    aws_region: Optional[str]
     s3_endpoint: str
     s3_secret_key: str
     s3_access_key: str
diff --git a/processing/processing/utils/minio_utils.py b/processing/processing/utils/minio_utils.py
index 429194536..8a49f557f 100644
--- a/processing/processing/utils/minio_utils.py
+++ b/processing/processing/utils/minio_utils.py
@@ -27,7 +27,14 @@ def create_minio_config():
             }
         )
     elif settings.s3_provider == "aws_iam":
-        minio_config.update({"credentials": IamAwsProvider()})
+        minio_config.update(
+            {
+                "credentials": IamAwsProvider(),
+                "region": settings.aws_region,
+                "access_key": settings.s3_access_key,
+                "secret_key": settings.s3_secret_key,
+            }
+        )
     elif settings.s3_provider == "aws_env":
         minio_config.update({"credentials": EnvAWSProvider()})
     elif settings.s3_provider == "aws_config":