Launch multiple tasks and summarize the results. Args: tasks (list[dict]): A list of task configs, usually generated by Partitioner.
(self, tasks: List[Dict[str, Any]])
| 29 | self.lark_reporter = None |
| 30 | |
| 31 | def __call__(self, tasks: List[Dict[str, Any]]): |
| 32 | """Launch multiple tasks and summarize the results. |
| 33 | |
| 34 | Args: |
| 35 | tasks (list[dict]): A list of task configs, usually generated by |
| 36 | Partitioner. |
| 37 | """ |
| 38 | status = self.launch(tasks) |
| 39 | status_list = list(status) # change into list format |
| 40 | self.summarize(status_list) |
| 41 | |
| 42 | @abstractmethod |
| 43 | def launch(self, tasks: List[Dict[str, Any]]) -> List[Tuple[str, int]]: |