diff --git a/airflow/cli/commands/task_command.py b/airflow/cli/commands/task_command.py index 22e061f36adbb..de0b754c2501f 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(