onsrap

• onsrap package
  • Catalog
    • Catalog.contents
    • Catalog.description
    • Catalog.name
  • DependencyCycleError
  • DuplicateStageError
  • ExecutionContext
    • ExecutionContext.active_stage_name
    • ExecutionContext.config
    • ExecutionContext.get_data_dir()
    • ExecutionContext.get_stage_config()
    • ExecutionContext.global_config
    • ExecutionContext.logger
    • ExecutionContext.pipeline_name
    • ExecutionContext.record()
    • ExecutionContext.resolve_given_path()
    • ExecutionContext.resolve_output_root()
    • ExecutionContext.result_for()
    • ExecutionContext.run_dir
    • ExecutionContext.run_id
    • ExecutionContext.set_active_stage()
    • ExecutionContext.stage_config
    • ExecutionContext.stage_config_for()
    • ExecutionContext.stage_configs
    • ExecutionContext.stage_outputs
    • ExecutionContext.stage_results
    • ExecutionContext.started_at
    • ExecutionContext.variables
    • ExecutionContext.working_directory
  • GlobalConfig
    • GlobalConfig.exclusion
    • GlobalConfig.from_dict()
    • GlobalConfig.get_attributes()
  • LogConfig
    • LogConfig.log_dir
    • LogConfig.log_level
    • LogConfig.logger_name
  • Logger
    • Logger.event()
    • Logger.extract_historical_run_ids()
    • Logger.warning()
  • MissingDependencyError
  • OnsrapError
  • Pipeline
    • Pipeline.add_dependencies()
    • Pipeline.add_stage()
    • Pipeline.add_stage_config()
    • Pipeline.create_stage_config()
    • Pipeline.disable_stage()
    • Pipeline.enable_stage()
    • Pipeline.from_config()
    • Pipeline.from_dict()
    • Pipeline.from_files()
    • Pipeline.ordered_stages()
    • Pipeline.run()
    • Pipeline.validate()
  • PipelineConfig
    • PipelineConfig.allow_subprocess_fallback
    • PipelineConfig.backend
    • PipelineConfig.data_dir
    • PipelineConfig.from_any()
    • PipelineConfig.from_file()
    • PipelineConfig.from_mapping()
    • PipelineConfig.log_dir
    • PipelineConfig.metadata
    • PipelineConfig.name
    • PipelineConfig.output_dir
    • PipelineConfig.overwrite
    • PipelineConfig.project_root
    • PipelineConfig.python_executable
    • PipelineConfig.stages_to_run
    • PipelineConfig.to_dict()
    • PipelineConfig.work_dir
  • PipelineRun
    • PipelineRun.completed_at
    • PipelineRun.load_pipeline_run_for_historical_run()
    • PipelineRun.manifest
    • PipelineRun.result_for()
    • PipelineRun.stage_outputs
    • PipelineRun.stage_results
    • PipelineRun.started_at
    • PipelineRun.status
    • PipelineRun.succeeded
  • PipelineRunner
    • PipelineRunner.run()
  • PipelineStatus
    • PipelineStatus.FAILED
    • PipelineStatus.PENDING
    • PipelineStatus.RUNNING
    • PipelineStatus.SUCCEEDED
  • PipelineValidationError
  • PythonStageExecutor
    • PythonStageExecutor.execute()
  • RAPDataset
  • RunManifest
    • RunManifest.backend
    • RunManifest.config
    • RunManifest.git_commit
    • RunManifest.inputs
    • RunManifest.outputs
    • RunManifest.package_versions
    • RunManifest.parameters
    • RunManifest.rap_name
    • RunManifest.reason
    • RunManifest.run_id
    • RunManifest.stages_run
    • RunManifest.timestamp
    • RunManifest.user
  • RuntimeID
    • RuntimeID.get_hash()
    • RuntimeID.get_id()
    • RuntimeID.get_short_hash()
    • RuntimeID.get_timestamp()
    • RuntimeID.hash
    • RuntimeID.id
    • RuntimeID.short_hash
    • RuntimeID.timestamp
  • Stage
    • Stage.backend
    • Stage.dependencies
    • Stage.entrypoint
    • Stage.from_callable()
    • Stage.from_dict()
    • Stage.from_file()
    • Stage.metadata
    • Stage.name
    • Stage.run()
    • Stage.source
    • Stage.source_label
    • Stage.source_path
    • Stage.validate()
    • Stage.with_dependencies()
  • StageConfig
    • StageConfig.from_mapping()
    • StageConfig.get()
    • StageConfig.get_variables()
    • StageConfig.metadata
    • StageConfig.name
    • StageConfig.require()
    • StageConfig.to_dict()
    • StageConfig.variables
  • StageConfigurationError
  • StageExecutionError
  • StageExecutor
    • StageExecutor.execute()
  • StageGraph
    • StageGraph.from_stages()
    • StageGraph.stages
    • StageGraph.topological_order()
    • StageGraph.validate()
  • StageLoadError
  • StageResult
    • StageResult.duration_seconds
    • StageResult.error
    • StageResult.finished_at
    • StageResult.metadata
    • StageResult.name
    • StageResult.outputs
    • StageResult.return_code
    • StageResult.source
    • StageResult.started_at
    • StageResult.status
    • StageResult.stderr
    • StageResult.stdout
    • StageResult.succeeded
  • StageStatus
    • StageStatus.FAILED
    • StageStatus.PENDING
    • StageStatus.RUNNING
    • StageStatus.SKIPPED
    • StageStatus.SUCCEEDED
  • Subpackages
    • onsrap.example_modules package
      • hello_world()
      • print_favourite_number()
      • print_string()
      • Submodules
  • Submodules
    • onsrap.errors module
      • DependencyCycleError
      • DuplicateStageError
      • HistoricalPipelineLoadError
      • MissingDependencyError
      • OnsrapError
      • PipelineConfigurationError
      • PipelineInitialisationError
      • PipelineValidationError
      • StageConfigurationError
      • StageDependencyError
      • StageExecutionError
      • StageLoadError
    • onsrap.execution module
      • ExecutionContext
      • PythonStageExecutor
      • StageExecutor
    • onsrap.graph module
      • StageGraph
    • onsrap.loader module
      • discover_python_entrypoint()
      • load_historical_run()
      • load_python_callable()
      • load_python_module()
    • onsrap.logger module
      • LogConfig
      • Logger
    • onsrap.models module
      • Catalog
      • GlobalConfig
      • PipelineConfig
      • PipelineRun
      • PipelineStatus
      • RAPDataset
      • RunManifest
      • RuntimeID
      • StageConfig
      • StageResult
      • StageStatus
      • now()
      • utcnow()
    • onsrap.pipeline module
      • Pipeline
    • onsrap.run_pipeline module
    • onsrap.runner module
      • PipelineRunner
      • build_parser()
      • main()
      • print_config_diffs()
    • onsrap.stage module
      • Stage
    • onsrap.warnings module
      • ConfigurationInjectionWarning
      • OnsrapWarning
      • PipelineConfigurationWarning
      • StageConfigurationWarning