compass.pipeline.coordinator.COMPASSSearch#

class COMPASSSearch(runtime)[source]#

Bases: BaseRunMode

Search-only strategy using existing reports and shards

Parameters:

runtime (compass.pipeline.runtime.PipelineRuntime) – The runtime object containing all dependencies, configurations, and settings for the pipeline run. This object should be initialized with the user’s request and any necessary setup (e.g., folder creation, model registry construction) before being passed to the workflow. The workflow will use the runtime to access configurations such as the mode to run in, the tech being processed, model configurations, known sources, and any other relevant settings needed to execute the workflow for the specified mode.

Methods

run(jurisdictions_df)

Persist search shards and their aggregate manifest

Attributes

is_continuation_run

Indicates whether this run is a continuation run
property is_continuation_run[source]#

Indicates whether this run is a continuation run

Type:

bool

async run(jurisdictions_df)[source]#

Persist search shards and their aggregate manifest