Skip to content

Commit 0156a2f

Browse files
committed
Add missing session to CLI call
1 parent 79f9f86 commit 0156a2f

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

airflow/cli/commands/remote_commands/task_command.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -286,7 +286,8 @@ def _run_task_by_executor(args, dag: DAG, ti: TaskInstance) -> None:
286286
from airflow.executors import workloads
287287

288288
workload = workloads.ExecuteTask.make(ti, dag_path=dag.relative_fileloc)
289-
executor.queue_workload(workload)
289+
with create_session() as session:
290+
executor.queue_workload(workload, session)
290291
else:
291292
executor.queue_task_instance(
292293
ti,

0 commit comments

Comments
 (0)