2017-12-18 2 views
0

다음과 같이 DAG를 구성한 샘플 DAG를 만들었습니다.공기 흐름에서 DAG를 실행하는 동안 "신호 처리 중"메시지가 표시됩니다.

default_args = { 
    'owner': 'airflow',   
    'depends_on_past': False, 
    'start_date': one_min_ago, 
    'email': ['[email protected]'], 
    'email_on_failure': True, 
    'email_on_retry': True, 
    'retries': 5, 
    'retry_delay': timedelta(hours=30)) 

공기 흐름 웹 서버를 실행할 때 메시지 아래에 있습니다.

/home/af_user/anaconda/lib/python3.5/site-packages/flask/exthook.py:71: 
ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use 
flask_cache instead. 
.format(x=modname), ExtDeprecationWarning 
[2017-12-18 12:41:27,967] [17328] {models.py:167} INFO - Filling up the 
DagBag from /home/af_user/airflow/dags 
[2017-12-18 12:41:28 +0000] [16648] [INFO] Handling signal: ttou 
[2017-12-18 12:41:57 +0000] [16655] [INFO] Worker exiting (pid: 16655) 

또한 DAG는 실행 상태에서만 존재합니다.

한 번만이 문제가 생겨서 이미 해결 된 적이 있다면 알려주십시오.

답변

1

해당 메시지가 필요합니다. ttou (및 ttin) 신호는 웹 서버의 gunicorn 작업자를 새로 고침하여 DAG 변경 사항을 가져 오는 데 사용됩니다. worker_refresh_intervalworker_refresh_batch_size 기류 구성 값을 사용하여이 동작을 수정하거나 비활성화 할 수 있습니다.

관련 문제