From 2e01c242ef7959c06a7541d99082ef186cf2d772 Mon Sep 17 00:00:00 2001 From: Jonathan Jin Date: Thu, 5 Sep 2019 14:45:09 -0400 Subject: [PATCH] [TWTR][AIRFLOW-4939] Fixup use of fallback kwarg in conf.getint --- airflow/models.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/models.py b/airflow/models.py index 653033d7d3c92..757913b2dd36e 100755 --- a/airflow/models.py +++ b/airflow/models.py @@ -2420,7 +2420,7 @@ def __init__( ) self._schedule_interval = schedule_interval self.retries = retries if retries is not None else \ - configuration.conf.getint('core', 'default_task_retries', fallback=0) + int(configuration.conf.get('core', 'default_task_retries', fallback=0)) self.queue = queue self.pool = pool self.sla = sla