Как мне подключиться к SSH с помощью Airflows SSHOperator?

Question

Я пытаюсь подключиться к экземпляру ec2 с воздушным потоком с помощью SSHOperator, но мой dag не работает со следующим сообщением об ошибке:

[2020-05-24 06:17:04,191] {base_task_runner.py:98} INFO - Subtask:   File "/usr/local/lib/python3.6/site-packages/airflow/contrib/operators/ssh_operator.py", line 146, in execute
[2020-05-24 06:17:04,191] {base_task_runner.py:98} INFO - Subtask:     raise AirflowException("SSH operator error: {0}".format(str(e)))
[2020-05-24 06:17:04,191] {base_task_runner.py:98} INFO - Subtask: airflow.exceptions.AirflowException: SSH operator error: 'NoneType' object has no attribute 'exec_command'

Вот мой исходный код:

from airflow.contrib.operators.ssh_operator import SSHOperator
...

t1 = BashOperator(
    task_id='print_date',
    bash_command='date',
    dag=DAG)

t2 = SSHOperator(
    ssh_conn_id='my_ec2_connection',
    task_id='ssh_operator',
    command='ls',
    dag=DAG)

t1 >> t2

Я установил файл pem, используя соединение ssh в пользовательском интерфейсе, а также сделал ssh-add ключа pem.