def METHOD_NAME(self, data, parent_data):
    executor = parent_data.get_one_of_inputs("executor")
    client = get_client_by_user(executor)
    if parent_data.get_one_of_inputs("language"):
        setattr(client, "language", parent_data.get_one_of_inputs("language"))
        translation.activate(parent_data.get_one_of_inputs("language"))
    config_data = data.get_one_of_inputs("all_biz_job_config")
    biz_cc_id = config_data.get("all_biz_cc_id")
    supplier_account = supplier_account_for_business(biz_cc_id)
    is_tagged_ip = config_data.get("is_tagged_ip", False)
    data.inputs.biz_cc_id = biz_cc_id
    data.inputs.is_tagged_ip = is_tagged_ip
    original_global_var = deepcopy(config_data.get("job_global_var")) or []
    global_var_list = []
    if not has_biz_set(int(biz_cc_id)):
        self.biz_scope_type = JobBizScopeType.BIZ.value
    for _value in original_global_var:
        val = loose_strip(crypto.decrypt(parse_passwd_value(_value["value"])))
        if _value["type"] == JOBV3_VAR_CATEGORY_IP:
            ip_list = self.get_ip_list(val)
            result, server = self.get_target_server_biz_set(
                executor, ip_list, supplier_account=supplier_account, logger_handle=self.logger, need_build_ip=False
            )
            if not result:
                data.outputs.ex_data = "ip查询失败, 请检查ip配置是否正确，ip_list={}".format(ip_list)
                return False
            if result:
                global_var_list.append({"id": _value["id"], "server": server})
        # 密文变量在没有修改的情况下不加入全局变量，避免脱敏字符串作为正式值进行作业执行逻辑
        elif _value.get("category") == JOBV3_VAR_CATEGORY_PASSWORD and val == "******":
            continue
        else:
            global_var_list.append({"id": _value["id"], "value": val})
    job_kwargs = {
        "bk_scope_type": self.biz_scope_type,
        "bk_scope_id": str(biz_cc_id),
        "bk_biz_id": biz_cc_id,
        "job_plan_id": config_data.get("job_plan_id"),
        "global_var_list": global_var_list,
        "callback_url": get_node_callback_url(self.root_pipeline_id, self.id, getattr(self, "version", "")),
    }
    job_result = client.jobv3.execute_job_plan(job_kwargs)
    self.logger.info("job_result: {result}, job_kwargs: {kwargs}".format(result=job_result, kwargs=job_kwargs))
    if job_result["result"]:
        job_instance_id = job_result["data"]["job_instance_id"]
        data.outputs.job_inst_url = get_job_instance_url(biz_cc_id, job_instance_id)
        data.outputs.job_inst_id = job_instance_id
        data.outputs.job_inst_name = job_result["data"]["job_instance_name"]
        data.outputs.client = client
        data.outputs.biz_cc_id = biz_cc_id
        return True
    else:
        message = job_handle_api_error("jobv3.execute_job_plan", job_kwargs, job_result)
        self.logger.error(message)
        data.outputs.ex_data = message
        return False