[TWTR][AIRFLOW-4939] Fixup use of fallback kwarg in conf.getint

Sampreeth24 · Sep 5, 2019 · 2e01c24 · 2e01c24
1 parent 93f2f29
commit 2e01c24
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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