Write task data.
(self, file, task)
| 639 | super().write_file_metadata(file, **kw) |
| 640 | |
| 641 | def write_task(self, file, task): |
| 642 | """Write task data.""" |
| 643 | # Gather data in parallel |
| 644 | out = task['out'] |
| 645 | data = out.gather_data() |
| 646 | # Write global data from root process |
| 647 | if self.comm.rank == 0: |
| 648 | dset = file['tasks'][task['name']] |
| 649 | dset.resize(self.file_write_num, axis=0) |
| 650 | dset[self.file_write_num-1] = data |
| 651 | |
| 652 | |
| 653 | class H5ParallelFileHandler(H5FileHandlerBase): |
nothing calls this directly
no test coverage detected