From 4797426d11e37392cfcaed039db9ea5511a09f81 Mon Sep 17 00:00:00 2001 From: Tao He Date: Tue, 25 May 2021 16:26:20 +0800 Subject: [PATCH] Fill the "job_id" field for `airflow task run` command. Fixes #13805, see comment https://github.com/apache/airflow/issues/13805#issuecomment-844291902. Signed-off-by: Tao He --- airflow/cli/commands/task_command.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airflow/cli/commands/task_command.py b/airflow/cli/commands/task_command.py index 6c05d7776d3ea..c0cfb03f66258 100644 --- a/airflow/cli/commands/task_command.py +++ b/airflow/cli/commands/task_command.py @@ -88,6 +88,7 @@ def _run_task_by_executor(args, dag, ti): print(e) raise e executor = ExecutorLoader.get_default_executor() + executor.job_id = "manual" executor.start() print("Sending to executor.") executor.queue_task_instance(