One more debug logging message in the scheduler

This commit is contained in:
Maxime Beauchemin 2015-05-17 17:41:38 -07:00
Родитель e5b379f218
Коммит a414fd0324
1 изменённых файлов: 2 добавлений и 0 удалений

Просмотреть файл

@ -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: