2017-12-18 13 views
0

Ich habe eine Beispiel-DAG erstellt, in der ich die DAG-Konfiguration wie folgt hatte.Meldung "Handling signal: ttou" während der DAG im Luftstrom läuft

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

Mit diesem wenn ich Luftstromwebserver laufen lasse, komme ich unter Nachricht.

/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) 

Und auch DAG da sein nur in Laufzustand.

Lassen Sie mich wissen, wenn einmal auf dieses Problem stieß und es bereits behoben.

Antwort

1

Diese Nachrichten werden erwartet. Die Signale ttou (und ttin) werden verwendet, um Gunicorn-Mitarbeiter des Webservers zu aktualisieren, damit sie DAG-Änderungen aufnehmen können. Sie können dieses Verhalten mit den Luftstromkonfigurationswerten worker_refresh_interval und worker_refresh_batch_size ändern oder deaktivieren.

Verwandte Themen