compass.pipeline.search.persistence#

Persistence for search results documents

Functions

build_search_manifest(runtime, jur_results, ...)

Aggregate jurisdiction search results into a report

load_search_result_jurisdictions(...)

Load saved search results indexed by jurisdiction code

load_search_shards(out_dir, jurisdictions, ...)

Inventory individual requested shards

reset_search_manifest_shards(manifest_dir, paths)

Remove one collection checkpoint and its stale aggregate manifest

validate_search_targets(targets[, num_urls])

Validate shard count targets and return search metric accessors

write_search_manifest(manifest_dir, ...)

Write a collection manifest to disk

write_search_manifest_shard(manifest_dir, ...)

Write one jurisdiction's existing search result shard format