diff --git a/examples/lr/train_lr.yaml b/examples/lr/train_lr.yaml index 1b13597d7..ccd59ffe9 100644 --- a/examples/lr/train_lr.yaml +++ b/examples/lr/train_lr.yaml @@ -80,7 +80,7 @@ dag: - lr_0 inputs: data: - input_data: + input_datas: task_output_artifact: - output_artifact_key: train_output_data producer_task: lr_0 diff --git a/python/fate_flow/controller/task.py b/python/fate_flow/controller/task.py index 3c3453f2f..f87fef197 100644 --- a/python/fate_flow/controller/task.py +++ b/python/fate_flow/controller/task.py @@ -120,8 +120,8 @@ def update_local(task): @staticmethod def update_launcher_config(task, launcher_name, task_parameters): # support deepspeed and other launcher - if task.f_role == "arbiter": - return + # if task.f_role == "arbiter": + # return schedule_logger(task.f_job_id).info(f"task runtime launcher name: {launcher_name}") if launcher_name and launcher_name != LauncherType.DEFAULT: task_parameters.launcher_name = task.f_launcher_name = launcher_name