func consumeExecutePlanClient()

in client/sql/sparksession.go [171:183]

• 13 lines of code
• 4 McCabe index (conditional complexity)

func consumeExecutePlanClient(responseClient proto.SparkConnectService_ExecutePlanClient) error {
	for {
		_, err := responseClient.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				return nil
			} else {
				return fmt.Errorf("failed to receive plan execution response: %w", err)
			}
		}
	}
	return nil
}