Index

A

abort (otter.task.model.TaskContext attribute) abort() (otter.task.task_reporter.TaskReporter method) ABORTED (otter.manifest.model.Result attribute)

add_specs() (otter.task.model.TaskContext method) artifacts (otter.manifest.model.StepManifest attribute) (otter.manifest.model.TaskManifest attribute) (otter.task.task_reporter.TaskReporter property)

C

check() (otter.storage.google.GoogleStorage method) (otter.storage.model.RemoteStorage method) (otter.storage.noop.NoopStorage method) check_destination() (in module otter.util.fs) check_dir() (in module otter.util.fs) check_file_exists() (in module otter.util.fs) check_file_not_exists() (in module otter.util.fs)

check_source() (in module otter.util.fs) complete() (otter.manifest.manifest_manager.ManifestManager method) config (otter.task.model.TaskContext attribute) config_path (otter.config.model.BaseConfig attribute) (otter.config.model.Config attribute) (otter.config.model.Defaultconfig attribute) config_to_env() (in module otter.config.cli) Copy (class in otter.tasks.copy)

D

DEP_READY_STATES (in module otter.task.model) destination (otter.manifest.model.Artifact attribute) (otter.tasks.copy.CopySpec attribute) (otter.tasks.download.DownloadSpec attribute) do (otter.tasks.explode.ExplodeSpec attribute) (otter.tasks.explode_glob.ExplodeGlobSpec attribute) DONE (otter.task.model.State attribute)

Download (class in otter.tasks.download) download_to_file() (otter.storage.google.GoogleStorage method) (otter.storage.model.RemoteStorage method) (otter.storage.noop.NoopStorage method) download_to_string() (otter.storage.google.GoogleStorage method) (otter.storage.model.RemoteStorage method) (otter.storage.noop.NoopStorage method) DownloadError

E

elapsed (otter.manifest.model.StepManifest property) (otter.manifest.model.TaskManifest property)

env_to_config() (in module otter.config.env) Explode (class in otter.tasks.explode) ExplodeGlob (class in otter.tasks.explode_glob)

F

fail() (otter.step.step_reporter.StepReporter method) (otter.task.task_reporter.TaskReporter method) FAILURE (otter.manifest.model.Result attribute) file_exists() (in module otter.validators.file) file_size() (in module otter.validators.file) FindLatest (class in otter.tasks.find_latest) finish_run() (otter.task.task_reporter.TaskReporter method)

finish_validation() (otter.step.step_reporter.StepReporter method) (otter.task.task_reporter.TaskReporter method) finished_run_at (otter.manifest.model.StepManifest attribute) (otter.manifest.model.TaskManifest attribute) finished_validation_at (otter.manifest.model.TaskManifest attribute) flush() (otter.util.logger.MessageQueue method) foreach (otter.tasks.explode.ExplodeSpec attribute)

G

get_exception_info() (in module otter.util.logger) get_format_log() (in module otter.util.logger) get_remote_storage() (in module otter.storage) get_session() (otter.storage.google.GoogleStorage method) (otter.storage.model.RemoteStorage method) (otter.storage.noop.NoopStorage method)

get_state_execution_method() (otter.task.model.Task method) glob (otter.tasks.explode_glob.ExplodeGlobSpec attribute) glob() (otter.storage.google.GoogleStorage method) (otter.storage.model.RemoteStorage method) (otter.storage.noop.NoopStorage method) GoogleStorage (class in otter.storage.google)

H

HelloWorld (class in otter.tasks.hello_world)

I

idpattern (otter.scratchpad.model.ScratchpadTemplate attribute)

init_logger() (in module otter.util.logger) instantiate() (otter.task.task_registry.TaskRegistry method)

L

list() (otter.storage.google.GoogleStorage method) (otter.storage.model.RemoteStorage method) (otter.storage.noop.NoopStorage method) load_config() (in module otter.config) load_scratchpad() (in module otter.scratchpad) load_specs() (in module otter.task) log (otter.manifest.model.RootManifest attribute) (otter.manifest.model.StepManifest attribute) (otter.manifest.model.TaskManifest attribute)

log_level (otter.config.model.BaseConfig attribute) (otter.config.model.Config attribute) (otter.config.model.Defaultconfig attribute) (otter.config.model.YamlConfig attribute) LOG_LEVELS (in module otter.config.model) log_pydantic() (in module otter.util.errors)

M

ManifestManager (class in otter.manifest.manifest_manager) merge() (otter.scratchpad.model.Scratchpad method) MessageQueue (class in otter.util.logger) modified_at (otter.manifest.model.RootManifest attribute) module otter.config otter.config.cli otter.config.env otter.config.model otter.config.yaml otter.core otter.manifest otter.manifest.manifest_manager otter.manifest.model otter.scratchpad otter.scratchpad.model otter.step otter.step.model otter.step.step_reporter otter.storage otter.storage.google otter.storage.model otter.storage.noop otter.task otter.task.model otter.task.task_registry otter.task.task_reporter otter.tasks otter.tasks.copy otter.tasks.download otter.tasks.explode otter.tasks.explode_glob otter.tasks.find_latest otter.tasks.hello_world otter.util otter.util.errors otter.util.fs otter.util.logger otter.validators otter.validators.file

N

name (otter.core.Runner attribute) (otter.manifest.model.StepManifest attribute) (otter.manifest.model.TaskManifest attribute) (otter.storage.google.GoogleStorage property) (otter.storage.model.RemoteStorage property) (otter.storage.noop.NoopStorage property) (otter.task.model.Spec attribute)

