def _run_task(self):
    self._init_mapping()
    self._init_db()
    for mapping in self.mappings.values():
        soql = self._soql_for_mapping(mapping)
        self._run_query(soql, mapping)
    self._drop_sf_id_columns()
    if self.options.get('sql_path'):
        self._sqlite_dump()
def _run_task(self):
    self._init_mapping()
    self._init_db()
    for mapping in self.mappings.values():
        soql = self._soql_for_mapping(mapping)
        self._run_query(soql, mapping)
    self._drop_sf_id_columns()
    if self.options.get('sql_path'):
        self._sqlite_dump()