File tree Expand file tree Collapse file tree 7 files changed +5
-7
lines changed
Expand file tree Collapse file tree 7 files changed +5
-7
lines changed Original file line number Diff line number Diff line change 1212from app .schemas .log_schemas import (
1313 LogEntryResponse ,
1414 LogListResponse ,
15- AnalysisSummaryResponse ,
1615 APIResponse ,
1716)
1817from app .services .log_service import LogService
Original file line number Diff line number Diff line change 22
33import logging
44import sys
5- from typing import Any , Dict
5+ from typing import Any
66
77import structlog
88from structlog .types import EventDict , Processor
Original file line number Diff line number Diff line change 11"""RabbitMQ connection management with auto-reconnect."""
22
3- import asyncio
43from typing import Optional
54
65import aio_pika
7- from aio_pika import Connection , Channel
6+ from aio_pika import Channel
87from aio_pika .abc import AbstractRobustConnection
98from tenacity import (
109 retry ,
Original file line number Diff line number Diff line change 44import json
55from typing import Callable , Optional
66
7- from aio_pika import IncomingMessage
87from aio_pika .abc import AbstractIncomingMessage
98
109from app .core .config import get_settings
Original file line number Diff line number Diff line change @@ -136,6 +136,7 @@ async def publish_to_recommendations(
136136 queue = await self .connection .declare_queue (
137137 self .settings .recommendation_queue , durable = True
138138 )
139+ print ("queue" , queue )
139140
140141 await self .connection .channel .default_exchange .publish (
141142 aio_pika .Message (
@@ -215,6 +216,8 @@ async def publish_to_alerts(
215216 self .settings .alerts_queue , durable = True
216217 )
217218
219+ print ("queue" , queue )
220+
218221 await self .connection .channel .default_exchange .publish (
219222 aio_pika .Message (
220223 body = json .dumps (message_payload ).encode (),
Original file line number Diff line number Diff line change 22
33import re
44from collections import Counter
5- from datetime import datetime , timedelta
65from typing import List , Dict , Any
76
87from app .core .config import get_settings
Original file line number Diff line number Diff line change 11"""Service for pattern operations."""
22
33from typing import List , Optional
4- from uuid import UUID
54
65from sqlalchemy import select
76from sqlalchemy .ext .asyncio import AsyncSession
You can’t perform that action at this time.
0 commit comments