TaskD Manager Interface

def init_taskd_manager(config:dict) -> bool:

Function Description

The user-side code calls this function to initializeTaskD Manager.

Input Parameters

Table 1 Parameter description

Parameter	Type	Description
config	dict:{str : str}	TaskD Manager configuration information, passed in as key-value pairs. The keys include: job_id: string type, indicating the job ID. node_nums: int type, indicating the number of nodes. proc_per_node: int type, indicating the number of processes per node. plugin_dir: string type, indicating the plugin directory. fault_recover: string type, indicating the fault recovery policy. taskd_enable: string type, indicating the switch for the TaskD process-level recovery feature. cluster_infos: dict type, indicating cluster information. The keys of cluster_infos are ip (the IP address of the current node), port (the server port), name (the server name), and role (the server role), all of which are string types.

Return Value

Table 2 Return value description

Return Value Type	Description
bool	Indicates whether the initialization is successful. True: Initialization succeeded. False: Initialization failed.

def start_taskd_manager() -> bool:

Function Description

The user-side code calls this function to start TaskD Manager.

Input Parameters

None

Return Value

Table 1 Return value description

Return Value Type	Description
bool	Indicates whether the startup was successful. True: Startup succeed. False: Startup failed.