next() (otter.task.model.State method) NoopStorage (class in otter.storage.noop) NotFoundError

O

otter.config module otter.config.cli module otter.config.env module otter.config.model module otter.config.yaml module otter.core module otter.manifest module otter.manifest.manifest_manager module otter.manifest.model module otter.scratchpad module otter.scratchpad.model module otter.step module otter.step.model module otter.step.step_reporter module otter.storage module otter.storage.google module otter.storage.model module otter.storage.noop module

otter.task module otter.task.model module otter.task.task_registry module otter.task.task_reporter module otter.tasks module otter.tasks.copy module otter.tasks.download module otter.tasks.explode module otter.tasks.explode_glob module otter.tasks.find_latest module otter.tasks.hello_world module otter.util module otter.util.errors module otter.util.fs module otter.util.logger module otter.validators module otter.validators.file module OtterError

P

parse_cli() (in module otter.config.cli) parse_env() (in module otter.config.env) parse_yaml() (in module otter.config.yaml) pattern (otter.tasks.find_latest.FindLatestSpec attribute) PENDING (otter.manifest.model.Result attribute) PENDING_RUN (otter.task.model.State attribute)

PENDING_VALIDATION (otter.task.model.State attribute) pool_size (otter.config.model.BaseConfig attribute) (otter.config.model.Config attribute) (otter.config.model.Defaultconfig attribute) (otter.config.model.YamlConfig attribute) PreconditionFailedError put() (otter.util.logger.MessageQueue method)

R

READY_STATES (in module otter.task.model) register() (otter.task.task_registry.TaskRegistry method) register_tasks() (otter.core.Runner method) release_uri (otter.config.model.BaseConfig attribute) (otter.config.model.Config attribute) (otter.config.model.Defaultconfig attribute) (otter.config.model.YamlConfig attribute) RemoteStorage (class in otter.storage.model) replace_dict() (otter.scratchpad.model.Scratchpad method) report() (in module otter.task.task_reporter) requires (otter.task.model.Spec attribute)

Result (class in otter.manifest.model) result (otter.manifest.model.RootManifest attribute) (otter.manifest.model.StepManifest attribute) (otter.manifest.model.TaskManifest attribute) run() (otter.core.Runner method) (otter.step.model.Step method) (otter.task.model.Task method) (otter.tasks.hello_world.HelloWorld method) run_elapsed (otter.manifest.model.TaskManifest property) Runner (class in otter.core) RUNNING (otter.task.model.State attribute)

S

Scratchpad (class in otter.scratchpad.model) scratchpad (otter.task.model.TaskContext attribute) scratchpad_ignore_missing (otter.task.model.Spec attribute) scratchpad_key (otter.tasks.find_latest.FindLatestSpec attribute) ScratchpadError ScratchpadTemplate (class in otter.scratchpad.model) sentinel_dict (otter.scratchpad.model.Scratchpad attribute) source (otter.manifest.model.Artifact attribute) (otter.tasks.copy.CopySpec attribute) (otter.tasks.download.DownloadSpec attribute) (otter.tasks.find_latest.FindLatestSpec attribute) specs (otter.task.model.TaskContext property) start() (otter.core.Runner method) start_run() (otter.step.step_reporter.StepReporter method) (otter.task.task_reporter.TaskReporter method) start_validation() (otter.task.task_reporter.TaskReporter method) started_at (otter.manifest.model.RootManifest attribute) started_run_at (otter.manifest.model.StepManifest attribute) (otter.manifest.model.TaskManifest attribute)

started_validation_at (otter.manifest.model.TaskManifest attribute) stat() (otter.storage.google.GoogleStorage method) (otter.storage.model.RemoteStorage method) (otter.storage.noop.NoopStorage method) State (class in otter.task.model) state (otter.task.model.TaskContext attribute) Step (class in otter.step.model) step (otter.config.model.BaseConfig attribute) (otter.config.model.Config attribute) step_logging() (in module otter.util.logger) StepFailedError StepInvalidError StepReporter (class in otter.step.step_reporter) steps (otter.config.model.Config attribute) (otter.config.model.YamlConfig attribute) (otter.manifest.model.RootManifest attribute) StorageError store() (otter.scratchpad.model.Scratchpad method) substitute() (otter.scratchpad.model.ScratchpadTemplate method) SUCCESS (otter.manifest.model.Result attribute)

T

Task (class in otter.task.model) task_logging() (in module otter.util.logger) task_type (otter.task.model.Spec property) TaskAbortedError

TaskContext (class in otter.task.model) TaskRegistry (class in otter.task.task_registry) TaskReporter (class in otter.task.task_reporter) tasks (otter.manifest.model.StepManifest attribute) TaskValidationError

U

upload() (otter.storage.google.GoogleStorage method) (otter.storage.model.RemoteStorage method) (otter.storage.noop.NoopStorage method)

upsert_task_manifests() (otter.step.step_reporter.StepReporter method)

V

v() (in module otter.validators) validate() (otter.task.model.Task method) (otter.tasks.copy.Copy method) (otter.tasks.download.Download method) (otter.tasks.hello_world.HelloWorld method)

VALIDATING (otter.task.model.State attribute) validation_elapsed (otter.manifest.model.TaskManifest property)

W

who (otter.tasks.hello_world.HelloWorldSpec attribute) work_path (otter.config.model.BaseConfig attribute) (otter.config.model.Config attribute) (otter.config.model.Defaultconfig attribute) (otter.config.model.YamlConfig attribute)