##// END OF EJS Templates
add debug log when a task is added to the queue
MinRK -
Show More
@@ -577,6 +577,7 b' class TaskScheduler(SessionFactory):'
577 def save_unmet(self, job):
577 def save_unmet(self, job):
578 """Save a message for later submission when its dependencies are met."""
578 """Save a message for later submission when its dependencies are met."""
579 msg_id = job.msg_id
579 msg_id = job.msg_id
580 self.log.debug("Adding task %s to the queue", msg_id)
580 self.queue_map[msg_id] = job
581 self.queue_map[msg_id] = job
581 heapq.heappush(self.queue, job)
582 heapq.heappush(self.queue, job)
582 # track the ids in follow or after, but not those already finished
583 # track the ids in follow or after, but not those already finished
General Comments 0
You need to be logged in to leave comments. Login now