Update Azure Blob Service Config

externals/storages/azure_blob.py

@@ -14,17 +14,17 @@ from utils.logger import get_logger
 logger = get_logger("azure-blob")
 
 # ---------- SINGLETONS ----------
-if "azureai__container__key" not in os.environ:
-    credential=DefaultAzureCredential()
-    logger.info(f"✅ Initialized Azure AI Cred: Using **Default Credential**")
-else:
-    credential = AzureSasCredential(AzureBlobConstants.SAS_KEY)
-    logger.info(f"✅ Initialized Azure AI Cred: Using **Azure Key Credential**")
 
 
 
 async def get_blob_service_client() -> BlobServiceClient:
     try:
+        if "azureai__container__key" not in os.environ:
+            credential=DefaultAzureCredential()
+            logger.info(f"✅ Initialized Azure AI Cred: Using **Default Credential**")
+        else:
+            credential = AzureSasCredential(AzureBlobConstants.SAS_KEY)
+            logger.info(f"✅ Initialized Azure AI Cred: Using **Azure Key Credential**")
         # default_credential = DefaultAzureCredential()
         # blob_service_client = BlobServiceClient(url, credential=credential)
         _blob_service_client = BlobServiceClient(

services/uploader/azure_blob_service.py

@@ -21,16 +21,15 @@ logger = get_logger("azure blob")
 
 
 # --- Environment Variables ---
-if "azureai__container__key" not in os.environ:
-    credential=DefaultAzureCredential()
-    logger.info(f"✅ Initialized Azure AI Cred: Using **Default Credential**")
-else:
-    credential = AzureSasCredential(AzureBlobConstants.SAS_KEY)
-    logger.info(f"✅ Initialized Azure AI Cred: Using **Azure Key Credential**")
-
-
 async def get_blob_service_client() -> BlobServiceClient:
     try:
+        if "azureai__container__key" not in os.environ:
+            credential=DefaultAzureCredential()
+            logger.info(f"✅ Initialized Azure AI Cred: Using **Default Credential**")
+        else:
+            credential = AzureSasCredential(AzureBlobConstants.SAS_KEY)
+            logger.info(f"✅ Initialized Azure AI Cred: Using **Azure Key Credential**")
+
         # default_credential = DefaultAzureCredential()
         # blob_service_client = BlobServiceClient(url, credential=credential)
         _blob_service_client = BlobServiceClient(