246
246
# yet, and are unlikely to in non-rich-root environments anyway.
247
247
root_id_order.sort(key=operator.itemgetter(0))
248
248
# Create a record stream containing the roots to create.
253
251
new_roots_stream = _new_root_data_stream(
254
252
root_id_order, rev_id_to_root_id, parent_map, self.source, graph)
255
253
return [('texts', new_roots_stream)]
267
256
def _new_root_data_stream(
268
257
root_keys_to_create, rev_id_to_root_id_map, parent_map, repo, graph=None):
269
258
"""Generate a texts substream of synthesised root entries.