compass.pipeline.collection.persistence.load_collected_docs#

async load_collected_docs(collection_info, *, task_name)[source]#

Load all docs for one jurisdiction from collection info

Parameters:
  • collection_info (dict) – Persisted collection metadata for one jurisdiction, including a documents list of serialized document records.

  • task_name (str) – Task name applied to each asynchronous document-loading task.

Returns:

list – Loaded document objects in the same order as the persisted documents entries.