def METHOD_NAME(self):
    self.queue = {}
    corpora = yield self.db.list_corpus(projection=[])
    dl = [self.db.get_waiting_jobs(corpus["_id"]) for corpus in corpora]
    alljobs = yield DeferredList(dl, consumeErrors=True)
    for bl, res in alljobs:
        if not bl:
            print "ERROR collecting old crawljobs for a corpus", res
        corpus, jobs = res
        for job in jobs:
            self.queue[job["_id"]] = {
              "corpus": corpus,
              "timestamp": job["created_at"],
              "crawl_arguments": job["crawl_arguments"]
            }