From 3ed9274d84dce809e8725486d4b684af79e34af0 Mon Sep 17 00:00:00 2001 From: cybermaggedon Date: Sat, 24 May 2025 12:10:05 +0100 Subject: [PATCH] Remove much logging output in gateway (#393) --- trustgraph-flow/trustgraph/gateway/dispatch/librarian.py | 2 -- trustgraph-flow/trustgraph/gateway/dispatch/mux.py | 1 - trustgraph-flow/trustgraph/gateway/dispatch/requestor.py | 2 -- trustgraph-flow/trustgraph/gateway/dispatch/streamer.py | 2 -- trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py | 1 - .../trustgraph/gateway/endpoint/constant_endpoint.py | 4 +--- .../trustgraph/gateway/endpoint/variable_endpoint.py | 4 +--- 7 files changed, 2 insertions(+), 14 deletions(-) diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/librarian.py b/trustgraph-flow/trustgraph/gateway/dispatch/librarian.py index d33138ac..364ba1c2 100644 --- a/trustgraph-flow/trustgraph/gateway/dispatch/librarian.py +++ b/trustgraph-flow/trustgraph/gateway/dispatch/librarian.py @@ -65,8 +65,6 @@ class LibrarianRequestor(ServiceRequestor): def from_response(self, message): - print(message) - response = {} if message.document_metadata: diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/mux.py b/trustgraph-flow/trustgraph/gateway/dispatch/mux.py index e2c5a921..463d6dc9 100644 --- a/trustgraph-flow/trustgraph/gateway/dispatch/mux.py +++ b/trustgraph-flow/trustgraph/gateway/dispatch/mux.py @@ -149,7 +149,6 @@ class Mux: break try: - print(id, svc, request) await self.start_request_task( self.ws, id, flow, svc, request, workers diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/requestor.py b/trustgraph-flow/trustgraph/gateway/dispatch/requestor.py index b8a84644..35c41c8f 100644 --- a/trustgraph-flow/trustgraph/gateway/dispatch/requestor.py +++ b/trustgraph-flow/trustgraph/gateway/dispatch/requestor.py @@ -82,8 +82,6 @@ class ServiceRequestor: resp, fin = self.from_response(resp) - print(resp, fin, flush=True) - if responder: await responder(resp, fin) diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/streamer.py b/trustgraph-flow/trustgraph/gateway/dispatch/streamer.py index 60d4aff2..54674906 100644 --- a/trustgraph-flow/trustgraph/gateway/dispatch/streamer.py +++ b/trustgraph-flow/trustgraph/gateway/dispatch/streamer.py @@ -76,8 +76,6 @@ class ServiceRequestor: resp, fin = self.from_inbound(resp) - print(resp, fin) - await self.receiver(resp, fin) if fin: break diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py b/trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py index 5db84abd..7c3a5fc9 100644 --- a/trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py +++ b/trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py @@ -48,7 +48,6 @@ class TriplesQueryRequestor(ServiceRequestor): ) def from_response(self, message): - print(message) return { "response": serialize_subgraph(message.triples) }, True diff --git a/trustgraph-flow/trustgraph/gateway/endpoint/constant_endpoint.py b/trustgraph-flow/trustgraph/gateway/endpoint/constant_endpoint.py index eda9da4d..1e1d9d28 100644 --- a/trustgraph-flow/trustgraph/gateway/endpoint/constant_endpoint.py +++ b/trustgraph-flow/trustgraph/gateway/endpoint/constant_endpoint.py @@ -47,10 +47,8 @@ class ConstantEndpoint: data = await request.json() - print(data) - async def responder(x, fin): - print(x) + pass resp = await self.dispatcher.process(data, responder) diff --git a/trustgraph-flow/trustgraph/gateway/endpoint/variable_endpoint.py b/trustgraph-flow/trustgraph/gateway/endpoint/variable_endpoint.py index 8813165c..4a131d9d 100644 --- a/trustgraph-flow/trustgraph/gateway/endpoint/variable_endpoint.py +++ b/trustgraph-flow/trustgraph/gateway/endpoint/variable_endpoint.py @@ -47,10 +47,8 @@ class VariableEndpoint: data = await request.json() - print(data) - async def responder(x, fin): - print(x) + pass resp = await self.dispatcher.process( data, responder, request.match_info