エアフロー内でダグを手動で実行中エラー

テストフローとバックフィルコマンドで正常に実行されたエアフロー内にDAGを作成しましたが、エアフローUIから手動で実行するとエラーが発生します。私の問題に対する解決策はありますか？ DAGはLocalExecutorで動作します。 UIエアフローでエアフロー内でダグを手動で実行中エラー

エラーログ：

*** Log file isn't local. 
*** Fetching here: http://:8793/log/test/start/2017-10-31T09:14:32.378718 
*** Failed to fetch log file from worker. 

*** Reading remote logs... 
*** Unsupported remote log location.

コードDAG：

from airflow.models import DAG 
from airflow.operators.dummy_operator import DummyOperator 
from datetime import datetime, timedelta 

DAG_NAME = 'test' 
args = { 
    'owner': 'airflow', 
    'depends_on_past': False, 
    'start_date': datetime(2017, 10, 17), 
    'email': ['[email protected]'], 
    'email_on_failure': False, 
    'email_on_retry': False, 
    'retries': 1, 
    'retry_delay': timedelta(minutes=5), 
} 

with DAG(DAG_NAME, schedule_interval=timedelta(days=1), 
     default_args=args) as dag: 

    start = DummyOperator(
     task_id='start') 

    end = DummyOperator(
     trigger_rule='one_success', 
     task_id='end') 

    start >> end

感謝。

出典

2017-10-31 RJK

実行しようとしているタスクインスタンスの現在の状態は何ですか？ログを取得するエラーに基づいて、実際に実行されたようには聞こえません。また、スケジューラ（および該当する場合はワーカー）が実行されていることを確認します。 –

args dictの最後のカンマを削除しようとしましたか？私はそれにもいくつかの問題に直面しました。問題の一部である可能性がありますが、ログの問題は関連していない可能性があります。 –

@DanielHuang DAGはLocalExecutorで動作しています。私は何を設定労働者または開始サービスワーカー..？私はちょうどサーバーUIのエアフローを実行しているからです。 IamはCeleryExecutorを使用しません。 – RJK

あなたのタスク定義に問題がありますが、それらの任務を割り当てていません。それぞれにdag = dagを追加すれば動作します。例：

start = DummyOperator(task_id='start', dag=dag) 

end = DummyOperator(trigger_rule='one_success', task_id='end', dag=dag)

NB：労働者のログをチェックして、あなたがヒントを得ているでしょう：『dag_stats.dag_id「のIN述語が』空のシーケンスで呼び出されました。これは矛盾になり、それにもかかわらず評価するのに費用がかかります」

出典

2017-11-06 20:54:48 Breathe

エアフロー内でダグを手動で実行中エラー

答えて

関連する問題