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