Я новичок в airflow и написал простой SSHOperator, чтобы узнать, как он работает.
default_args = {
'start_date': datetime(2018,6,20)
}
dag = DAG(dag_id='ssh_test', schedule_interval = '@hourly',default_args=default_args)
sshHook = SSHHook(ssh_conn_id='testing')
t1 = SSHOperator(
task_id='task1',
command='echo Hello World',
ssh_hook=sshHook,
dag=dag)
Когда я вручную запускаю его в пользовательском интерфейсе, даг показывает статус работы, но оператор остается белым, без статуса.
Мне интересно, почему моя задача не стоит в очереди. У кого-нибудь есть идеи? Мой airflow.config используется по умолчанию, если это полезная информация.
Даже это не работает
dag=DAG(dag_id='test',start_date = datetime(2018,6,21), schedule_interval='0 0 * * *')
runMe = DummyOperator(task_id = 'testest', dag = dag)
