Index

A

active_stage_name (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) add_dependencies() (onsrap.Pipeline method) (onsrap.pipeline.Pipeline method) add_stage() (onsrap.Pipeline method) (onsrap.pipeline.Pipeline method)

add_stage_config() (onsrap.Pipeline method) (onsrap.pipeline.Pipeline method) allow_subprocess_fallback (onsrap.models.PipelineConfig attribute) (onsrap.PipelineConfig attribute)

B

backend (onsrap.models.PipelineConfig attribute) (onsrap.models.RunManifest attribute) (onsrap.PipelineConfig attribute) (onsrap.RunManifest attribute) (onsrap.Stage attribute) (onsrap.stage.Stage attribute)

build_parser() (in module onsrap.runner)

C

Catalog (class in onsrap) (class in onsrap.models) completed_at (onsrap.models.PipelineRun attribute) (onsrap.PipelineRun attribute) config (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) (onsrap.models.RunManifest attribute) (onsrap.RunManifest attribute)

ConfigurationInjectionWarning contents (onsrap.Catalog attribute) (onsrap.models.Catalog attribute) create_stage_config() (onsrap.Pipeline method) (onsrap.pipeline.Pipeline method)

D

data_dir (onsrap.models.PipelineConfig attribute) (onsrap.PipelineConfig attribute) dependencies (onsrap.Stage attribute) (onsrap.stage.Stage attribute) DependencyCycleError, [1] description (onsrap.Catalog attribute) (onsrap.models.Catalog attribute)

disable_stage() (onsrap.Pipeline method) (onsrap.pipeline.Pipeline method) discover_python_entrypoint() (in module onsrap.loader) DuplicateStageError, [1] duration_seconds (onsrap.models.StageResult property) (onsrap.StageResult property)

E

enable_stage() (onsrap.Pipeline method) (onsrap.pipeline.Pipeline method) entrypoint (onsrap.Stage attribute) (onsrap.stage.Stage attribute) error (onsrap.models.StageResult attribute) (onsrap.StageResult attribute) event() (onsrap.Logger method) (onsrap.logger.Logger method) exclusion (onsrap.GlobalConfig attribute) (onsrap.models.GlobalConfig attribute)

execute() (onsrap.execution.PythonStageExecutor method) (onsrap.execution.StageExecutor method) (onsrap.PythonStageExecutor method) (onsrap.StageExecutor method) ExecutionContext (class in onsrap) (class in onsrap.execution) extract_historical_run_ids() (onsrap.Logger method) (onsrap.logger.Logger method)

F

FAILED (onsrap.models.PipelineStatus attribute) (onsrap.models.StageStatus attribute) (onsrap.PipelineStatus attribute) (onsrap.StageStatus attribute) finished_at (onsrap.models.StageResult attribute) (onsrap.StageResult attribute) from_any() (onsrap.models.PipelineConfig class method) (onsrap.PipelineConfig class method) from_callable() (onsrap.Stage class method) (onsrap.stage.Stage class method) from_config() (onsrap.Pipeline class method) (onsrap.pipeline.Pipeline class method) from_dict() (onsrap.GlobalConfig class method) (onsrap.models.GlobalConfig class method) (onsrap.Pipeline class method) (onsrap.pipeline.Pipeline class method) (onsrap.Stage class method) (onsrap.stage.Stage class method)

from_file() (onsrap.models.PipelineConfig class method) (onsrap.PipelineConfig class method) (onsrap.Stage class method) (onsrap.stage.Stage class method) from_files() (onsrap.Pipeline class method) (onsrap.pipeline.Pipeline class method) from_mapping() (onsrap.models.PipelineConfig class method) (onsrap.models.StageConfig class method) (onsrap.PipelineConfig class method) (onsrap.StageConfig class method) from_stages() (onsrap.graph.StageGraph class method) (onsrap.StageGraph class method)

G

get() (onsrap.models.StageConfig method) (onsrap.StageConfig method) get_attributes() (onsrap.GlobalConfig method) (onsrap.models.GlobalConfig method) get_data_dir() (onsrap.execution.ExecutionContext method) (onsrap.ExecutionContext method) get_hash() (onsrap.models.RuntimeID method) (onsrap.RuntimeID method) get_id() (onsrap.models.RuntimeID method) (onsrap.RuntimeID method) get_short_hash() (onsrap.models.RuntimeID method) (onsrap.RuntimeID method)

get_stage_config() (onsrap.execution.ExecutionContext method) (onsrap.ExecutionContext method) get_timestamp() (onsrap.models.RuntimeID method) (onsrap.RuntimeID method) get_variables() (onsrap.models.StageConfig method) (onsrap.StageConfig method) git_commit (onsrap.models.RunManifest attribute) (onsrap.RunManifest attribute) global_config (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) GlobalConfig (class in onsrap) (class in onsrap.models)

H

hash (onsrap.models.RuntimeID attribute) (onsrap.RuntimeID attribute)

