From cb6dd239167ece03f6b4032e1f9c7665ac1400f5 Mon Sep 17 00:00:00 2001 From: Zohar Tauber Date: Fri, 27 Dec 2024 11:53:06 -0500 Subject: [PATCH] Update batch_push_results.py to read queue name from the app environment settings --- code/backend/batch/batch_push_results.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/code/backend/batch/batch_push_results.py b/code/backend/batch/batch_push_results.py index 673e6a0b8..85170ef6b 100644 --- a/code/backend/batch/batch_push_results.py +++ b/code/backend/batch/batch_push_results.py @@ -12,6 +12,7 @@ bp_batch_push_results = func.Blueprint() logger = logging.getLogger(__name__) logger.setLevel(level=os.environ.get("LOGLEVEL", "INFO").upper()) +queue_name = os.environ.get("DOCUMENT_PROCESSING_QUEUE_NAME", "doc-processing") def _get_file_name_from_message(message_body) -> str: @@ -24,7 +25,7 @@ def _get_file_name_from_message(message_body) -> str: @bp_batch_push_results.queue_trigger( - arg_name="msg", queue_name="doc-processing", connection="AzureWebJobsStorage" + arg_name="msg", queue_name=queue_name, connection="AzureWebJobsStorage" ) def batch_push_results(msg: func.QueueMessage) -> None: message_body = json.loads(msg.get_body().decode("utf-8"))