Web-UIでDAGが表示されない

Question

Airflowを初めて使用しています。私はチュートリアルに続き、次のコードを書いています。

from airflow import DAG 
from airflow.operators.python_operator import PythonOperator 
from datetime import datetime, timedelta 
from models.correctness_prediction import CorrectnessPrediction 

default_args = { 
    'owner': 'abc', 
    'depends_on_past': False, 
    'start_date': datetime.now(), 
    'email': ['abc@xyz.com'], 
    'email_on_failure': False, 
    'email_on_retry': False, 
    'retries': 1, 
    'retry_delay': timedelta(minutes=5) 
} 

def correctness_prediction(arg): 
    CorrectnessPrediction.train() 

dag = DAG('daily_processing', default_args=default_args) 

task_1 = PythonOperator(
    task_id='print_the_context', 
    provide_context=True, 
    python_callable=correctness_prediction, 
    dag=dag) 

スクリプトを実行するには、それはすべてのエラーを表示しませんが、私はWeb-UIにdogsをチェックするときには、メニューの下表示されません - >のDAG

をしかし、私はスケジュールjobの下にを見ることができますメニュー - >閲覧 - >ジョブズも

私は$ AIRFLOW_HOME/DAGの中で何を見ることができません。それはこれだけのようになっていますか？なぜ誰かが説明できますか？

Answer 1

ジョブページに表示されるScheduleJobは、スケジューラのエントリです。ダグは予定されていません。

あなたの$ AIRFLOW_HOME/dagsが空であることは間違いありません。すべてのダグは$ AIRFLOW_HOME/dagsディレクトリ（具体的には、airflow.cfgファイルに設定されているダグ・ディレクトリ）内になければなりません。右のディレクトリ（dagsディレクトリ）に実際のダグを格納していないように見えます。

また、ダグが表示されるようにWebサーバーを再起動する必要がある場合もあります（ただし、ここで問題はないようです）。