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