From 9b5928524a10e929f7d1d3d7cb3ec6ff9b1ecd25 Mon Sep 17 00:00:00 2001 From: Nikolaos Maroulis Date: Thu, 18 Dec 2025 14:56:23 +0100 Subject: [PATCH] preserve metadata field in broker message --- fasta2a/task_manager.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/fasta2a/task_manager.py b/fasta2a/task_manager.py index 54ab709..ed04241 100644 --- a/fasta2a/task_manager.py +++ b/fasta2a/task_manager.py @@ -120,7 +120,12 @@ async def send_message(self, request: SendMessageRequest) -> SendMessageResponse task = await self.storage.submit_task(context_id, message) - broker_params: TaskSendParams = {'id': task['id'], 'context_id': context_id, 'message': message} + broker_params: TaskSendParams = { + 'id': task['id'], + 'context_id': context_id, + 'message': message, + 'metadata': request['params'].get('metadata', {}), + } config = request['params'].get('configuration', {}) history_length = config.get('history_length') if history_length is not None: