From 6d459fc5f75a4736b567addc75dbc2a545e9734b 2013-03-29 18:24:20
From: MinRK <benjaminrk@gmail.com>
Date: 2013-03-29 18:24:20
Subject: [PATCH] add debug log when a task is added to the queue
---

diff --git a/IPython/parallel/controller/scheduler.py b/IPython/parallel/controller/scheduler.py
index 0133406..e7d8d91 100644
--- a/IPython/parallel/controller/scheduler.py
+++ b/IPython/parallel/controller/scheduler.py
@@ -577,6 +577,7 @@ class TaskScheduler(SessionFactory):
     def save_unmet(self, job):
         """Save a message for later submission when its dependencies are met."""
         msg_id = job.msg_id
+        self.log.debug("Adding task %s to the queue", msg_id)
         self.queue_map[msg_id] = job
         heapq.heappush(self.queue, job)
         # track the ids in follow or after, but not those already finished