def wrap_async_endpoint()

in APIs/1.0/base-py/ai4e_service.py [0:0]


    def wrap_async_endpoint(self, trace_name=None, *args, **kwargs):
        if (self.tracer):
            if (not trace_name):
                api_path = kwargs['api_path']
                trace_name = api_path

            with self.tracer.span(name=trace_name) as span:
                self._create_and_execute_thread(*args, **kwargs)
        else:
            self._create_and_execute_thread(*args, **kwargs)