def get_sku_nnodes_exec_time()

in src/hpcadvisor/dataset_handler.py [0:0]


def get_sku_nnodes_exec_time(datapoints, dynamic_filters, appexectime):
    if not datapoints:
        return {}, {}, 0

    max_exectime = 0
    mydata = {}
    num_vms = {}
    # sort datapoints by nnodes

    for datapoint in datapoints:
        matched_dynamic_filter = dynamic_filter_matches(datapoint, dynamic_filters)
        if not matched_dynamic_filter:
            continue

        sku = datapoint["sku"]
        nnodes = datapoint["nnodes"]
        if appexectime:
            exectime = datapoint["appexectime"]
        else:
            exectime = datapoint["exec_time"]

        if mydata.get(sku) is None:
            mydata[sku] = []
            num_vms[sku] = []
        mydata[sku].append(int(exectime))
        num_vms[sku].append(int(nnodes))
        max_exectime = max(max_exectime, max(mydata[sku]))
    return mydata, num_vms, max_exectime