fix: lint cleanup after medium priority tasks

1 files changed, 2 insertions, 7 deletions

diff --git a/services/portfolio-manager/src/portfolio_manager/main.py b/services/portfolio-manager/src/portfolio_manager/main.py
index 87e4c64..a6823ae 100644
--- a/services/portfolio-manager/src/portfolio_manager/main.py
+++ b/services/portfolio-manager/src/portfolio_manager/main.py
@@ -1,7 +1,6 @@
 """Portfolio Manager Service entry point."""
 
 import asyncio
-from decimal import Decimal
 
 from shared.broker import RedisBroker
 from shared.db import Database
@@ -111,15 +110,11 @@ async def run() -> None:
             await broker.ack(ORDERS_STREAM, GROUP, msg_id)
         except Exception as exc:
             log.error("pending_process_failed", error=str(exc), msg_id=msg_id)
-            metrics.errors_total.labels(
-                service="portfolio-manager", error_type="processing"
-            ).inc()
+            metrics.errors_total.labels(service="portfolio-manager", error_type="processing").inc()
 
     try:
         while True:
-            messages = await broker.read_group(
-                ORDERS_STREAM, GROUP, CONSUMER, count=10, block=1000
-            )
+            messages = await broker.read_group(ORDERS_STREAM, GROUP, CONSUMER, count=10, block=1000)
             for msg_id, msg in messages:
                 try:
                     event = Event.from_dict(msg)