light9 Changeset - e8401b82e6bc

Changeset - e8401b82e6bc

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

drewp@bigasterisk.com - 20 months ago 2023-05-24 21:10:15
drewp@bigasterisk.com

attempt to deal with ClientDisconnect, which was spamming logs

1 file changed with 7 insertions and 1 deletions:

light9/collector/service.py

0 comments (0 inline, 0 general)

light9/collector/service.py

➞

Show inline comments

@@ @@ -19,12 +19,13 @@ from light9.namespaces import L9 @@
 from light9.run_local import log
 from light9.zmqtransport import parseJsonMessage
 from prometheus_client import Summary
 from rdfdb.syncedgraph.syncedgraph import SyncedGraph
 from starlette.applications import Starlette
 from starlette.endpoints import WebSocketEndpoint
 from starlette.requests import ClientDisconnect
 from starlette.responses import Response
 from starlette.routing import Route, WebSocketRoute
 from starlette.types import Receive, Scope, Send
 from starlette.websockets import WebSocket
 from starlette_exporter import PrometheusMiddleware, handle_metrics
@@ @@ -54,13 +55,18 @@ class Updates(WebSocketEndpoint, UiListe @@
     pass
 async def PutAttrs(collector: Collector, request):
     with STAT_SETATTR.time():
         client, clientSession, settings, sendTime = parseJsonMessage(collector.graph, await request.body())
         try:
             body = await request.body()
         except ClientDisconnect:
             log.warning("PUT /attrs request disconnected- ignoring")
             return Response('', status_code=400)
         client, clientSession, settings, sendTime = parseJsonMessage(collector.graph, body)
         collector.setAttrs(client, clientSession, settings, sendTime)
         return Response('', status_code=202)
 def main():
     logging.getLogger('autodepgraphapi').setLevel(logging.INFO)

0 comments (0 inline, 0 general)