(self, program=None, trainer=None)
| 2258 | return res |
| 2259 | |
| 2260 | def _dump_debug_info(self, program=None, trainer=None): |
| 2261 | with open(str(id(program)) + "_train_desc.prototxt", "w") as fout: |
| 2262 | fout.write(str(trainer)) |
| 2263 | if program._fleet_opt and "fleet_desc" in program._fleet_opt: |
| 2264 | with open("fleet_desc.prototxt", "w") as fout: |
| 2265 | fout.write(str(program._fleet_opt["fleet_desc"])) |
| 2266 | |
| 2267 | def _adjust_pipeline_resource(self, pipeline_opt, dataset, pipeline_num): |
| 2268 | filelist_length = len(dataset.dataset.get_filelist()) |
no test coverage detected