Show More
@@ -577,6 +577,7 b' class TaskScheduler(SessionFactory):' | |||
|
577 | 577 | def save_unmet(self, job): |
|
578 | 578 | """Save a message for later submission when its dependencies are met.""" |
|
579 | 579 | msg_id = job.msg_id |
|
580 | self.log.debug("Adding task %s to the queue", msg_id) | |
|
580 | 581 | self.queue_map[msg_id] = job |
|
581 | 582 | heapq.heappush(self.queue, job) |
|
582 | 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