(self, key: Any, descriptor: fl.FlightDescriptor)
| 93 | ) |
| 94 | |
| 95 | def _make_flight_info(self, key: Any, descriptor: fl.FlightDescriptor): |
| 96 | if len(self.tls_certificates) != 0: |
| 97 | location = fl.Location.for_grpc_tls(self.host, self.port) |
| 98 | else: |
| 99 | location = fl.Location.for_grpc_tcp(self.host, self.port) |
| 100 | endpoints = [ |
| 101 | fl.FlightEndpoint(repr(key), [location]), |
| 102 | ] |
| 103 | schema = pa.schema([]) |
| 104 | |
| 105 | return fl.FlightInfo(schema, descriptor, endpoints, -1, -1) |
| 106 | |
| 107 | @inject_user_details_decorator |
| 108 | @arrow_server_error_handling_decorator |
no test coverage detected