Function isTerminalSessionIdleWaitError

server/flightclient/flight_executor.go:337–347

(err error)

	if len(args) > 0 {
		query = interpolateArgs(query, args)
	}

	reqCtx, cancel := e.mergedContext(ctx)
	defer cancel()

	reqCtx = e.withSession(reqCtx)

	// Note: we hand-roll the DoPut here instead of calling
	// flightsql.Client.ExecuteUpdate so we can capture the gRPC trailer.
	// ExecuteUpdate is a bidi-streaming RPC and grpc.Trailer(&md) as a
	// CallOption only works for unary RPCs — for streams the trailer is
	// only reachable via stream.Trailer() after Recv returns io.EOF.
	// Without that capture the worker's per-query profiling JSON is