This is an automated email from the ASF dual-hosted git repository. ash pushed a commit to branch v2-1-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit b9e5a2dc46b31e3589529dde5f8e1d3e2041b313 Author: Tao He <[email protected]> AuthorDate: Thu May 27 20:50:03 2021 +0800 Fill the "job_id" field for `airflow task run` without `--local`/`--raw` for KubeExecutor (#16108) (cherry picked from commit cdc9f1a33854254607fa81265a323cf1eed6d6bb) --- 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 dc38b87..ee34646 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(
