26

私は初めて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)

スクリプトを実行してもエラーは表示されませんが、チェックインするとdags、[メニュー] -> [ DAGWeb-UI ]の下に表示されません

ここに画像の説明を入力

しかし、メニュー->ブラウズ->ジョブjobの下にスケジュールが表示されます。

ここに画像の説明を入力

$AIRFLOW_HOME/dags にも何も表示されません。これだけでいいのでしょうか？誰かが理由を説明できますか？

4

9 に答える 9

11

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

$AIRFLOW_HOME/dags が空であることは奇妙です。すべての dags は $AIRFLOW_HOME/dags ディレクトリ内 (具体的には、airflow.cfgファイルで構成された dags ディレクトリ内) にある必要があります。実際の dag を正しいディレクトリ (dags ディレクトリ) に保存していないようです。

または、dag を表示するために Web サーバーを再起動する必要がある場合もあります (ただし、ここでは問題ではないようです)。

于 2016-08-17T20:01:49.573 に答える
1

同じ問題がありました。ダウンロードした Airflow を 2 回、1 回は sudo なしで、もう 1 回は sudo で配置しました。ユーザーパスの下にディレクトリがあるsudoバージョンで使用していました。気流コマンドを実行しただけです: export AIRFLOW_HOME=~/airflow

于 2021-05-27T11:39:16.993 に答える