Function load_monitoring_data

benchmarks/src/postprocessing/report.py:60–71

(directory: Path, cluster: Cluster)

def load_monitoring_data(directory: Path, cluster: Cluster) -> MonitoringData:
    data = {}

    for node, process in cluster.processes():
        if "monitor" == process.key:
            trace_file = node_monitoring_trace(directory, node.hostname)
            if trace_file.exists():
                with open(trace_file) as f:
                    data[node] = MonitoringRecord.deserialize_records(f)
            else:
                logging.warning(f"Monitoring trace for {node.hostname} not found at {trace_file}")
    return data