diff --git a/app/routers/contacts.py b/app/routers/contacts.py index 3594d24..5724f7d 100644 --- a/app/routers/contacts.py +++ b/app/routers/contacts.py @@ -295,7 +295,6 @@ async def request_telemetry(public_key: str, request: TelemetryRequest) -> Telem if status: break logger.debug("Status request timeout, retrying...") - await asyncio.sleep(REPEATER_OP_DELAY_SECONDS) if not status: raise HTTPException( @@ -305,9 +304,6 @@ async def request_telemetry(public_key: str, request: TelemetryRequest) -> Telem logger.info("Received telemetry from %s: %s", contact.public_key[:12], status) - # Wait before next request - await asyncio.sleep(REPEATER_OP_DELAY_SECONDS) - # Fetch neighbors (fetch_all_neighbours handles pagination) logger.info("Fetching neighbors from repeater %s", contact.public_key[:12]) neighbors_data = None @@ -321,7 +317,6 @@ async def request_telemetry(public_key: str, request: TelemetryRequest) -> Telem if neighbors_data: break logger.debug("Neighbors request timeout, retrying...") - await asyncio.sleep(REPEATER_OP_DELAY_SECONDS) # Process neighbors - resolve pubkey prefixes to contact names neighbors: list[NeighborInfo] = [] @@ -338,9 +333,6 @@ async def request_telemetry(public_key: str, request: TelemetryRequest) -> Telem last_heard_seconds=n.get("secs_ago", 0), )) - # Wait before next request - await asyncio.sleep(REPEATER_OP_DELAY_SECONDS) - # Fetch ACL logger.info("Fetching ACL from repeater %s", contact.public_key[:12]) acl_data = None @@ -354,7 +346,6 @@ async def request_telemetry(public_key: str, request: TelemetryRequest) -> Telem if acl_data: break logger.debug("ACL request timeout, retrying...") - await asyncio.sleep(REPEATER_OP_DELAY_SECONDS) # Process ACL - resolve pubkey prefixes to contact names acl_entries: list[AclEntry] = []