Remove much logging output

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:

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

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)
 

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

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

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)
 

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