

def run(self, **kwargs):
    " This will run in a tight loop. It is expected that the subclass's\n        get_task() method will introduce a delay if the results queue is\n        empty.\n        "
    private_context_file = kwargs.get('private_context_file', None)
    self._private_context = self.get_private_context(private_context_file)
    while True:
        task = self.get_task(**kwargs)
        if (not task):
            logger.debug('Task queue is empty.')
            continue
        result = self.handle_task(task, **kwargs)
        if result:
            self.submit_result(result, **kwargs)
        self.delete_task(task)

dataset/ETHPy150Open cloudtools/nymms/nymms/probe/Probe.py Probe.run/original