SpecterQuanta/tensorflow-app-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Updates server logic
All checks were successful
Build and Push Multi-Platform Docker Image / build-and-push (push) Successful in 15s
Details

Browse Source
This commit is contained in:
Hirviturkki
2025-04-21 21:14:50 +02:00
parent 720fb915fe
commit 4ac82d6134
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server.py
View File

@@ -77,6 +77,7 @@ async def broadcast_labels_periodically():
# 1) clear stale clients # 1) clear stale clients
for pid, last_ts in list(CLIENT_LABELS_TS.items()): for pid, last_ts in list(CLIENT_LABELS_TS.items()):
if now - last_ts > STALE_TIMEOUT: if now - last_ts > STALE_TIMEOUT:
CLIENT_LABELS[pid] = [] CLIENT_LABELS[pid] = []
# Optionally also remove their timestamp entry if you don't # Optionally also remove their timestamp entry if you don't
# want them checked again until next registration/update: # want them checked again until next registration/update:
@@ -94,6 +95,7 @@ async def broadcast_labels_periodically():
ws.send(payload) for ws in CLIENTS.values() ws.send(payload) for ws in CLIENTS.values()
), return_exceptions=True) ), return_exceptions=True)
logging.debug("Broadcasted labels to %d clients", len(CLIENTS)) logging.debug("Broadcasted labels to %d clients", len(CLIENTS))
logging.info("Broadcasted labels to %d clients", len(CLIENTS))
await asyncio.sleep(1) await asyncio.sleep(1)