def dump()

in log_analyzer/log.py [0:0]

• 21 lines of code
• 8 McCabe index (conditional complexity)

    def dump(self, filename):
        folder_path = os.path.dirname(filename)
        if folder_path and not os.path.exists(folder_path):
            os.makedirs(folder_path)
        default_folder_path = "results/mocked_workload/"
        if not os.path.exists(default_folder_path):
            os.makedirs(default_folder_path, exist_ok=True)
        if "." in filename:
            filename = os.path.basename(filename).split(".")[0]
        filename = os.path.join("results/mocked_workload/", filename)
        csv_filename = filename + "_workload.csv"
        with open(csv_filename, "w") as f:
            f.write(self.workload[0].csv_header() + "\n")
            for log_item in self.workload:
                log_item_write = copy.deepcopy(log_item)
                if(log_item_write.comm_type == CommType.computation):
                    msg_size_str = "("+' '.join(str(shape).replace(',', '') for shape in log_item_write.msg_size)+")"
                    log_item_write.msg_size = msg_size_str
                f.write(log_item_write.view_as_csv_line() + "\n")
                del log_item_write
        print(f"Workload file generated:{csv_filename}")