apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-04-27 17:36:23 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Remove much logging output in gateway (#393)

Browse source
This commit is contained in:
cybermaggedon 2025-05-24 12:10:05 +01:00 • committed by GitHub
parent 448819ed47
commit 3ed9274d84
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
7 changed files with 2 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

2
trustgraph-flow/trustgraph/gateway/dispatch/librarian.py
View file

@ -65,8 +65,6 @@ class LibrarianRequestor(ServiceRequestor):
def from_response(self, message):
print(message)
response = {}
if message.document_metadata:

1
trustgraph-flow/trustgraph/gateway/dispatch/mux.py
View file

@ -149,7 +149,6 @@ class Mux:
break
try:
print(id, svc, request)
await self.start_request_task(
self.ws, id, flow, svc, request, workers

2
trustgraph-flow/trustgraph/gateway/dispatch/requestor.py
View file

@ -82,8 +82,6 @@ class ServiceRequestor:
resp, fin = self.from_response(resp)
print(resp, fin, flush=True)
if responder:
await responder(resp, fin)

2
trustgraph-flow/trustgraph/gateway/dispatch/streamer.py
View file

@ -76,8 +76,6 @@ class ServiceRequestor:
resp, fin = self.from_inbound(resp)
print(resp, fin)
await self.receiver(resp, fin)
if fin: break

1
trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py
View file

@ -48,7 +48,6 @@ class TriplesQueryRequestor(ServiceRequestor):
)
def from_response(self, message):
print(message)
return {
"response": serialize_subgraph(message.triples)
}, True

4
trustgraph-flow/trustgraph/gateway/endpoint/constant_endpoint.py
View file

@ -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)

4
trustgraph-flow/trustgraph/gateway/endpoint/variable_endpoint.py
View file

@ -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