在气流中运行DAG时"处理信号:ttou"消息

Question

我已经创建了示例DAG,其中我有DAG配置,如下所示.

default_args = {
    'owner': 'airflow',         
    'depends_on_past': False, 
    'start_date': one_min_ago,
    'email': ['admin@airflow.com'],
    '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也将只在运行状态.

如果有人遇到过这个问题并且已经修好了,请告诉我.

Answer 1

这些消息是预期的.在ttou(和ttin)信号被用于刷新gunicorn Web服务器的工人,这样它拿起DAG变化.您可以使用worker_refresh_interval和worker_refresh_batch_sizeairflow配置值修改或禁用此行为.