ran linting

rnr/src/rnr/app/api/routes/consumer.py

@@ -1,6 +1,5 @@
 from fastapi import APIRouter, BackgroundTasks, Depends
 from pydantic import BaseModel
-
 from src.rnr.app import get_consumer_manager
 from src.rnr.app.consumer_manager import ConsumerManager
 from src.rnr.app.core import get_settings

rnr/src/rnr/app/api/routes/nwps.py

@@ -1,7 +1,6 @@
 from typing import Annotated
 
 from fastapi import APIRouter, Depends
-
 from src.rnr.app.api.services.nwps import NWPSService
 from src.rnr.app.core import get_settings
 from src.rnr.app.core.settings import Settings

rnr/src/rnr/app/api/routes/publish.py

@@ -3,9 +3,11 @@
 
 from fastapi import APIRouter, Depends
 from sqlalchemy.orm import Session
-
-from src.rnr.app.api.client.pika import (close_connection, start_connection,
-                                         start_work_queues)
+from src.rnr.app.api.client.pika import (
+    close_connection,
+    start_connection,
+    start_work_queues,
+)
 from src.rnr.app.api.database import get_db
 from src.rnr.app.api.services.publish import MessagePublisherService
 from src.rnr.app.api.services.rfc import RFCReaderService

rnr/src/rnr/app/api/routes/rfc.py

@@ -1,6 +1,5 @@
 from fastapi import APIRouter, Depends
 from sqlalchemy.orm import Session
-
 from src.rnr.app.api.database import get_db
 from src.rnr.app.api.services.rfc import RFCReaderService
 from src.rnr.app.schemas import RFCDatabaseEntries

rnr/src/rnr/app/api/services/publish.py

@@ -10,8 +10,12 @@
 from src.rnr.app.core import get_settings
 from src.rnr.app.core.exceptions import NoForecastError, NWPSAPIError
 from src.rnr.app.core.settings import Settings
-from src.rnr.app.schemas import (GaugeData, GaugeForecast, ProcessedData,
-                                 RFCDatabaseEntry)
+from src.rnr.app.schemas import (
+    GaugeData,
+    GaugeForecast,
+    ProcessedData,
+    RFCDatabaseEntry,
+)
 
 _settings = get_settings()
 

rnr/src/rnr/app/api/services/replace_and_route.py

@@ -26,7 +26,7 @@ class ReplaceAndRoute:
 
     def __init__(self) -> None:
         pass
-    
+
     def create_troute_domains(self, ch, method, properties, body):
         # David TODO: Make the JSON conversion idiot-proof
         message_string = body.decode()

rnr/src/rnr/app/consumer_manager.py

@@ -1,9 +1,12 @@
 import asyncio
 
-from src.rnr.app.api.client.pika import (close_connection, start_connection,
-                                         start_work_queues)
-from src.rnr.app.api.services.replace_and_route import ReplaceAndRoute
+from src.rnr.app.api.client.pika import (
+    close_connection,
+    start_connection,
+    start_work_queues,
+)
 from src.rnr.app.api.services.error_handler import ErrorHandler
+from src.rnr.app.api.services.replace_and_route import ReplaceAndRoute
 from src.rnr.app.core.settings import Settings
 from src.rnr.app.schemas import ConsumerStatus
 

rnr/src/rnr/frontend/api/services.py

@@ -3,7 +3,6 @@
 from datetime import datetime
 
 from fastapi import Request
-
 from src.rnr.frontend.core import get_settings
 
 settings = get_settings()

rnr/tests/conftest.py

@@ -2,7 +2,6 @@
 from typing import Dict, List, Tuple, Union
 
 import pytest
-
 from src.rnr.app.schemas import RFC, WFO, ProcessedData, Status, StatusData
 
 

rnr/tests/test_nwps_service.py

@@ -3,7 +3,6 @@
 import pytest
 from fastapi.testclient import TestClient
 from httpx import ASGITransport, AsyncClient
-
 from src.rnr.app.core import get_settings
 from src.rnr.app.core.settings import Settings
 from src.rnr.app.core.utils import convert_to_m3_per_sec

rnr/tests/test_publishing.py

@@ -3,7 +3,6 @@
 import pytest
 from fastapi.testclient import TestClient
 from httpx import ASGITransport, AsyncClient
-
 from src.rnr.app.core import get_settings
 from src.rnr.app.core.settings import Settings
 from src.rnr.app.core.utils import AsyncRateLimiter

rnr/tests/test_redis.py

@@ -1,5 +1,4 @@
 import redis
-
 from src.rnr.app.core.settings import Settings
 
 test_settings = Settings()

rnr/tests/test_rfc_reader.py

@@ -3,7 +3,6 @@
 import pytest
 from fastapi.testclient import TestClient
 from httpx import ASGITransport, AsyncClient
-
 from src.rnr.app.core import get_settings
 from src.rnr.app.core.settings import Settings
 from src.rnr.app.core.utils import parse_datetime