Fix msg policy

Azure-Samples · Apr 4, 2024 · 3fda07f · 3fda07f
1 parent 0baec4f
commit 3fda07f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/code/backend/batch/utilities/helpers/AzureBlobStorageHelper.py b/code/backend/batch/utilities/helpers/AzureBlobStorageHelper.py
@@ -12,7 +12,7 @@
 from azure.identity import DefaultAzureCredential
 
 
-def connection_string(account_name: str = None, account_key: str = None):
+def connection_string(account_name: str, account_key: str):
     return f"DefaultEndpointsProtocol=https;AccountName={account_name};AccountKey={account_key};EndpointSuffix=core.windows.net"
 
 
@@ -32,6 +32,7 @@ def create_queue_client():
                 env_helper.AZURE_BLOB_ACCOUNT_NAME, env_helper.AZURE_BLOB_ACCOUNT_KEY
             ),
             queue_name=env_helper.DOCUMENT_PROCESSING_QUEUE_NAME,
+            message_encode_policy=BinaryBase64EncodePolicy(),
         )