def run(self, **kwargs):
        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)
This will run in a tight loop. It is expected that the subclass's
dataset/ETHPy150Open cloudtools/nymms/nymms/probe/Probe.py/Probe.run