lint: Improve code readability by proper linting

Author: samuelogboye

app/db/session.py

@@ -67,7 +67,6 @@ def init_db() -> None:
             environment=settings.environment,
         )
 
-
     # Create session factory
     async_session_factory = async_sessionmaker(
         engine,

app/messaging/connection.py

@@ -112,7 +112,11 @@ def channel(self) -> Optional[Channel]:
     @property
     def is_connected(self) -> bool:
         """Check if connected to RabbitMQ."""
-        return self._is_connected and self._connection is not None and not self._connection.is_closed
+        return (
+            self._is_connected
+            and self._connection is not None
+            and not self._connection.is_closed
+        )
 
     async def declare_queue(
         self, queue_name: str, durable: bool = True, auto_delete: bool = False

app/messaging/consumer.py

@@ -156,7 +156,14 @@ def _validate_message(self, data: dict) -> bool:
             message_data = data["data"]
 
             # Check required message fields
-            required_fields = ["type", "receiver", "service_name", "log_level", "message", "timestamp"]
+            required_fields = [
+                "type",
+                "receiver",
+                "service_name",
+                "log_level",
+                "message",
+                "timestamp"
+                ]
 
             if not all(field in message_data for field in required_fields):
                 return False

app/services/analysis_service.py

@@ -5,7 +5,7 @@
 from uuid import UUID
 import json
 
-from sqlalchemy import select, and_
+from sqlalchemy import select
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from app.models.analysis_result import AnalysisResult

app/services/log_service.py

@@ -143,7 +143,7 @@ async def get_unprocessed_logs(self, limit: int = 100) -> List[LogEntry]:
         """Get unprocessed log entries for batch processing."""
         query = (
             select(LogEntry)
-            .where(LogEntry.processed == False)
+            .where(LogEntry.processed.is_(False))
             .order_by(LogEntry.timestamp.asc())
             .limit(limit)
         )

app/services/pattern_service.py

@@ -77,7 +77,7 @@ async def get_active_patterns(
         self, service_name: Optional[str] = None, limit: int = 100
     ) -> List[Pattern]:
         """Get active patterns, optionally filtered by service."""
-        query = select(Pattern).where(Pattern.is_active == True)
+        query = select(Pattern).where(Pattern.is_active.is_(True))
 
         if service_name:
             query = query.where(Pattern.service_name == service_name)