Horizontal42/netsleuth
1
0
Fork 0
mirror of https://github.com/Horizontal42/netsleuth.git synced 2026-11-10 15:42:10 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Refactor collect_path_diversity to run probes concurrently using asyncio.gather. (#25)

Browse source 
Co-authored-by: google-labs-jules[bot] <161369871+google-labs-jules[bot]@users.noreply.github.com>
This commit is contained in:
Horizontal42 2026-08-19 16:56:22 +03:00 • committed by GitHub
parent 67f677a536
commit 03d54b900c
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/netsleuth/probes/bgp_path.py
View file

@ -1,5 +1,6 @@
from __future__ import annotations from __future__ import annotations
import asyncio
import re import re
import httpx import httpx
@ -158,8 +159,9 @@ async def collect_path_diversity(
timeout: float, timeout: float,
source_ip: str | None = None, source_ip: str | None = None,
) -> PathDiversity: ) -> PathDiversity:
hops = [ coros = [
await probe_edge(client, host, timeout=timeout, source_ip=source_ip) probe_edge(client, host, timeout=timeout, source_ip=source_ip)
for _label, host in targets[:max_targets] for _label, host in targets[:max_targets]
] ]
return build_path_diversity(client_country, hops) hops = await asyncio.gather(*coros)
return build_path_diversity(client_country, list(hops))