254
254
root_id_order.sort(key=operator.itemgetter(0))
255
255
# Create a record stream containing the roots to create.
258
260
new_roots_stream = _new_root_data_stream(
259
261
root_id_order, rev_id_to_root_id, parent_map, self.source, graph)
260
262
return [('texts', new_roots_stream)]