hello_world() (in module onsrap.example_modules) (in module onsrap.example_modules.example_module) HistoricalPipelineLoadError

I

id (onsrap.models.RuntimeID attribute) (onsrap.RuntimeID attribute)

inputs (onsrap.models.RunManifest attribute) (onsrap.RunManifest attribute)

L

load_historical_run() (in module onsrap.loader) load_pipeline_run_for_historical_run() (onsrap.models.PipelineRun class method) (onsrap.PipelineRun class method) load_python_callable() (in module onsrap.loader) load_python_module() (in module onsrap.loader) log_dir (onsrap.LogConfig attribute) (onsrap.logger.LogConfig attribute) (onsrap.models.PipelineConfig attribute) (onsrap.PipelineConfig attribute)

log_level (onsrap.LogConfig attribute) (onsrap.logger.LogConfig attribute) LogConfig (class in onsrap) (class in onsrap.logger) Logger (class in onsrap) (class in onsrap.logger) logger (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) logger_name (onsrap.LogConfig attribute) (onsrap.logger.LogConfig attribute)

M

main() (in module onsrap.runner) manifest (onsrap.models.PipelineRun attribute) (onsrap.PipelineRun attribute) metadata (onsrap.models.PipelineConfig attribute) (onsrap.models.StageConfig attribute) (onsrap.models.StageResult attribute) (onsrap.PipelineConfig attribute) (onsrap.Stage attribute) (onsrap.stage.Stage attribute) (onsrap.StageConfig attribute) (onsrap.StageResult attribute) MissingDependencyError, [1] module onsrap onsrap.errors onsrap.example_modules onsrap.example_modules.example_module onsrap.execution onsrap.graph onsrap.loader onsrap.logger onsrap.models onsrap.pipeline onsrap.run_pipeline onsrap.runner onsrap.stage onsrap.warnings

N

name (onsrap.Catalog attribute) (onsrap.models.Catalog attribute) (onsrap.models.PipelineConfig attribute) (onsrap.models.StageConfig attribute) (onsrap.models.StageResult attribute) (onsrap.PipelineConfig attribute) (onsrap.Stage attribute) (onsrap.stage.Stage attribute) (onsrap.StageConfig attribute) (onsrap.StageResult attribute)

now() (in module onsrap.models)

O

onsrap module onsrap.errors module onsrap.example_modules module onsrap.example_modules.example_module module onsrap.execution module onsrap.graph module onsrap.loader module onsrap.logger module onsrap.models module onsrap.pipeline module

onsrap.run_pipeline module onsrap.runner module onsrap.stage module onsrap.warnings module OnsrapError, [1] OnsrapWarning ordered_stages() (onsrap.Pipeline method) (onsrap.pipeline.Pipeline method) output_dir (onsrap.models.PipelineConfig attribute) (onsrap.PipelineConfig attribute) outputs (onsrap.models.RunManifest attribute) (onsrap.models.StageResult attribute) (onsrap.RunManifest attribute) (onsrap.StageResult attribute) overwrite (onsrap.models.PipelineConfig attribute) (onsrap.PipelineConfig attribute)

P

package_versions (onsrap.models.RunManifest attribute) (onsrap.RunManifest attribute) parameters (onsrap.models.RunManifest attribute) (onsrap.RunManifest attribute) PENDING (onsrap.models.PipelineStatus attribute) (onsrap.models.StageStatus attribute) (onsrap.PipelineStatus attribute) (onsrap.StageStatus attribute) Pipeline (class in onsrap) (class in onsrap.pipeline) pipeline_name (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) PipelineConfig (class in onsrap) (class in onsrap.models) PipelineConfigurationError PipelineConfigurationWarning PipelineInitialisationError

PipelineRun (class in onsrap) (class in onsrap.models) PipelineRunner (class in onsrap) (class in onsrap.runner) PipelineStatus (class in onsrap) (class in onsrap.models) PipelineValidationError, [1] print_config_diffs() (in module onsrap.runner) print_favourite_number() (in module onsrap.example_modules) (in module onsrap.example_modules.example_module) print_string() (in module onsrap.example_modules) (in module onsrap.example_modules.example_module) project_root (onsrap.models.PipelineConfig attribute) (onsrap.PipelineConfig attribute) python_executable (onsrap.models.PipelineConfig attribute) (onsrap.PipelineConfig attribute) PythonStageExecutor (class in onsrap) (class in onsrap.execution)

R

rap_name (onsrap.models.RunManifest attribute) (onsrap.RunManifest attribute) RAPDataset (class in onsrap) (class in onsrap.models) reason (onsrap.models.RunManifest attribute) (onsrap.RunManifest attribute) record() (onsrap.execution.ExecutionContext method) (onsrap.ExecutionContext method) require() (onsrap.models.StageConfig method) (onsrap.StageConfig method) resolve_given_path() (onsrap.execution.ExecutionContext method) (onsrap.ExecutionContext method) resolve_output_root() (onsrap.execution.ExecutionContext method) (onsrap.ExecutionContext method) result_for() (onsrap.execution.ExecutionContext method) (onsrap.ExecutionContext method) (onsrap.models.PipelineRun method) (onsrap.PipelineRun method) return_code (onsrap.models.StageResult attribute) (onsrap.StageResult attribute)

