2017-02-09 4 views
6

Я пытаюсь написать свой первый Airflow DAG, и я получаю следующее сообщение об ошибке при попытке перечислить задачи, используя команду airflow list_tasks orderwarehouse:TemplateNotFound ошибка при запуске простого Airflow BashOperator

Traceback (most recent call last): 
    File "/usr/local/lib/python2.7/site-packages/airflow/models.py", line 2038, in resolve_template_files 
    setattr(self, attr, env.loader.get_source(env, content)[0]) 
    File "/usr/local/lib/python2.7/site-packages/jinja2/loaders.py", line 187, in get_source 
    raise TemplateNotFound(template) 
TemplateNotFound: ./home/deploy/airflow-server/task_scripts/orderwarehouse/load_warehouse_tables.sh 

Это Даг не предполагается использовать шаблон. Я только пытаюсь запустить сценарий оболочки в указанном месте в соответствии с инструкциями в the docs. Скрипт оболочки существует в этом месте и правильно написан. Моя DAG выглядит так:

from airflow import DAG 
from airflow.operators.bash_operator import BashOperator 

default_args = { 
    'owner': 'airflow', 
    'depends_on_past': False, 
    'start_date': datetime(2015, 6, 1), 
    'email': ['[email protected]'], 
    'email_on_failure': False, 
    'email_on_retry': False, 
    'retries': 1, 
    'retry_delay': timedelta(minutes=5), 
    # 'queue': 'bash_queue', 
    # 'pool': 'backfill', 
    # 'priority_weight': 10, 
    # 'end_date': datetime(2016, 1, 1), 
} 

orderwarehouse = DAG('orderwarehouse', default_args=default_args) 

load_mysql = BashOperator(
    task_id='load_warehouse_mysql', 
    bash_command='./home/deploy/airflow-server/task_scripts/orderwarehouse/load_warehouse_tables.sh', 
    dag=orderwarehouse) 

Не уверен, почему он считает, что ему нужно найти шаблон Jinja. Запуск идей по этому вопросу был бы признателен, если бы кто-нибудь мог указать мне, где я сбиваюсь с пути. Благодарю.

ответ

10

Это ловушка воздушного потока. Добавить место в конце вашего bash_command, и он должен работать нормально

Источник: https://cwiki.apache.org/confluence/display/AIRFLOW/Common+Pitfalls

+1

Обнаруженный это также работает с новой строки перед именем файла! – quaintm

+0

ничего себе! благодаря! он полностью работает – NaWeeD

Смежные вопросы