4efb423f447f5ba0957e1e27272c5e674e4a8461,studio/local_queue.py,LocalQueue,has_next,#LocalQueue#,22

Before Change

        self.logger.setLevel(verbose)

    def has_next(self):
        return any(glob.glob(self.path + "/*"))

    def clean(self, timeout=0):
        while self.has_next():

After Change

    def has_next(self):
        is_active, files = self._get_queue_status()
        return is_active and len(files) > 0

    def clean(self, timeout=0):
        while self.has_next():
            self.dequeue()

Instances