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