def METHOD_NAME(self):
    if self.options["cached"]:
        requests_cache.install_cache("tprek")
    queryset = Place.objects.filter(data_source=self.data_source)
    if self.options.get("single", None):
        obj_id = self.options["single"]
        obj_list = [self.pk_get("unit", obj_id)]
        queryset = queryset.filter(id=obj_id)
    else:
        logger.info("Loading units...")
        obj_list = self.pk_get("unit")
        logger.info("%s units loaded" % len(obj_list))
    syncher = ModelSyncher(
        queryset,
        lambda obj: obj.origin_id,
        delete_func=self.mark_deleted,
        check_deleted_func=self.check_deleted,
    )
    for idx, info in enumerate(obj_list):
        if idx and (idx % 1000) == 0:
            logger.info("%s units processed" % idx)
        self._import_unit(syncher, info)
    syncher.finish(self.options.get("remap", False))