在氣流中運行DAG時的「處理信號：ttou」消息

我已經創建了示例DAG，其中我具有DAG配置，如下所示。在氣流中運行DAG時的「處理信號：ttou」消息

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

有了這個當我運行airflow webserver時，我得到了下面的消息。

/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將只在運行狀態。

讓我知道是否有人曾經遇到過這個問題，並已經修復它。

來源

2017-12-18 Somashekar Muniyappa

這些消息是預期的。 ttou（和ttin）信號用於刷新網絡服務器的gunicorn工作人員，以便它接收DAG更改。您可以使用worker_refresh_interval和worker_refresh_batch_size氣流配置值修改或禁用此行爲。

來源

2018-01-04 17:30:21

在氣流中運行DAG時的「處理信號：ttou」消息

回答

相關問題