我好像有问题BashOperator.我正在使用Conda Forge上的软件包在Miniconda环境(Python 3.6)中使用CentOS上安装的Airflow 1.10.
当我运行airflow test tutorial pyHi 2018-01-01输出时是"Hello world!" 正如所料.
但是,当我跑步airflow test tutorial print_date 2018-01-01或
airflow test tutorial templated 2018-01-01没有任何反应.
这是Linux shell输出:
(etl) [root@VIRT02 airflow]# airflow test tutorial sleep 2015-06-01
[2018-09-28 19:56:09,727] {__init__.py:51} INFO - Using executor SequentialExecutor
[2018-09-28 19:56:09,962] {models.py:258} INFO - Filling up the DagBag from /root/airflow/dags
我的DAG配置文件基于Airflow教程,如下所示.
from airfl ow import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_operator import PythonOperator
from datetime import datetime, timedelta
import test …Run Code Online (Sandbox Code Playgroud)