From 61b2a193e79d74783bb1ad4c3a8ccb6ead0f24c0 Mon Sep 17 00:00:00 2001 From: TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com> Date: Wed, 1 Apr 2026 17:57:43 +0900 Subject: fix: lint cleanup after medium priority tasks --- services/order-executor/src/order_executor/main.py | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) (limited to 'services/order-executor/src') 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) -- cgit v1.2.3