diff --git a/trustgraph-flow/trustgraph/gateway/endpoint.py b/trustgraph-flow/trustgraph/gateway/endpoint.py
index 6d6ca8d5..1f38c489 100644
--- a/trustgraph-flow/trustgraph/gateway/endpoint.py
+++ b/trustgraph-flow/trustgraph/gateway/endpoint.py
@@ -53,10 +53,10 @@ class ServiceEndpoint:
 
             print(data)
 
-            def responder(x, fin):
+            async def responder(x, fin):
                 print(x)
 
-            resp, fin = await self.requestor.process(data, responder)
+            resp = await self.requestor.process(data, responder)
 
             return web.json_response(resp)