diff options
Diffstat (limited to 'services/order-executor/src/order_executor')
| -rw-r--r-- | services/order-executor/src/order_executor/main.py | 12 |
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) |