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

…aw` for KubeExecutor (#16108)
apache · May 27, 2021 · cdc9f1a · cdc9f1a
1 parent 436e0d0
commit cdc9f1a
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(