Я пытаюсь написать свой первый 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. Запуск идей по этому вопросу был бы признателен, если бы кто-нибудь мог указать мне, где я сбиваюсь с пути. Благодарю.
Обнаруженный это также работает с новой строки перед именем файла! – quaintm
ничего себе! благодаря! он полностью работает – NaWeeD