小编Joe*_*fer的帖子

Airflow BashOperator不起作用,但PythonOperator也可以

我好像有问题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-01airflow 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)

python linux bash airflow

4
推荐指数
1
解决办法
1229
查看次数

标签 统计

airflow ×1

bash ×1

linux ×1

python ×1