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