Returns provided pipeline executor statistics metadata as a dictionary. Each key in the dictionary is the operator name. To enable it use ``executor_statistics`` Available metadata keys for each operator: * ``real_memory_size`` - list of memory sizes that is used by eac
(self)
| 619 | return {k: v["epoch_size_padded"] for k, v in meta.items()} |
| 620 | |
| 621 | def executor_statistics(self): |
| 622 | """Returns provided pipeline executor statistics metadata as a dictionary. |
| 623 | Each key in the dictionary is the operator name. To enable it use ``executor_statistics`` |
| 624 | |
| 625 | Available metadata keys for each operator: |
| 626 | |
| 627 | * ``real_memory_size`` - list of memory sizes that is used by each output of |
| 628 | the operator. Index in the list corresponds to the output index. |
| 629 | |
| 630 | * ``max_real_memory_size`` - list of maximum tensor size that is used by each output of |
| 631 | the operator. Index in the list corresponds to the output index. |
| 632 | |
| 633 | * ``reserved_memory_size`` - list of memory sizes that is reserved for each of |
| 634 | the operator outputs. Index in the list corresponds to the output index. |
| 635 | |
| 636 | * ``max_reserved_memory_size`` - list of maximum memory sizes per tensor that is |
| 637 | reserved for each of the operator outputs. Index in the list corresponds to |
| 638 | the output index. |
| 639 | |
| 640 | .. note:: |
| 641 | Executor statistics are available only when ``exec_dynamic=False``. |
| 642 | """ |
| 643 | self.build() |
| 644 | return self._pipe.executor_statistics() |
| 645 | |
| 646 | def external_source_shm_statistics(self): |
| 647 | """Returns parallel external source's statistics regarding shared memory consumption. |