From a414fd032418c99bdad642908b712ca270006ada Mon Sep 17 00:00:00 2001
From: Maxime Beauchemin <maximebeauchemin@gmail.com>
Date: Sun, 17 May 2015 17:41:38 -0700
Subject: [PATCH] One more debug logging message in the scheduler

---
 airflow/executors/celery_executor.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/airflow/executors/celery_executor.py b/airflow/executors/celery_executor.py
index 8f317cec39..a124c3134d 100644
--- a/airflow/executors/celery_executor.py
+++ b/airflow/executors/celery_executor.py
@@ -57,6 +57,8 @@ class CeleryExecutor(BaseExecutor):
         self.last_state[key] = celery_states.PENDING
 
     def sync(self):
+        logging.debug(
+            "Inquiring about {} celery task(s)".format(len(self.tasks)))
         for key, async in self.tasks.items():
             if self.last_state[key] != async.state:
                 if async.state == celery_states.SUCCESS: