Index

A

AbsEventUnit (class in ampel.abstract.AbsEventUnit) activate_process() (ampel.core.AmpelContext.AmpelContext method) after (ampel.model.time.TimeConstraintModel.TimeConstraintModel attribute) all_of (ampel.model.operator.AllOf.AllOf attribute) AllOf (class in ampel.model.operator.AllOf)

AmpelContext (class in ampel.core.AmpelContext) AmpelLogger (class in ampel.log.AmpelLogger) AmpelRegister (class in ampel.core.AmpelRegister) any_of (ampel.model.operator.AnyOf.AnyOf attribute) AnyOf (class in ampel.model.operator.AnyOf)

B

base_log_flag (ampel.abstract.AbsEventUnit.AbsEventUnit attribute)

before (ampel.model.time.TimeConstraintModel.TimeConstraintModel attribute) build() (ampel.core.AmpelContext.AmpelContext class method)

C

channel (ampel.abstract.AbsEventUnit.AbsEventUnit attribute) (ampel.model.ingest.IngestDirective.IngestDirective attribute) (ampel.t3.T3Processor.T3Processor attribute) check_header() (ampel.core.AmpelRegister.AmpelRegister method) check_rename() (ampel.core.AmpelRegister.AmpelRegister method)

close() (ampel.core.AmpelRegister.AmpelRegister method) col (ampel.model.t3.LoaderDirective.LoaderDirective attribute) compression (ampel.core.AmpelRegister.AmpelRegister attribute) compression_level (ampel.core.AmpelRegister.AmpelRegister attribute) ContextUnit (class in ampel.core.ContextUnit)

D

dateTimeFormat (ampel.model.time.TimeStringModel.TimeStringModel attribute) dateTimeStr (ampel.model.time.TimeStringModel.TimeStringModel attribute)

days (ampel.model.time.TimeDeltaModel.TimeDeltaModel attribute) db_handler_kwargs (ampel.abstract.AbsEventUnit.AbsEventUnit attribute)

E

excluding_query (ampel.model.t3.LoaderDirective.LoaderDirective attribute)

F

fallback (ampel.model.time.TimeLastRunModel.TimeLastRunModel attribute) file_handle (ampel.core.AmpelRegister.AmpelRegister attribute)

file_prefix (ampel.core.AmpelRegister.AmpelRegister attribute) filter (ampel.model.ingest.IngestDirective.IngestDirective attribute)

G

gen_new_header() (ampel.core.AmpelRegister.AmpelRegister method) get_class_by_name() (ampel.core.UnitLoader.UnitLoader method) get_config() (ampel.core.AmpelContext.AmpelContext method) get_database() (ampel.core.AmpelContext.AmpelContext method) get_file_name() (ampel.core.AmpelRegister.AmpelRegister method) get_file_path() (ampel.core.AmpelRegister.AmpelRegister method) get_init_config() (ampel.core.UnitLoader.UnitLoader method)

get_logger() (ampel.log.AmpelLogger.AmpelLogger class method) get_query_model() (ampel.model.time.TimeConstraintModel.TimeConstraintModel method) get_resources() (ampel.core.UnitLoader.UnitLoader method) get_timestamp() (ampel.model.time.TimeDeltaModel.TimeDeltaModel method) (ampel.model.time.TimeLastRunModel.TimeLastRunModel method) (ampel.model.time.TimeStringModel.TimeStringModel method) (ampel.model.time.UnixTimeModel.UnixTimeModel method)

H

hours (ampel.model.time.TimeDeltaModel.TimeDeltaModel attribute)

I

IngestDirective (class in ampel.model.ingest.IngestDirective)

J

job_sig (ampel.abstract.AbsEventUnit.AbsEventUnit attribute)

L

load() (ampel.core.AmpelContext.AmpelContext class method)

LoaderDirective (class in ampel.model.t3.LoaderDirective) log_profile (ampel.abstract.AbsEventUnit.AbsEventUnit attribute)

M

match (ampel.model.t3.T2FilterModel.T2FilterModel attribute) match_type (ampel.model.time.TimeDeltaModel.TimeDeltaModel attribute) (ampel.model.time.TimeLastRunModel.TimeLastRunModel attribute) (ampel.model.time.TimeStringModel.TimeStringModel attribute) (ampel.model.time.UnixTimeModel.UnixTimeModel attribute) microseconds (ampel.model.time.TimeDeltaModel.TimeDeltaModel attribute) milliseconds (ampel.model.time.TimeDeltaModel.TimeDeltaModel attribute) minutes (ampel.model.time.TimeDeltaModel.TimeDeltaModel attribute) model_config (ampel.model.ingest.IngestDirective.IngestDirective attribute) (ampel.model.operator.AllOf.AllOf attribute) (ampel.model.operator.AnyOf.AnyOf attribute) (ampel.model.operator.OneOf.OneOf attribute) (ampel.model.t3.LoaderDirective.LoaderDirective attribute) (ampel.model.t3.T2FilterModel.T2FilterModel attribute) (ampel.model.time.TimeConstraintModel.TimeConstraintModel attribute) (ampel.model.time.TimeDeltaModel.TimeDeltaModel attribute) (ampel.model.time.TimeLastRunModel.TimeLastRunModel attribute) (ampel.model.time.TimeStringModel.TimeStringModel attribute) (ampel.model.time.UnixTimeModel.UnixTimeModel attribute)

model_fields (ampel.model.ingest.IngestDirective.IngestDirective attribute) (ampel.model.operator.AllOf.AllOf attribute) (ampel.model.operator.AnyOf.AnyOf attribute) (ampel.model.operator.OneOf.OneOf attribute) (ampel.model.t3.LoaderDirective.LoaderDirective attribute) (ampel.model.t3.T2FilterModel.T2FilterModel attribute) (ampel.model.time.TimeConstraintModel.TimeConstraintModel attribute) (ampel.model.time.TimeDeltaModel.TimeDeltaModel attribute) (ampel.model.time.TimeLastRunModel.TimeLastRunModel attribute) (ampel.model.time.TimeStringModel.TimeStringModel attribute) (ampel.model.time.UnixTimeModel.UnixTimeModel attribute)

N

new() (ampel.abstract.AbsEventUnit.AbsEventUnit class method) (ampel.core.UnitLoader.UnitLoader method) new_context_unit() (ampel.core.UnitLoader.UnitLoader method)

new_logical_unit() (ampel.core.UnitLoader.UnitLoader method) new_run_id() (ampel.core.AmpelContext.AmpelContext method) new_safe_logical_unit() (ampel.core.UnitLoader.UnitLoader method)

O

OneOf (class in ampel.model.operator.OneOf)

onload_update_header() (ampel.core.AmpelRegister.AmpelRegister method)

P

path_base (ampel.core.AmpelRegister.AmpelRegister attribute) path_extra (ampel.core.AmpelRegister.AmpelRegister attribute) path_full (ampel.core.AmpelRegister.AmpelRegister attribute)

prepare() (ampel.abstract.AbsEventUnit.AbsEventUnit method) process_name (ampel.abstract.AbsEventUnit.AbsEventUnit attribute) (ampel.model.time.TimeLastRunModel.TimeLastRunModel attribute) provenance (ampel.abstract.AbsEventUnit.AbsEventUnit attribute)

Q

query_complement (ampel.model.t3.LoaderDirective.LoaderDirective attribute)

R

raise_exc (ampel.abstract.AbsEventUnit.AbsEventUnit attribute) register_file_access() (ampel.core.AmpelRegister.AmpelRegister method) require_success (ampel.model.time.TimeLastRunModel.TimeLastRunModel attribute)

resolve_aliases() (ampel.core.UnitLoader.UnitLoader method) resolve_config (ampel.model.t3.LoaderDirective.LoaderDirective attribute) resolve_secrets() (ampel.core.UnitLoader.UnitLoader method)

S

seconds (ampel.model.time.TimeDeltaModel.TimeDeltaModel attribute)

stage (ampel.t3.T3Processor.T3Processor attribute) supply (ampel.t3.T3Processor.T3Processor attribute)

T

T2FilterModel (class in ampel.model.t3.T2FilterModel) T3Processor (class in ampel.t3.T3Processor) TimeConstraintModel (class in ampel.model.time.TimeConstraintModel)

TimeDeltaModel (class in ampel.model.time.TimeDeltaModel) TimeLastRunModel (class in ampel.model.time.TimeLastRunModel) TimeStringModel (class in ampel.model.time.TimeStringModel)

U

unit (ampel.model.t3.T2FilterModel.T2FilterModel attribute)

UnitLoader (class in ampel.core.UnitLoader) UnixTimeModel (class in ampel.model.time.UnixTimeModel)

V

validate_unit_models() (ampel.core.UnitLoader.UnitLoader method)

value (ampel.model.time.UnixTimeModel.UnixTimeModel attribute)

W

weeks (ampel.model.time.TimeDeltaModel.TimeDeltaModel attribute)