zero_error_mimic.py

import subprocess
import numpy as np
import os
import sys
import pandas as pd
from PIL import Image
import h5py
import matplotlib.pyplot as plt
from typing import List, Tuple

import torch
from torch.utils import data
from tqdm.notebook import tqdm
from pathlib import Path
from dataset.utils import pre_caption
from health_multimodal.image.data.transforms import create_chest_xray_transform_for_inference, \
    create_chest_xray_transform_for_train
from error_generator import ErrorGenerator
import json

import torch.nn as nn
from torchvision.transforms import Compose, Normalize, Resize, InterpolationMode

import sklearn
from sklearn.metrics import confusion_matrix, accuracy_score, auc, roc_auc_score, roc_curve, classification_report
from sklearn.metrics import precision_recall_curve, f1_score
from sklearn.metrics import average_precision_score

import cv2
from eval_zero import evaluate, plot_roc, accuracy, sigmoid, bootstrap, compute_cis

import torch.nn.functional as F

from dataset.utils import shuffle

CXR_FILEPATH = '../../project-files/data/test_cxr.h5'
FINAL_LABEL_PATH = '../../project-files/data/final_paths.csv'


def preprocess(img, desired_size=320):
    old_size = img.size
    ratio = float(desired_size) / max(old_size)
    new_size = tuple([int(x * ratio) for x in old_size])
    img = img.resize(new_size, Image.ANTIALIAS)
    # create a new image and paste the resized on it

    new_img = Image.new('L', (desired_size, desired_size))
    new_img.paste(img, ((desired_size - new_size[0]) // 2,
                        (desired_size - new_size[1]) // 2))
    return new_img


class CXRTestDataset(torch.utils.data.Dataset):
    """Represents an abstract HDF5 dataset.

    Input params:
        img_path: Path to hdf5 file containing images.
        label_path: Path to file containing labels
        transform: PyTorch transform to apply to every data instance (default=None).
    """

    def __init__(
            self,
            ann_file,
            transform=None,
            max_words=120
    ):
        super().__init__()
        self.max_words = max_words
        self.transforms = transform

        corpus_dir = '/COVID_8TB/sangjoon/mimic_CXR/mimic_impressions_final.csv'
        label_dir = '/COVID_8TB/sangjoon/mimic-cxr/mimic-cxr-2.0.0-chexpert.csv'
        pair_dir = './entire_pair_final.json'

        with open(pair_dir, 'r') as f:
            entire_pair = json.load(f, encoding='cp949')

        entire_texts = pd.read_csv(corpus_dir)
        entire_labels = pd.read_csv(label_dir)

        self.error_generator = ErrorGenerator(entire_texts, entire_labels, entire_pair, probability=0.05,
                                              random_state=777)

        self.img_dset = h5py.File(ann_file[0], 'r')['cxr']
        self.df = pd.read_csv(ann_file[1])

        self.index_mapping = []

        for i in range(len(self.df)):
            split = self.df.iloc[i].split
            findings = self.df.iloc[i].findings
            impression = self.df.iloc[i].impression
            views = self.df.iloc[i].views
            # if split == mode and findings != 'NONE' and impression != 'NONE' and type(findings) != float and type(impression) != float:
            if split == 'test':
                #     # if views == 'AP' or views == 'PA':
                if (impression != 'NONE' and type(impression) != float and len(
                        shuffle(pre_caption(impression, 120))) > 1):
                    self.index_mapping.append(i)

        if len(self.img_dset) != len(self.df):
            raise AssertionError()

    def __len__(self):
        return len(self.index_mapping)

    def _resize_img(self, img, scale):
        """
        Args:
            img - image as numpy array (cv2)
            scale - desired output image-size as scale x scale
        Return:
            image resized to scale x scale with shortest dimension 0-padded
        """
        size = img.shape
        max_dim = max(size)
        max_ind = size.index(max_dim)

        # Resizing
        if max_ind == 0:
            # image is heigher
            wpercent = scale / float(size[0])
            hsize = int((float(size[1]) * float(wpercent)))
            desireable_size = (scale, hsize)
        else:
            # image is wider
            hpercent = scale / float(size[1])
            wsize = int((float(size[0]) * float(hpercent)))
            desireable_size = (wsize, scale)
        resized_img = cv2.resize(
            img, desireable_size[::-1], interpolation=cv2.INTER_AREA
        )  # this flips the desireable_size vector

        # Padding
        if max_ind == 0:
            # height fixed at scale, pad the width
            pad_size = scale - resized_img.shape[1]
            left = int(np.floor(pad_size / 2))
            right = int(np.ceil(pad_size / 2))
            top = int(0)
            bottom = int(0)
        else:
            # width fixed at scale, pad the height
            pad_size = scale - resized_img.shape[0]
            top = int(np.floor(pad_size / 2))
            bottom = int(np.ceil(pad_size / 2))
            left = int(0)
            right = int(0)
        resized_img = np.pad(
            resized_img, [(top, bottom), (left, right)], "constant", constant_values=0
        )

        return resized_img

    def __getitem__(self, mapping_idx):
        # ann = self.ann[index]
        index = self.index_mapping[mapping_idx]

        image = self.img_dset[index]

        # image_path = self.ann[index]['image']
        # image = cv2.imread(str(image_path), 0)

        image = self._resize_img(image, 512)
        image = Image.fromarray(image)

        output = self.transforms(image) / 255.

        # impression
        impression = self.df.iloc[index].impression
        impression = pre_caption(impression, self.max_words)

        error_imp = self.error_generator(impression, FP=False, FN=False, L=False, E=True, M=False, train=False)
        error_imp = pre_caption(error_imp)

        if impression != error_imp:
            label = 1
        else:
            label = 0

        return output, error_imp, label


# def zeroshot_classifier(image, classnames, templates, model, context_length=120):
#     """
#     FUNCTION: zeroshot_classifier
#     -------------------------------------
#     This function outputs the weights for each of the classes based on the
#     output of the trained clip model text transformer.
#
#     args:
#     * classnames - Python list of classes for a specific zero-shot task. (i.e. ['Atelectasis',...]).
#     * templates - Python list of phrases that will be indpendently tested as input to the clip model.
#     * model - Pytorch model, full trained clip model.
#     * context_length (optional) - int, max number of tokens of text inputted into the model.
#
#     Returns PyTorch Tensor, output of the text encoder given templates.
#     """
#     with torch.no_grad():
#         image = image.to(model.device)
#
#         with torch.no_grad():
#             image_feat = model.visual_encoder(image)
#             image_embed = model.vision_proj(image_feat[:, 0, :])
#             image_embed = F.normalize(image_embed, dim=-1)
#
#         image_feats = image_feat
#
#         zeroshot_weights = []
#         # compute embedding through model for each class
#         for classname in tqdm(classnames):
#             texts = classname
#             text_input = model.tokenizer(texts, padding='max_length', truncation=True, max_length=90,
#                                    return_tensors="pt").to(
#                 model.device)
#             text_output = model.text_encoder(text_input.input_ids, attention_mask=text_input.attention_mask,
#                                              return_dict=True, mode='text')
#             text_feat = text_output.last_hidden_state
#             text_embed = F.normalize(model.text_proj(text_feat[:, 0, :]), dim=-1)
#
#             text_embeds = text_embed
#             text_feats = text_feat
#             text_atts = text_input.attention_mask
#
#             encoder_output = image_feats
#             encoder_att = torch.ones(encoder_output.size()[:-1], dtype=torch.long).to(model.device)
#
#             output_t = model.text_encoder(encoder_embeds=text_feats,
#                                           attention_mask=text_atts,
#                                           encoder_hidden_states=encoder_output,
#                                           encoder_attention_mask=encoder_att,
#                                           return_dict=True,
#                                           mode='fusion'
#                                           )
#             output_v = model.text_encoder(encoder_embeds=encoder_output,
#                                           attention_mask=encoder_att,
#                                           encoder_hidden_states=text_feats,
#                                           encoder_attention_mask=text_atts,
#                                           return_dict=True,
#                                           mode='fusion'
#                                           )
#             score_pos_t = model.itm_head_t(output_t.last_hidden_state[:, 0, :])[:, 1]
#             score_pos_v = model.itm_head_v(output_v.last_hidden_state[:, 0, :])[:, 1]
#             score_pos = (score_pos_t + score_pos_v) / 2.
#
#             zeroshot_weights.append(score_pos)
#         zeroshot_weights = torch.stack(zeroshot_weights, dim=1)
#     return zeroshot_weights

def predict(loader, model, verbose=0):
    """
    FUNCTION: predict
    ---------------------------------
    This function runs the cxr images through the model
    and computes the cosine similarities between the images
    and the text embeddings.

    args:
        * loader -  PyTorch data loader, loads in cxr images
        * model - PyTorch model, trained clip model
        * zeroshot_weights - PyTorch Tensor, outputs of text encoder for labels
        * softmax_eval (optional) - Use +/- softmax method for evaluation
        * verbose (optional) - bool, If True, will print out intermediate tensor values for debugging.

    Returns numpy array, predictions on all test data samples.
    """
    y_true = []

    y_pred = []
    with torch.no_grad():
        for i, data in enumerate(tqdm(loader)):
            image = data[0]
            texts = data[1]  # as list
            label = data[2]

            y_true.append(label.numpy())

            image = image.cuda()

            # bs = image.size(0)

            with torch.no_grad():
                image_feat = model.visual_encoder(image)
                image_embed = model.vision_proj(image_feat[:, 0, :])
                image_embed = F.normalize(image_embed, dim=-1)

            image_feats = image_feat

            logits = []

            text_input = model.tokenizer.batch_encode_plus(batch_text_or_text_pairs=texts,
                                                           add_special_tokens=True,
                                                           padding='longest',
                                                           return_tensors='pt').to(image.device)

            with torch.no_grad():
                text_output = model.text_encoder(text_input.input_ids, attention_mask=text_input.attention_mask,
                                                 return_dict=True)
                text_feat = text_output.last_hidden_state
                # text_embed = F.normalize(model.text_proj(text_feat[:, 0, :]), dim=-1)

                text_feats = text_feat
                text_atts = text_input.attention_mask

                encoder_output = image_feats
                encoder_att = torch.ones(encoder_output.size()[:-1], dtype=torch.long).cuda()

                output = model.fusion_encoder(encoder_embeds=text_feats,
                                              attention_mask=text_atts,
                                              encoder_hidden_states=encoder_output,
                                              encoder_attention_mask=encoder_att,
                                              return_dict=True,
                                              mode='fusion'
                                              )
                score = model.itm_head(output.last_hidden_state[:, 0, :])[:, 1]
                score = score.mean()
            logits.append(score.cpu().detach().numpy())
            logits = np.array(logits).squeeze()  # (num_classes,)
            # logits = sigmoid(logits)

            # norm_logits = (logits - logits.mean()) / (logits.std())
            logits = 1. - sigmoid(logits)

            # # predict
            # image_features = model.encode_image(images)
            # image_features /= image_features.norm(dim=-1, keepdim=True) # (1, 768)
            #
            # # obtain logits
            # logits = image_features @ zeroshot_weights # (1, num_classes)
            # logits = np.squeeze(logits.numpy(), axis=0) # (num_classes,)

            # if softmax_eval is False:
            #     norm_logits = (logits - logits.mean()) / (logits.std())
            #     logits = sigmoid(norm_logits)

            y_pred.append(logits)

            if verbose:
                plt.imshow(image[0][0])
                plt.show()
                print('images: ', image)
                print('images size: ', image.size())

                print('image_features size: ', image_embed.size())
                print('logits: ', logits)
                print('logits size: ', logits.size())

    y_pred = np.array(y_pred)
    return np.array(y_pred), np.array(y_true)


def run_single_prediction(model, loader):
    """
    FUNCTION: run_single_prediction
    --------------------------------------
    This function will make probability predictions for a single template
    (i.e. "has {}").

    args:
        * cxr_labels - list, labels for a specific zero-shot task. (i.e. ['Atelectasis',...])
        * template - string, template to input into model.
        * model - PyTorch model, trained clip model
        * loader - PyTorch data loader, loads in cxr images
        * softmax_eval (optional) - Use +/- softmax method for evaluation
        * context_length (optional) - int, max number of tokens of text inputted into the model.

    Returns list, predictions from the given template.
    """
    # cxr_phrase = [template]
    # zeroshot_weights = zeroshot_classifier(cxr_labels, cxr_phrase, model, context_length=context_length)
    y_pred, y_true = predict(loader, model)
    return y_pred, y_true


def process_alt_labels(alt_labels_dict, cxr_labels):
    """
        Process alt labels and return relevant info. If `alt_labels_dict` is
        None, return None.

    Returns:
    * alt_label_list : list
        List of all alternative labels
    * alt_label_idx_map : dict
        Maps alt label to idx of original label in cxr_labels
        Needed to access correct column during evaluation

    """

    if alt_labels_dict is None:
        return None, None

    def get_inverse_labels(labels_alt_map: dict):
        """
        Returns dict mapping alternative label back to actual label.
        Used for reference during evaluation.
        """
        inverse_labels_dict = {}
        for main in labels_alt_map:
            inverse_labels_dict[main] = main  # adds self to list of alt labels
            for alt in labels_alt_map[main]:
                inverse_labels_dict[alt] = main
        return inverse_labels_dict

    inv_labels_dict = get_inverse_labels(alt_labels_dict)
    alt_label_list = [w for w in inv_labels_dict.keys()]

    # create index map
    index_map = dict()
    for i, label in enumerate(cxr_labels):
        index_map[label] = i

    # make map to go from alt label directly to index
    alt_label_idx_map = dict()
    for alt_label in alt_label_list:
        alt_label_idx_map[alt_label] = index_map[inv_labels_dict[alt_label]]

    return alt_label_list, alt_label_idx_map


def run_softmax_eval(model, loader, context_length: int = 120):
    """
    Run softmax evaluation to obtain a single prediction from the model.
    """
    #  # get pos and neg phrases
    # pos = pair_template[0]
    # neg = pair_template[1]

    # get pos and neg predictions, (num_samples, num_classes)
    y_pred, labels = run_single_prediction(model, loader)

    # # compute probabilities with softmax
    # sum_pred = np.exp(pos_pred) + np.exp(neg_pred)
    # y_pred = np.exp(pos_pred) / sum_pred
    # labels = labels[:,0]

    return y_pred, labels


def run_experiment(model, cxr_labels, cxr_templates, loader, y_true, alt_labels_dict=None, softmax_eval=True,
                   context_length=120, use_bootstrap=True):
    '''
    FUNCTION: run_experiment
    ----------------------------------------
    This function runs the zeroshot experiment on each of the templates
    individually, and stores the results in a list.

    args:
        * model - PyTorch model, trained clip model
        * cxr_labels - list, labels for a specific zero-shot task. (i.e. ['Atelectasis',...])
        * cxr_templates - list, templates to input into model. If softmax_eval is True,
        this should be a list of tuples, where each tuple is a +/- pair
        * loader - PyTorch data loader, loads in cxr images
        * y_true - list, ground truth labels for test dataset
        * softmax_eval (optional) - bool, if True, will evaluate results through softmax of pos vs. neg samples.
        * context_length - int, max number of tokens of text inputted into the model.
        * use_bootstrap (optional) - bool, whether or not to use bootstrap sampling

    Returns a list of results from the experiment.
    '''

    alt_label_list, alt_label_idx_map = process_alt_labels(alt_labels_dict, cxr_labels)
    if alt_label_list is not None:
        eval_labels = alt_label_list
    else:
        eval_labels = cxr_labels

    results = []
    for template in cxr_templates:
        print('Phrase being used: ', template)

        try:
            # if softmax_eval:
            #     y_pred = run_softmax_eval(model, loader, eval_labels, template, context_length=context_length)
            #
            # else:
            # get single prediction
            y_pred, y_true = run_single_prediction(eval_labels, template, model, y_true, loader,
                                                   softmax_eval=softmax_eval, context_length=context_length)
        #             print("y_pred: ", y_pred)
        except:
            print("Argument error. Make sure cxr_templates is proper format.", sys.exc_info()[0])
            raise

        # evaluate
        if use_bootstrap:
            # compute bootstrap stats
            boot_stats = bootstrap(y_pred, y_true, eval_labels, label_idx_map=alt_label_idx_map)
            results.append(boot_stats)  # each template has a pandas array of samples
        else:
            stats = evaluate(y_pred, y_true, eval_labels)
            results.append(stats)

    return results, y_pred


def make_true_labels(
        cxr_true_labels_path: str,
        cxr_labels: List[str],
        cutlabels: bool = True
):
    """
    Loads in data containing the true binary labels
    for each pathology in `cxr_labels` for all samples. This
    is used for evaluation of model performance.

    args:
        * cxr_true_labels_path - str, path to csv containing ground truth labels
        * cxr_labels - List[str], subset of label columns to select from ground truth df
        * cutlabels - bool, if True, will keep columns of ground truth labels that correspond
            with the labels inputted through `cxr_labels`. Otherwise, drop the first column and keep remaining.

    Returns a numpy array of shape (# samples, # labels/pathologies)
        representing the binary ground truth labels for each pathology on each sample.
    """
    # create ground truth labels
    full_labels = pd.read_csv(cxr_true_labels_path)
    if cutlabels:
        full_labels = full_labels.loc[:, cxr_labels]
    else:
        full_labels.drop(full_labels.columns[0], axis=1, inplace=True)

    y_true = full_labels.to_numpy()
    return y_true


from models.model_retrieval import XVLModel
import yaml
from models.model_retrieval import XVLModel
from models.vit import interpolate_pos_embed
from models.tokenization_bert import BertTokenizer
from transformers import AutoTokenizer
from torchvision import transforms
from PIL import Image


def make(
        model_path: str,
        report_filepath: str,
        pretrained: bool = True,
        context_length: bool = 120,
):
    """
    FUNCTION: make
    -------------------------------------------
    This function makes the model, the data loader, and the ground truth labels.

    args:
        * model_path - String for directory to the weights of the trained clip model.
        * context_length - int, max number of tokens of text inputted into the model.
        * cxr_filepath - String for path to the chest x-ray images.
        * cxr_labels - Python list of labels for a specific zero-shot task. (i.e. ['Atelectasis',...])
        * pretrained - bool, whether or not model uses pretrained clip weights
        * cutlabels - bool, if True, will keep columns of ground truth labels that correspond
        with the labels inputted through `cxr_labels`. Otherwise, drop the first column and keep remaining.

    Returns model, data loader.
    """
    # load model
    # model = load_clip(
    #     model_path=model_path,
    #     pretrained=pretrained,
    #     context_length=context_length
    # )

    config = yaml.load(open('./configs/Classification.yaml', 'r'), Loader=yaml.Loader)

    model = XVLModel(config=config).cuda()

    checkpoint = torch.load(model_path, map_location='cpu')
    state_dict = checkpoint['model']

    # # reshape positional embedding to accomodate for image resolution change
    # pos_embed_reshaped = interpolate_pos_embed(state_dict['visual_encoder.pos_embed'],
    #                                            model.visual_encoder)
    # state_dict['visual_encoder.pos_embed'] = pos_embed_reshaped
    # m_pos_embed_reshaped = interpolate_pos_embed(state_dict['visual_encoder_m.pos_embed'],
    #                                              model.visual_encoder_m)
    # state_dict['visual_encoder_m.pos_embed'] = m_pos_embed_reshaped
    # state_dict = {k.replace("backbone.", ""): v for k, v in state_dict.items()}

    for key in list(state_dict.keys()):
        if 'fusion_encoder.bert' in key:
            encoder_key = key.replace('fusion_encoder.bert', 'fusion_encoder')
            state_dict[encoder_key] = state_dict[key]
            del state_dict[key]
        if 'fusion_encoder_m.bert' in key:
            encoder_key = key.replace('fusion_encoder_m.bert', 'fusion_encoder_m')
            state_dict[encoder_key] = state_dict[key]
            del state_dict[key]
    msg = model.load_state_dict(state_dict, strict=False)

    print('load checkpoint from %s' % model_path)
    print(msg)

    # # load data
    # transformations = [
    #     # means computed from sample in `cxr_stats` notebook
    #     Normalize((101.48761, 101.48761, 101.48761), (83.43944, 83.43944, 83.43944)),
    # ]
    # test_transform = transforms.Compose([
    #     transforms.Resize((config['image_res'],config['image_res']),interpolation=Image.BICUBIC),
    #     transforms.ToTensor(),
    #     ])
    #
    # # if using CLIP pretrained model
    # if pretrained:
    #     # resize to input resolution of pretrained clip model
    #     input_resolution = 224
    #     transformations.append(Resize(input_resolution, interpolation=InterpolationMode.BICUBIC))
    TRANSFORM_RESIZE = 240
    TRANSFORM_CENTER_CROP_SIZE = 224

    resize = TRANSFORM_RESIZE,
    center_crop_size = TRANSFORM_CENTER_CROP_SIZE,
    test_transform = create_chest_xray_transform_for_inference(resize, center_crop_size)

    # create dataset
    torch_dset = CXRTestDataset(
        ann_file=['/COVID_8TB/sangjoon/mimic_CXR/cxr.h5', '/COVID_8TB/sangjoon/mimic_CXR/mimic_impressions_final.csv'],
        transform=test_transform,
    )
    loader = torch.utils.data.DataLoader(torch_dset, shuffle=False)

    return model.eval(), loader


## Run the model on the data set using ensembled models
def ensemble_models(
        model_paths: List[str],
        cxr_filepath: str,
        cxr_labels: List[str],
        cxr_pair_template: Tuple[str],
        cache_dir: str = None,
        save_name: str = None,
) -> Tuple[List[np.ndarray], np.ndarray]:
    """
    Given a list of `model_paths`, ensemble model and return
    predictions. Caches predictions at `cache_dir` if location provided.

    Returns a list of each model's predictions and the averaged
    set of predictions.
    """

    predictions = []
    model_paths = sorted(model_paths)  # ensure consistency of 
    for path in model_paths:  # for each model
        model_name = Path(path).stem

        # load in model and `torch.DataLoader`
        model, loader = make(
            model_path=path,
            cxr_filepath=cxr_filepath,
        )

        # path to the cached prediction
        if cache_dir is not None:
            if save_name is not None:
                cache_path = Path(cache_dir) / f"{save_name}_{model_name}.npy"
            else:
                cache_path = Path(cache_dir) / f"{model_name}.npy"

        # if prediction already cached, don't recompute prediction
        if cache_dir is not None and os.path.exists(cache_path):
            print("Loading cached prediction for {}".format(model_name))
            y_pred = np.load(cache_path)
        else:  # cached prediction not found, compute preds
            print("Inferring model {}".format(path))
            y_pred, y_true = run_softmax_eval(model, loader, cxr_labels, cxr_pair_template)
            # if cache_dir is not None:
            #     Path(cache_dir).mkdir(exist_ok=True, parents=True)
            #     np.save(file=cache_path, arr=y_pred)
        predictions.append(y_pred)

    # compute average predictions
    y_pred_avg = np.mean(predictions, axis=0)

    return predictions, y_pred_avg, y_true


def run_zero_shot(cxr_labels, cxr_templates, model_path, cxr_filepath, final_label_path, alt_labels_dict: dict = None,
                  softmax_eval=True, context_length=120, pretrained: bool = False, use_bootstrap=True, cutlabels=True):
    """
    FUNCTION: run_zero_shot
    --------------------------------------
    This function is the main function to run the zero-shot pipeline given a dataset, 
    labels, templates for those labels, ground truth labels, and config parameters.

    args: 
        * cxr_labels - list
            labels for a specific zero-shot task. (i.e. ['Atelectasis',...])
            task can either be a string or a tuple (name of alternative label, name of label in csv)
        * cxr_templates - list, phrases that will be indpendently tested as input to the clip model. If `softmax_eval` is True, this parameter should be a 
        list of positive and negative template pairs stored as tuples. 
        * model_path - String for directory to the weights of the trained clip model. 
        * cxr_filepath - String for path to the chest x-ray images. 
        * final_label_path - String for path to ground truth labels.

        * alt_labels_dict (optional) - dict, map cxr_labels to list of alternative labels (i.e. 'Atelectasis': ['lung collapse', 'atelectatic lung', ...]) 
        * softmax_eval (optional) - bool, if True, will evaluate results through softmax of pos vs. neg samples. 
        * context_length (optional) - int, max number of tokens of text inputted into the model. 
        * pretrained (optional) - bool, whether or not model uses pretrained clip weights
        * use_bootstrap (optional) - bool, whether or not to use bootstrap sampling
        * cutlabels (optional) - bool, if True, will keep columns of ground truth labels that correspond
        with the labels inputted through `cxr_labels`. Otherwise, drop the first column and keep remaining. 

    Returns an array of results per template, each consists of a tuple containing a pandas dataframes 
    for n bootstrap samples, and another pandas dataframe with the confidence intervals for each class.
    """

    np.random.seed(97)
    # make the model, data loader, and ground truth labels
    model, loader = make(
        model_path=model_path,
        cxr_filepath=cxr_filepath,
        pretrained=pretrained,
        context_length=context_length
    )

    y_true = make_true_labels(
        cxr_true_labels_path=final_label_path,
        cxr_labels=cxr_labels,
        cutlabels=cutlabels,
    )

    # run multiphrase experiment
    results, y_pred = run_experiment(model, cxr_labels, cxr_templates, loader, y_true,
                                     alt_labels_dict=alt_labels_dict, softmax_eval=softmax_eval,
                                     context_length=context_length, use_bootstrap=use_bootstrap)
    return results, y_pred


def run_cxr_zero_shot(model_path, context_length=120, pretrained=False):
    """
    FUNCTION: run_cxr_zero_shot
    --------------------------------------
    This function runs zero-shot specifically for the cxr dataset. 
    The only difference between this function and `run_zero_shot` is that
    this function is already pre-parameterized for the 14 cxr labels evaluated
    using softmax method of positive and negative templates. 

    args: 
        * model_path - string, filepath of model being evaluated
        * context_length (optional) - int, max number of tokens of text inputted into the model. 
        * pretrained (optional) - bool, whether or not model uses pretrained clip weights
        * use_bootstrap (optional) - bool, whether or not to use bootstrap sampling

    Returns an array of labels, and an array of results per template, 
    each consists of a tuple containing a pandas dataframes 
    for n bootstrap samples, and another pandas dataframe with the confidence intervals for each class.
    """
    cxr_filepath = '/deep/group/data/med-data/test_cxr.h5'
    final_label_path = '/deep/group/data/med-data/final_paths.csv'

    cxr_labels = ['Atelectasis', 'Cardiomegaly', 'Edema', 'Fracture', 'Pleural Effusion', 'Pneumonia', 'Pneumothorax']

    # templates list of positive and negative template pairs
    cxr_templates = [('{}.', 'no {}.')]

    cxr_results = run_zero_shot(cxr_labels, cxr_templates, model_path, cxr_filepath=cxr_filepath,
                                final_label_path=final_label_path, softmax_eval=True, context_length=context_length,
                                pretrained=pretrained, use_bootstrap=False, cutlabels=True)

    return cxr_labels, cxr_results[0]