6
मैं हमारी पहली वायु प्रवाह DAG लिखने के लिए जब मैं आदेश airflow list_tasks orderwarehouse का उपयोग कर कार्यों को सूचीबद्ध करने की कोशिश कोशिश कर रहा हूँ, और मैं निम्नलिखित त्रुटि हो रही है: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