We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ee7a700 commit a60bf67Copy full SHA for a60bf67
code/backend/batch/batch_push_results.py
@@ -12,6 +12,7 @@
12
bp_batch_push_results = func.Blueprint()
13
logger = logging.getLogger(__name__)
14
logger.setLevel(level=os.environ.get("LOGLEVEL", "INFO").upper())
15
+queue_name = os.environ.get("DOCUMENT_PROCESSING_QUEUE_NAME", "doc-processing")
16
17
18
def _get_file_name_from_message(message_body) -> str:
@@ -24,7 +25,7 @@ def _get_file_name_from_message(message_body) -> str:
24
25
26
27
@bp_batch_push_results.queue_trigger(
- arg_name="msg", queue_name="doc-processing", connection="AzureWebJobsStorage"
28
+ arg_name="msg", queue_name=queue_name, connection="AzureWebJobsStorage"
29
)
30
def batch_push_results(msg: func.QueueMessage) -> None:
31
message_body = json.loads(msg.get_body().decode("utf-8"))
0 commit comments