fix: lint cleanup after medium priority tasks

1 files changed, 3 insertions, 9 deletions

diff --git a/services/order-executor/src/order_executor/main.py b/services/order-executor/src/order_executor/main.py
index 930517e..3fe4c12 100644
--- a/services/order-executor/src/order_executor/main.py
+++ b/services/order-executor/src/order_executor/main.py
@@ -90,21 +90,15 @@ async def run() -> None:
                     "processing_pending_signal", signal_id=str(signal.id), symbol=signal.symbol
                 )
                 await executor.execute(signal)
-                metrics.events_processed.labels(
-                    service="order-executor", event_type="signal"
-                ).inc()
+                metrics.events_processed.labels(service="order-executor", event_type="signal").inc()
             await broker.ack(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="order-executor", error_type="processing"
-            ).inc()
+            metrics.errors_total.labels(service="order-executor", error_type="processing").inc()
 
     try:
         while True:
-            messages = await broker.read_group(
-                stream, GROUP, CONSUMER, count=10, block=5000
-            )
+            messages = await broker.read_group(stream, GROUP, CONSUMER, count=10, block=5000)
             for msg_id, msg in messages:
                 try:
                     event = Event.from_dict(msg)