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.

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.