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은 스케줄러에 대한 항목입니다. dag이 예정되지 않고있는 thats.

$ AIRFLOW_HOME/dags가 비어있는 것은 이상합니다. 모든 dags는 $ AIRFLOW_HOME/dags 디렉토리 (특히 airflow.cfg 파일에 구성된 dags 디렉토리)에 있어야합니다. 올바른 디렉토리 (dags 디렉토리)에 실제 dag를 저장하지 않는 것 같습니다.

가끔은 또한 dag가 나타나기 위해 웹 서버를 다시 시작해야 할 수도 있습니다 (그러나 여기에서는 문제가되지 않습니다).