You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by as...@apache.org on 2021/06/22 13:45:59 UTC
[airflow] 09/38: Fill the "job_id" field for `airflow task run`
without `--local`/`--raw` for KubeExecutor (#16108)
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 <si...@gmail.com>
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(