def _run_task(self):
    for obj in self.options['objects']:
        self.logger.info('Deleting all {} records'.format(obj))
        delete_job = self._create_job(obj)
        if (delete_job is not None):
            self._wait_for_job(delete_job)
def _run_task(self):
    for obj in self.options['objects']:
        self.logger.info('Deleting all {} records'.format(obj))
        delete_job = self._create_job(obj)
        if (delete_job is not None):
            self._wait_for_job(delete_job)