[bugfix]Bugfix.

consumer/asr.py

@@ -2,14 +2,13 @@ import base64
 import io
 import logging
 import os
-import uuid
 from pathlib import Path
 from typing import Literal
 
 from faster_whisper import WhisperModel
 from pydantic import BaseModel, Field, ValidationError, model_validator
 
-from .base import BasicMessageReceiver, BasicMessageSender, Headers, Priority
+from .base import BasicMessageReceiver, BasicMessageSender
 
 
 class TranscribeInputMessage(BaseModel):
@@ -61,7 +60,7 @@ class TranscribeConsumer(BasicMessageReceiver):
 
     def send_message(self, message: dict):
         routing_key = 'transcribe-output'
-        headers = Headers(job_id=f'{uuid.uuid4()}', priority=Priority.NORMAL)
+        # headers = Headers(job_id=f'{uuid.uuid4()}', priority=Priority.NORMAL)
         self.sender.send_message(
             exchange_name=self.exchange_name,
             routing_key=routing_key,

consumer/base.py

@@ -156,7 +156,7 @@ class BasicMessageSender(BasicPikaClient):
         body = self.encode_message(body=body, encoding_type=self.message_encoding_type)
 
         properties = pika.BasicProperties(delivery_mode=pika.spec.PERSISTENT_DELIVERY_MODE,
-                                          priority=headers.priority.value,
+                                          priority=headers.priority.value if headers else None,
                                           headers=headers.model_dump() if headers else None)
         self.channel.basic_publish(
             exchange=exchange_name,