6
내가 명령 airflow list_tasks orderwarehouse 사용하여 작업 목록을하려고 할 때 우리의 첫 공기 흐름 DAG를 쓰기 위해 노력하고있어, 나는 다음과 같은 오류를 받고 있어요 :TemplateNotFound 오류 실행 간단한 공기 흐름 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
이 DAG가를 템플릿을 사용하지 않아야합니다. 나는 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)
진자 템플릿을 찾아야한다고 생각하는 이유를 잘 모릅니다. 이 아이디어에 대한 아이디어가 부족하다면, 누군가 내가 타락한 곳으로 나를 가리킬 수 있다면 고맙겠습니다. 감사.
또한 발견 된 파일 이름의 앞에 개행 문자와 함께 작동! – quaintm
와우! 감사! 완전히 작동한다. – NaWeeD