def run(self):
        timeout = 0.2
        if is_testing():
            timeout = 0.01
        while not self.stopped:
            try:
                element = self.queue.get(timeout=timeout)
            except Queue.Empty:
                continue

            if element is not None:
                self._iterate(element)
dataset/ETHPy150Open weblabdeusto/weblabdeusto/server/src/weblab/core/coordinator/scheduler_transactions_synchronizer.py/SchedulerTransactionsSynchronizer.run/original