UI 공기 흐름에서 수동으로 실행중인 기류에서 dag를 실행하는 중 오류가 발생했습니다.

공기 흐름 UI에서 수동으로 실행할 때 오류가 발생하고 테스트 및 백필 명령을 사용하여 성공적으로 실행 된 기류에 DAG를 만들었습니다. 내 문제에 대한 해결책은 무엇입니까? DAG는 LocalExecutor에서 실행됩니다. UI 공기 흐름에UI 공기 흐름에서 수동으로 실행중인 기류에서 dag를 실행하는 중 오류가 발생했습니다.

오류 로그 :

*** 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

실행하려는 타스크 인스턴스의 현재 상태는 + y입니까? 로그를 가져 오는 중 오류를 기반으로 실제로 실행 된 것처럼 소리가 나지 않습니다. 또한 스케줄러 (및 해당되는 경우 작업자)가 실행 중인지 확인하십시오. –

args dict에서 마지막 쉼표를 제거하려고 시도 했습니까? 나는 그것도 몇 가지 문제에 직면했다. 문제의 일부일 수도 있지만 로그 문제는 관련이 없습니다. –

@DanielHuang DAG는 LocalExecutor에서 실행 중입니다. 무엇 iam 설정 노동자 또는 시작 서비스 노동자 ..? 왜냐하면 iam이 서버 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

UI 공기 흐름에서 수동으로 실행중인 기류에서 dag를 실행하는 중 오류가 발생했습니다.

답변

관련 문제