Method MarkDead

server/flightclient/flight_executor.go:125–127

MarkDead marks this executor's backing worker as dead. All subsequent RPC calls will return ErrWorkerDead without touching the (possibly closed) gRPC client.

()

	var dialOpts []grpc.DialOption
	dialOpts = append(dialOpts, grpc.WithTransportCredentials(insecure.NewCredentials()))
	dialOpts = append(dialOpts, grpc.WithDefaultCallOptions(
		grpc.MaxCallRecvMsgSize(MaxGRPCMessageSize),
		grpc.MaxCallSendMsgSize(MaxGRPCMessageSize),
	))

	// Propagate OTEL trace context across gRPC to worker pods.