diff --git a/routers/amqp.py b/routers/amqp.py index f43bec0..a4ea8ed 100644 --- a/routers/amqp.py +++ b/routers/amqp.py @@ -1,7 +1,7 @@ from datetime import datetime -from faststream.rabbit import RabbitBroker from faststream.rabbit.fastapi import Logger, RabbitRouter # type: ignore +from faststream.rabbit import RabbitBroker from faststream.rabbit.schemas.queue import RabbitQueue from pydantic import BaseModel from schema import AMQPPayload, ResponseModel @@ -54,7 +54,7 @@ async def ask(payload: Payload, logger: Logger): message=result, queue=payload.content.route.destination.queue ) except Exception as e: - logger.error(f"Errors While processing job! {e}") + logger.exception(f"Errors While processing job! {e}") else: logger.error( f"No such `{payload.event}` event available for {Queue.HIVEMIND} queue!"