Update middleware example

This commit is contained in:
David Li committed 2019-10-08 16:42:52 -04:00
1 parent 5647837972
commit 69505a8db0
1 file changed
+4 -1
+4 -1
View File
@@ -100,6 +100,9 @@ class FlightServer(flight.FlightServerBase):
]
def do_action(self, context, action):
trace_middleware = context.get_middleware("trace")
if trace_middleware:
TraceContext.set_trace_id(trace_middleware.trace_id)
if action.type == "get-trace-id":
if self.delegate:
for result in self.delegate.do_action(action):
@@ -145,7 +148,7 @@ def main():
server = FlightServer(
args.delegate,
location=args.listen,
middleware=[TracingServerMiddlewareFactory()])
middleware={"trace": TracingServerMiddlewareFactory()})
server.serve()
elif args.command == "client":
client = flight.connect(