()
| 410 | |
| 411 | @staticmethod |
| 412 | def error_cases(): |
| 413 | return { |
| 414 | "internal": flight.FlightInternalError, |
| 415 | "timedout": flight.FlightTimedOutError, |
| 416 | "cancel": flight.FlightCancelledError, |
| 417 | "unauthenticated": flight.FlightUnauthenticatedError, |
| 418 | "unauthorized": flight.FlightUnauthorizedError, |
| 419 | "notimplemented": NotImplementedError, |
| 420 | "invalid": pa.ArrowInvalid, |
| 421 | "key": KeyError, |
| 422 | } |
| 423 | |
| 424 | def do_action(self, context, action): |
| 425 | error_cases = ErrorFlightServer.error_cases() |
no outgoing calls
no test coverage detected