def flush_deferred_objects(self):
        while self.saved and self.save_later:
            try_again = []
            for msg_objlist in list(self.save_later.values()):
                for objlist in list(msg_objlist.values()):
                    try_again += objlist
            logger.info("Trying to save %d deferred objects.",
                        len(try_again))
            self.save_later = {}
            self.saved = 0
            for obj in try_again:
                obj.try_save()  # ,*args,**kw):
            logger.info("Saved %d objects.", self.saved)
Sergeant function for spawning off all the right log tailing functions.
dataset/ETHPy150Open lsaffre/lino/lino/utils/dpy.py/LoaderBase.flush_deferred_objects--crossover with--dataset/ETHPy150Open Yelp/paasta/paasta_tools/cli/cmds/logs.py/ScribeLogReader.tail_logs