Fill the "job_id" field for airflow task run without --local/`--r…

…aw` for KubeExecutor (apache#16108) (cherry picked from commit cdc9f1a) (cherry picked from commit 55fc6f6)
astronomer · Jun 2, 2021 · 7a6492e · 7a6492e
1 parent cb21b0a
commit 7a6492e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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(