def _run_task(self):
    self._init_mapping()
    self._init_db()
    start_step = self.options.get('start_step')
    started = False
    for (name, mapping) in self.mapping.items():
        if ((not started) and start_step and (name != start_step)):
            self.logger.info('Skipping step: {}'.format(name))
            continue
        started = True
        self.logger.info('Running Job: {}'.format(name))
        result = self._load_mapping(mapping)
        if (result != 'Completed'):
            break
def _run_task(self):
    self._init_mapping()
    self._init_db()
    start_step = self.options.get('start_step')
    started = False
    for (name, mapping) in self.mapping.items():
        if ((not started) and start_step and (name != start_step)):
            self.logger.info('Skipping step: {}'.format(name))
            continue
        started = True
        self.logger.info('Running Job: {}'.format(name))
        result = self._load_mapping(mapping)
        if (result != 'Completed'):
            break