diff options
Diffstat (limited to 'services/portfolio-manager/src')
| -rw-r--r-- | services/portfolio-manager/src/portfolio_manager/main.py | 9 |
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) |