Wip

levsh · Apr 17, 2024 · 241e215 · 241e215
1 parent 44ab29c
commit 241e215
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/arrlio/backends/rabbitmq.py b/arrlio/backends/rabbitmq.py
@@ -906,7 +906,7 @@ async def _on_result_message(
             properties: aiormq.spec.Basic.Properties = message.header.properties
             task_id: UUID = UUID(properties.message_id)
 
-            task_result: TaskResult = self.serializer.loads_task_result(message.body)
+            task_result: TaskResult = self.serializer.loads_task_result(message.body, headers=properties.headers)
 
             if not no_ack:
                 await channel.basic_ack(message.delivery.delivery_tag)