255
255
to_sf.insert_record_stream(filter_absent(from_sf.get_record_stream(
256
256
[(rev_id,) for rev_id in revs],
257
257
self.to_repository._fetch_order,
259
259
self._fetch_just_revision_texts(revs)
261
261
def _fetch_just_revision_texts(self, version_ids):