TaskD
- def init_taskd_worker(rank_id: int, upper_limit_of_disk_in_mb: int = 5000) -> bool
- def start_taskd_worker() -> bool
- func InitTaskMonitor(rank int, upperLimitOfDiskInMb int) C.int
- func StartMonitorClient() C.int
- taskd.__version__
- taskd.python.toolkit.recover_module.recover_manager. DLRecoverManager
- report_stop_complete(code: int, msg: str, fault_ranks: dict) -> int
- report_recover_strategy(fault_ranks: dict, strategy_list: list) -> int
- report_recover_status(code: int, msg: str, fault_ranks: dict, strategy: str) -> int
- report_process_fault(fault_ranks: dict) -> int
- taskd.python.framework.agent.ms_mgr.msrun_plugin. MSRunPlugin
- __init__(self)
- register_callbacks(self, operator, func)
- start(self)
- 返回码说明