run() (onsrap.Pipeline method) (onsrap.pipeline.Pipeline method) (onsrap.PipelineRunner method) (onsrap.runner.PipelineRunner method) (onsrap.Stage method) (onsrap.stage.Stage method) run_dir (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) run_id (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) (onsrap.models.RunManifest attribute) (onsrap.RunManifest attribute) RunManifest (class in onsrap) (class in onsrap.models) RUNNING (onsrap.models.PipelineStatus attribute) (onsrap.models.StageStatus attribute) (onsrap.PipelineStatus attribute) (onsrap.StageStatus attribute) RuntimeID (class in onsrap) (class in onsrap.models)

S

set_active_stage() (onsrap.execution.ExecutionContext method) (onsrap.ExecutionContext method) short_hash (onsrap.models.RuntimeID attribute) (onsrap.RuntimeID attribute) SKIPPED (onsrap.models.StageStatus attribute) (onsrap.StageStatus attribute) source (onsrap.models.StageResult attribute) (onsrap.Stage attribute) (onsrap.stage.Stage attribute) (onsrap.StageResult attribute) source_label (onsrap.Stage property) (onsrap.stage.Stage property) source_path (onsrap.Stage property) (onsrap.stage.Stage property) Stage (class in onsrap) (class in onsrap.stage) stage_config (onsrap.execution.ExecutionContext property) (onsrap.ExecutionContext property) stage_config_for() (onsrap.execution.ExecutionContext method) (onsrap.ExecutionContext method) stage_configs (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) stage_outputs (onsrap.execution.ExecutionContext property) (onsrap.ExecutionContext property) (onsrap.models.PipelineRun attribute) (onsrap.PipelineRun attribute) stage_results (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) (onsrap.models.PipelineRun attribute) (onsrap.PipelineRun attribute) StageConfig (class in onsrap) (class in onsrap.models) StageConfigurationError, [1] StageConfigurationWarning StageDependencyError StageExecutionError, [1]

StageExecutor (class in onsrap) (class in onsrap.execution) StageGraph (class in onsrap) (class in onsrap.graph) StageLoadError, [1] StageResult (class in onsrap) (class in onsrap.models) stages (onsrap.graph.StageGraph attribute) (onsrap.StageGraph attribute) stages_run (onsrap.models.RunManifest attribute) (onsrap.RunManifest attribute) stages_to_run (onsrap.models.PipelineConfig attribute) (onsrap.PipelineConfig attribute) StageStatus (class in onsrap) (class in onsrap.models) started_at (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) (onsrap.models.PipelineRun attribute) (onsrap.models.StageResult attribute) (onsrap.PipelineRun attribute) (onsrap.StageResult attribute) status (onsrap.models.PipelineRun attribute) (onsrap.models.StageResult attribute) (onsrap.PipelineRun attribute) (onsrap.StageResult attribute) stderr (onsrap.models.StageResult attribute) (onsrap.StageResult attribute) stdout (onsrap.models.StageResult attribute) (onsrap.StageResult attribute) succeeded (onsrap.models.PipelineRun property) SUCCEEDED (onsrap.models.PipelineStatus attribute) succeeded (onsrap.models.StageResult property) SUCCEEDED (onsrap.models.StageStatus attribute) succeeded (onsrap.PipelineRun property) SUCCEEDED (onsrap.PipelineStatus attribute) succeeded (onsrap.StageResult property) SUCCEEDED (onsrap.StageStatus attribute)

T

timestamp (onsrap.models.RunManifest attribute) (onsrap.models.RuntimeID attribute) (onsrap.RunManifest attribute) (onsrap.RuntimeID attribute) to_dict() (onsrap.models.PipelineConfig method) (onsrap.models.StageConfig method) (onsrap.PipelineConfig method) (onsrap.StageConfig method)

topological_order() (onsrap.graph.StageGraph method) (onsrap.StageGraph method)

U

user (onsrap.models.RunManifest attribute) (onsrap.RunManifest attribute)

utcnow() (in module onsrap.models)

V

validate() (onsrap.graph.StageGraph method) (onsrap.Pipeline method) (onsrap.pipeline.Pipeline method) (onsrap.Stage method) (onsrap.stage.Stage method) (onsrap.StageGraph method)

variables (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute) (onsrap.models.StageConfig property) (onsrap.StageConfig property)

W

warning() (onsrap.Logger method) (onsrap.logger.Logger method) with_dependencies() (onsrap.Stage method) (onsrap.stage.Stage method)

work_dir (onsrap.models.PipelineConfig attribute) (onsrap.PipelineConfig attribute) working_directory (onsrap.execution.ExecutionContext attribute) (onsrap.ExecutionContext attribute)