faster discovery_interval, separate update_interval for tailscale

69f1fe18286721a75b7f4271dbddc2c2bc825954 · 2024-09-23 22:23:36 +0100 · Alex Cheema

Files touched

M exo/networking/tailscale_discovery.py

Diff

commit 69f1fe18286721a75b7f4271dbddc2c2bc825954
Author: Alex Cheema <alexcheema123@gmail.com>
Date:   Mon Sep 23 22:23:36 2024 +0100

    faster discovery_interval, separate update_interval for tailscale
---
 exo/networking/tailscale_discovery.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/exo/networking/tailscale_discovery.py b/exo/networking/tailscale_discovery.py
index b8348d22..cc35440c 100644
--- a/exo/networking/tailscale_discovery.py
+++ b/exo/networking/tailscale_discovery.py
@@ -16,8 +16,9 @@ class TailscaleDiscovery(Discovery):
     node_id: str,
     node_port: int,
     create_peer_handle: Callable[[str, str, DeviceCapabilities], PeerHandle],
-    discovery_interval: int = 10,
+    discovery_interval: int = 5,
     discovery_timeout: int = 30,
+    update_interval: int = 15,
     device_capabilities: DeviceCapabilities = UNKNOWN_DEVICE_CAPABILITIES,
     tailscale_api_key: str = None,
     tailnet: str = None,
@@ -27,6 +28,7 @@ class TailscaleDiscovery(Discovery):
     self.create_peer_handle = create_peer_handle
     self.discovery_interval = discovery_interval
     self.discovery_timeout = discovery_timeout
+    self.update_interval = update_interval
     self.device_capabilities = device_capabilities
     self.known_peers: Dict[str, Tuple[PeerHandle, float, float]] = {}
     self.discovery_task = None
@@ -51,7 +53,7 @@ class TailscaleDiscovery(Discovery):
         print(f"Error updating device posture attributes: {e}")
         print(traceback.format_exc())
       finally:
-        await asyncio.sleep(self.discovery_interval)
+        await asyncio.sleep(self.update_interval)
 
   async def get_device_id(self):
     if self._device_id:

← 15a2165d periodically update exo_updated_at attribute for tailscale · back to Exo · delete expired peers b480e7ed →