(ctx context.Context)
| 298 | // explicitly, then wait in case DoGet consumed it and is still unwinding. |
| 299 | _ = e.releaseQueryHandle(ticket) |
| 300 | _ = e.waitForSessionIdle() |
| 301 | return nil, fmt.Errorf("flight doget: %w", err) |
| 302 | } |
| 303 | |
| 304 | schema, err := flight.DeserializeSchema(info.Schema, e.alloc) |
| 305 | if err != nil { |
| 306 | cancel() |
| 307 | reader.Release() |
| 308 | _ = e.waitForSessionIdle() |
| 309 | return nil, fmt.Errorf("flight deserialize schema: %w", err) |
| 310 | } |
nothing calls this directly
no test coverage detected