Index A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W A affected_keys (loom.etl.declarative.HistorifyRepairReport attribute) aiocache_alias (loom.core.cache.CacheConfig attribute) aiocache_config (loom.core.cache.CacheConfig attribute) alias() (loom.etl.declarative.FromFile class method) (loom.etl.declarative.IntoFile class method) aliases (loom.etl.declarative.Sources property) allow_pagination_override (loom.rest.model.RestInterface attribute) allowed_profiles (loom.rest.model.RestInterface attribute) append (loom.etl.declarative.IntoTemp property) append() (loom.etl.backends.polars.PolarsTargetWriter method) (loom.etl.backends.spark.SparkTargetWriter method) (loom.etl.declarative.IntoTable method) (loom.etl.observability.RecordFrameTargetWriter method) apply() (loom.etl.testing.ETLScenario method) apply_config() (loom.core.cache.CacheGateway class method) (loom.core.cache.gateway.CacheGateway class method) apply_overwrite_cols() (loom.etl.backends._historify.HistorifyBackend method) ArrayType (class in loom.etl.schema) assert_count() (loom.etl.testing.StepResult method) assert_not_empty() (loom.etl.testing.StepResult method) assert_schema() (loom.etl.testing.StepResult method) AuditableModel (class in loom.core.repository.sqlalchemy) AuditActorMixin (class in loom.core.repository.sqlalchemy) auto (loom.rest.model.RestInterface attribute) B Base (class in loom.core.repository.sqlalchemy) BaseModel (class in loom.core.model) (class in loom.core.repository.sqlalchemy) bind_interfaces() (in module loom.rest.fastapi) (in module loom.rest.fastapi.router_runtime) build_app() (loom.testing.HttpTestHarness method) build_auto_routes() (in module loom.rest.autocrud) build_log_boundaries() (loom.etl.backends._historify.HistorifyBackend method) build_page_result() (in module loom.core.repository.abc) (in module loom.core.repository.abc.query) build_query_parameters_schema() (in module loom.rest.fastapi.openapi) build_repository_harness() (in module loom.testing) build_request_body_schema() (in module loom.rest.fastapi.openapi) build_sqlalchemy_repository_registration_module() (in module loom.core.repository.sqlalchemy) build_success_response_schema() (in module loom.rest.fastapi.openapi) build_table_resolver() (in module loom.etl.storage) bump_from_events() (loom.core.cache.dependency.GenerationalDependencyResolver method) (loom.core.cache.DependencyResolver method) (loom.core.cache.GenerationalDependencyResolver method) C c (loom.etl.schema.TableRef property) cache_query() (in module loom.core.cache) (in module loom.core.cache.decorators) CacheBackend (class in loom.core.cache) CacheConfig (class in loom.core.cache) cached() (in module loom.core.cache) (in module loom.core.cache.decorators) CachedRepository (class in loom.core.cache) (class in loom.core.cache.repository) CacheGateway (class in loom.core.cache) (class in loom.core.cache.gateway) Cardinality (class in loom.core.model) CatalogConnection (class in loom.etl.storage) CatalogRouteResolver (class in loom.etl.storage) CatalogTarget (class in loom.etl.storage) CategoricalType (class in loom.etl.schema) checkpoint_root (loom.etl.storage.StorageConfig property) checkpoint_storage_options (loom.etl.storage.StorageConfig property) CheckpointCleaner (in module loom.etl.checkpoint) CheckpointScope (class in loom.etl.checkpoint) CheckpointStore (class in loom.etl.checkpoint) cleanup_correlation() (loom.etl.checkpoint.CheckpointStore method) (loom.etl.runner.ETLRunner method) cleanup_run() (loom.etl.checkpoint.CheckpointStore method) clear() (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) close() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) col() (in module loom.etl.schema) ColumnField() (in module loom.core.model) ColumnFieldInfo (class in loom.core.model) columns() (loom.etl.declarative.FromFile method) (loom.etl.declarative.FromTable method) (loom.etl.runtime.TableDiscovery method) (loom.etl.testing.StubCatalog method) ColumnSchema (class in loom.etl.schema) ColumnType (class in loom.core.model) Command (class in loom.core.command) CommandAdapter (class in loom.core.command) CommandField (class in loom.core.command) CompilationError compile() (loom.core.engine.UseCaseCompiler method) (loom.rest.compiler.RestInterfaceCompiler method) compile_schema() (loom.core.command.CommandAdapter method) CompiledRoute (class in loom.rest.compiler) CompositeObserver (class in loom.etl.observability) CompositeRouteResolver (class in loom.etl.storage) Compute (class in loom.core.use_case) (class in loom.core.use_case.compute) computes (loom.core.use_case.UseCase attribute) ComputeStep (class in loom.core.engine) ConfigError ConfigResolver (class in loom.core.config) configure() (loom.core.cache.CacheGateway static method) (loom.core.cache.gateway.CacheGateway static method) Conflict count() (loom.core.repository.abc.Countable method) (loom.core.repository.abc.RepositoryRead method) Countable (class in loom.core.repository.abc) counter_alias (loom.core.cache.CacheConfig attribute) Creatable (class in loom.core.repository.abc) create() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (loom.core.repository.abc.Creatable method) (loom.core.repository.abc.RepositoryWrite method) (loom.testing.InMemoryRepository method) create_app() (in module loom.rest.fastapi) create_fastapi_app() (in module loom.rest.fastapi) (in module loom.rest.fastapi.app) created_at (loom.core.model.TimestampedModel attribute) CsvReadOptions (class in loom.etl.declarative) CsvWriteOptions (class in loom.etl.declarative) CURSOR (loom.core.repository.abc.PaginationMode attribute) (loom.core.repository.abc.query.PaginationMode attribute) CursorResult (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) D dates_requiring_rerun (loom.etl.declarative.HistorifyRepairReport attribute) DatetimeType (class in loom.etl.schema) DecimalType (class in loom.etl.schema) dedup_last() (loom.etl.backends._historify.HistorifyBackend method) default_list_ttl (loom.core.cache.CacheConfig attribute) default_ttl (loom.core.cache.CacheConfig attribute) Deletable (class in loom.core.repository.abc) delete() (loom.core.cache.CacheBackend method) (loom.core.cache.CachedRepository method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) (loom.core.cache.repository.CachedRepository method) (loom.core.repository.abc.Deletable method) (loom.core.repository.abc.RepositoryWrite method) (loom.testing.InMemoryRepository method) delete_many() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) delete_tree() (loom.etl.checkpoint.FsspecTempCleaner method) (loom.etl.checkpoint.TempCleaner method) DeletePolicy (class in loom.etl.declarative) DependencyResolver (class in loom.core.cache) describe_main_repo() (loom.core.use_case.UseCase class method) dispose() (loom.core.repository.sqlalchemy.SessionManager method) DomainError drop() (loom.etl.backends._historify.HistorifyBackend method) dumps() (loom.core.cache.MsgspecSerializer method) DurationType (class in loom.etl.schema) E effective_counter_alias (loom.core.cache.CacheConfig property) enabled (loom.core.cache.CacheConfig attribute) engine (loom.core.repository.sqlalchemy.SessionManager property) entity_name (loom.core.cache.CachedRepository property) (loom.core.cache.repository.CachedRepository property) entity_tags() (loom.core.cache.dependency.GenerationalDependencyResolver method) (loom.core.cache.DependencyResolver method) (loom.core.cache.GenerationalDependencyResolver method) EnumType (class in loom.etl.schema) EQ (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) ETLParams (class in loom.etl.pipeline) ETLPipeline (class in loom.etl.pipeline) ETLProcess (class in loom.etl.pipeline) ETLRunner (class in loom.etl.runner) ETLRunObserver (class in loom.etl.observability) ETLScenario (class in loom.etl.testing) ETLStep (class in loom.etl.pipeline) eval_param_expr() (in module loom.etl.backends._historify) event_names (loom.etl.testing.StubRunObserver property) EventKind (class in loom.core.engine) EventName (class in loom.etl.observability) events (loom.etl.testing.StubRunObserver attribute) ExcelReadOptions (class in loom.etl.declarative) execute() (loom.core.engine.RuntimeExecutor method) (loom.core.use_case.UseCase method) (loom.etl.pipeline.ETLStep method) (loom.etl.pipeline.StepSQL method) execute_sql() (loom.etl.backends.polars.PolarsSourceReader method) (loom.etl.backends.spark.SparkSourceReader method) (loom.etl.runtime.SQLExecutor method) (loom.etl.testing.StubSourceReader method) ExecutionPlan (class in loom.core.engine) ExecutionRecordsObserver (class in loom.etl.observability) ExecutionRecordStore (class in loom.etl.observability) ExecutionRecordStoreConfig (class in loom.etl.observability) ExecutionRecordWriter (class in loom.etl.observability) EXISTS (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) Exists() (in module loom.core.use_case) (in module loom.core.use_case.markers) exists() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) (loom.etl.runtime.TableDiscovery method) (loom.etl.testing.StubCatalog method) exists_by() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (loom.core.repository.abc.Countable method) (loom.core.repository.abc.RepositoryRead method) expose_profile (loom.rest.model.RestInterface attribute) extended() (loom.etl.declarative.SourceSet class method) F F() (in module loom.core.use_case) (in module loom.core.use_case.field_ref) Field (class in loom.core.model) field_ref() (in module loom.core.use_case.field_ref) FieldExpr (class in loom.core.use_case.field_ref) FieldRef (class in loom.core.use_case) (class in loom.core.use_case.field_ref) FileLocation (class in loom.etl.storage) FileLocator (class in loom.etl.storage) FilePathConfig (class in loom.etl.storage) FileRoute (class in loom.etl.storage) FileSourceSpec (class in loom.etl.declarative) FilterGroup (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) FilterOp (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) FilterParams (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) filters (loom.core.repository.abc.FilterParams attribute) (loom.core.repository.abc.query.FilterParams attribute) FilterSpec (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) fingerprint() (loom.core.cache.dependency.GenerationalDependencyResolver method) (loom.core.cache.DependencyResolver method) (loom.core.cache.GenerationalDependencyResolver method) FixedCatalogRouteResolver (class in loom.etl.storage) FixedPathRouteResolver (class in loom.etl.storage) Forbidden force_error() (loom.testing.GoldenHarness method) (loom.testing.HttpTestHarness method) Format (class in loom.etl.declarative) format (loom.etl.declarative.FromFile property) (loom.etl.declarative.TableSourceSpec property) from_config() (loom.etl.runner.ETLRunner class method) from_dict() (loom.etl.runner.ETLRunner class method) from_mapping() (loom.core.cache.CacheConfig class method) from_spark() (loom.etl.runner.ETLRunner class method) from_yaml() (loom.etl.runner.ETLRunner class method) FromFile (class in loom.etl.declarative) FromTable (class in loom.etl.declarative) FromTemp (class in loom.etl.declarative) FsspecTempCleaner (class in loom.etl.checkpoint) G GenerationalDependencyResolver (class in loom.core.cache) (class in loom.core.cache.dependency) get() (loom.etl.checkpoint.CheckpointStore method) get_by() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (loom.core.repository.abc.Readable method) (loom.core.repository.abc.RepositoryRead method) get_by_id() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (loom.core.repository.abc.Readable method) (loom.core.repository.abc.RepositoryRead method) (loom.testing.InMemoryRepository method) get_calculated_fields() (in module loom.core.command) get_column_fields() (in module loom.core.model) get_command_fields() (in module loom.core.command) get_id_attribute() (in module loom.core.model) get_input_fields() (in module loom.core.command) get_internal_fields() (in module loom.core.command) get_patch_fields() (in module loom.core.command) get_plan() (loom.core.engine.UseCaseCompiler method) get_projections() (in module loom.core.model) get_record_table_name() (in module loom.etl.observability) get_relations() (in module loom.core.model) get_table_name() (in module loom.core.model) get_value() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) GoldenHarness (class in loom.testing) GT (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) GTE (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) H has_catalog_routes() (loom.etl.storage.StorageConfig method) has_next (loom.core.repository.abc.CursorResult attribute) (loom.core.repository.abc.PageResult attribute) (loom.core.repository.abc.query.CursorResult attribute) (loom.core.repository.abc.query.PageResult attribute) has_path_routes() (loom.etl.storage.StorageConfig method) has_value() (loom.core.repository.sqlalchemy.Projection method) HistorifyBackend (class in loom.etl.backends._historify) HistorifyDateCollisionError HistorifyInputMode (class in loom.etl.declarative) HistorifyKeyConflictError HistorifyRepairReport (class in loom.etl.declarative) HistorifySpec (class in loom.etl.declarative) HistorifyTemporalConflictError history_dtype() (loom.etl.backends._historify.HistorifyBackend method) HistoryDateType (class in loom.etl.declarative) HttpTestHarness (class in loom.testing) I IdentityMixin (class in loom.core.repository.sqlalchemy) ILIKE (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) IN (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) include (loom.rest.model.RestInterface attribute) incr() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) inject_repo() (loom.testing.GoldenHarness method) (loom.testing.HttpTestHarness method) InMemoryRepository (class in loom.testing) Input() (in module loom.core.use_case) (in module loom.core.use_case.markers) InputBinding (class in loom.core.engine) InterfaceCompilationError IntoFile (class in loom.etl.declarative) IntoHistory (class in loom.etl.declarative) IntoTable (class in loom.etl.declarative) IntoTemp (class in loom.etl.declarative) InvalidStageError IS_NULL (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) is_patch_command() (in module loom.core.command) items (loom.core.repository.abc.CursorResult attribute) (loom.core.repository.abc.PageResult attribute) (loom.core.repository.abc.query.CursorResult attribute) (loom.core.repository.abc.query.PageResult attribute) J JsonReadOptions (class in loom.etl.declarative) JsonWriteOptions (class in loom.etl.declarative) K kind (loom.etl.declarative.FileSourceSpec property) (loom.etl.declarative.TableSourceSpec property) (loom.etl.declarative.TempSourceSpec property) L LIKE (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) limit (loom.core.repository.abc.PageParams attribute) (loom.core.repository.abc.PageResult attribute) (loom.core.repository.abc.query.PageParams attribute) (loom.core.repository.abc.query.PageResult attribute) list_paginated() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (loom.core.repository.abc.Listable method) (loom.core.repository.abc.RepositoryRead method) (loom.testing.InMemoryRepository method) list_tags() (loom.core.cache.dependency.GenerationalDependencyResolver method) (loom.core.cache.DependencyResolver method) (loom.core.cache.GenerationalDependencyResolver method) list_with_query() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (loom.core.repository.abc.Listable method) (loom.core.repository.abc.RepositoryRead method) Listable (class in loom.core.repository.abc) ListType (class in loom.etl.schema) Load() (in module loom.core.use_case) (in module loom.core.use_case.markers) load_config() (in module loom.core.config) LoadById() (in module loom.core.use_case) (in module loom.core.use_case.markers) loads() (loom.core.cache.MsgspecSerializer method) LoadStep (class in loom.core.engine) locate() (loom.etl.storage.FileLocator method) (loom.etl.storage.MappingFileLocator method) (loom.etl.storage.MappingLocator method) (loom.etl.storage.PrefixLocator method) (loom.etl.storage.TableLocator method) LookupKind (class in loom.core.use_case.markers) loom.core.cache module loom.core.cache.decorators module loom.core.cache.dependency module loom.core.cache.gateway module loom.core.cache.repository module loom.core.command module loom.core.config module loom.core.engine module loom.core.errors module loom.core.model module loom.core.repository.abc module loom.core.repository.abc.query module loom.core.repository.sqlalchemy module loom.core.use_case module loom.core.use_case.compute module loom.core.use_case.field_ref module loom.core.use_case.markers module loom.core.use_case.rule module loom.etl.backends._historify module loom.etl.backends.polars module loom.etl.backends.spark module loom.etl.checkpoint module loom.etl.declarative module loom.etl.observability module loom.etl.pipeline module loom.etl.runner module loom.etl.runtime module loom.etl.schema module loom.etl.storage module loom.etl.testing module loom.etl.testing.spark module loom.rest.autocrud module loom.rest.compiler module loom.rest.fastapi module loom.rest.fastapi.app module loom.rest.fastapi.openapi module loom.rest.fastapi.response module loom.rest.fastapi.router_runtime module loom.rest.model module loom.testing module loom_spark_runner() (in module loom.etl.testing.spark) loom_spark_session() (in module loom.etl.testing.spark) LoomDtype (class in loom.etl.schema) LoomError LoomStruct (class in loom.core.model) LoomStructMeta (class in loom.core.model) LT (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) LTE (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) M main_repo (loom.core.use_case.UseCase property) make_observers() (in module loom.etl.observability) MappingFileLocator (class in loom.etl.storage) MappingLocator (class in loom.etl.storage) max_size (loom.core.cache.CacheConfig attribute) MetricsAdapter (class in loom.core.engine) MissingTablePolicy (class in loom.etl.storage) module loom.core.cache loom.core.cache.decorators loom.core.cache.dependency loom.core.cache.gateway loom.core.cache.repository loom.core.command loom.core.config loom.core.engine loom.core.errors loom.core.model loom.core.repository.abc loom.core.repository.abc.query loom.core.repository.sqlalchemy loom.core.use_case loom.core.use_case.compute loom.core.use_case.field_ref loom.core.use_case.markers loom.core.use_case.rule loom.etl.backends._historify loom.etl.backends.polars loom.etl.backends.spark loom.etl.checkpoint loom.etl.declarative loom.etl.observability loom.etl.pipeline loom.etl.runner loom.etl.runtime loom.etl.schema loom.etl.storage loom.etl.testing loom.etl.testing.spark loom.rest.autocrud loom.rest.compiler loom.rest.fastapi loom.rest.fastapi.app loom.rest.fastapi.openapi loom.rest.fastapi.response loom.rest.fastapi.router_runtime loom.rest.model loom.testing MsgspecJSONResponse (class in loom.rest.fastapi) (class in loom.rest.fastapi.response) MsgspecSerializer (class in loom.core.cache) multi_get_values() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) multi_set_values() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) N name (loom.core.config.ConfigResolver property) NE (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) next_cursor (loom.core.repository.abc.CursorResult attribute) (loom.core.repository.abc.query.CursorResult attribute) NoopRunObserver (class in loom.etl.observability) NOT_EXISTS (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) NotFound null_col() (loom.etl.backends._historify.HistorifyBackend method) O ObservabilityConfig (class in loom.etl.observability) offset (loom.core.repository.abc.PageParams property) OFFSET (loom.core.repository.abc.PaginationMode attribute) offset (loom.core.repository.abc.query.PageParams property) OFFSET (loom.core.repository.abc.query.PaginationMode attribute) on_event() (loom.core.engine.MetricsAdapter method) on_pipeline_end() (loom.etl.observability.ETLRunObserver method) (loom.etl.observability.NoopRunObserver method) on_pipeline_start() (loom.etl.observability.ETLRunObserver method) (loom.etl.observability.NoopRunObserver method) on_process_end() (loom.etl.observability.ETLRunObserver method) (loom.etl.observability.NoopRunObserver method) on_process_start() (loom.etl.observability.ETLRunObserver method) (loom.etl.observability.NoopRunObserver method) on_step_end() (loom.etl.observability.ETLRunObserver method) (loom.etl.observability.NoopRunObserver method) on_step_error() (loom.etl.observability.ETLRunObserver method) (loom.etl.observability.NoopRunObserver method) on_step_start() (loom.etl.observability.ETLRunObserver method) (loom.etl.observability.NoopRunObserver method) on_transaction_committed() (loom.core.repository.sqlalchemy.RepositorySQLAlchemy method) OnDelete (class in loom.core.model) OnMissing (class in loom.core.use_case) (class in loom.core.use_case.markers) OnUpdate (class in loom.core.model) OtelConfig (class in loom.etl.observability) P page (loom.core.repository.abc.PageParams attribute) (loom.core.repository.abc.PageResult attribute) (loom.core.repository.abc.query.PageParams attribute) (loom.core.repository.abc.query.PageResult attribute) PageParams (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) PageResult (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) pagination_mode (loom.rest.model.RestInterface attribute) PaginationMode (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) ParamBinding (class in loom.core.engine) ParamExpr (class in loom.etl.pipeline) ParquetReadOptions (class in loom.etl.declarative) ParquetWriteOptions (class in loom.etl.declarative) parse() (loom.core.command.CommandAdapter method) parse_json() (loom.etl.declarative.FromFile method) (loom.etl.declarative.FromTable method) path (loom.etl.declarative.FromFile property) (loom.etl.pipeline.ParamExpr property) PathRouteResolver (class in loom.etl.storage) PathTarget (class in loom.etl.storage) pipeline_statuses (loom.etl.testing.StubRunObserver property) PipelineRunRecord (class in loom.etl.observability) plan (loom.testing.UseCaseTest property) PolarsFileWriter (class in loom.etl.backends.polars) PolarsPhysicalSchema (class in loom.etl.backends.polars) PolarsSourceReader (class in loom.etl.backends.polars) PolarsStepRunner (class in loom.etl.testing) PolarsTargetWriter (class in loom.etl.backends.polars) PredicateOp (class in loom.core.use_case) (class in loom.core.use_case.field_ref) predicates (loom.etl.declarative.FromTable property) prefix (loom.rest.model.RestInterface attribute) PrefixLocator (class in loom.etl.storage) prev_period_value() (in module loom.etl.backends._historify) processes (loom.etl.pipeline.ETLPipeline attribute) ProcessRunRecord (class in loom.etl.observability) profile_default (loom.rest.model.RestInterface attribute) Projection (class in loom.core.model) (class in loom.core.repository.sqlalchemy) ProjectionField() (in module loom.core.model) put() (loom.etl.checkpoint.CheckpointStore method) Q qualify() (loom.etl.schema.TableRef method) QuerySpec (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) R read() (loom.etl.backends.polars.PolarsSourceReader method) (loom.etl.backends.spark.SparkSourceReader method) (loom.etl.runtime.SourceReader method) (loom.etl.testing.StubSourceReader method) read_delta_physical_schema() (in module loom.etl.backends.polars) read_only (loom.core.use_case.UseCase attribute) Readable (class in loom.core.repository.abc) RecordField (class in loom.etl.observability) RecordFrameTargetWriter (class in loom.etl.observability) ref (loom.etl.schema.TableRef property) Relation (class in loom.core.model) RelationField() (in module loom.core.model) rename() (loom.etl.backends._historify.HistorifyBackend method) render() (loom.rest.fastapi.MsgspecJSONResponse method) (loom.rest.fastapi.response.MsgspecJSONResponse method) render_sql() (loom.etl.pipeline.StepSQL method) replace() (loom.etl.declarative.IntoTable method) replace_partition() (loom.etl.declarative.IntoTable method) replace_partitions() (loom.etl.declarative.IntoTable method) replace_where() (loom.etl.declarative.IntoTable method) RepoFor (class in loom.core.repository.abc) Repository (class in loom.core.repository.abc) RepositoryIntegrationHarness (class in loom.testing) RepositoryRead (class in loom.core.repository.abc) RepositorySQLAlchemy (class in loom.core.repository.sqlalchemy) RepositoryWrite (class in loom.core.repository.abc) resolve() (loom.core.config.ConfigResolver method) (loom.etl.storage.TableRouteResolver method) resolve_effective_date() (in module loom.etl.backends._historify) resolve_json_type() (in module loom.etl.schema) resolve_schema() (in module loom.etl.schema) resolve_track_cols() (in module loom.etl.backends._historify) resolved_predicate (loom.etl.testing.PolarsStepRunner property) RestApiDefaults (class in loom.rest.model) RestInterface (class in loom.rest.model) RestInterfaceCompiler (class in loom.rest.compiler) RestRoute (class in loom.rest.model) rollback_same_day_run() (loom.etl.backends._historify.HistorifyBackend method) RoutedCatalog (class in loom.etl.storage) routes (loom.rest.model.RestInterface attribute) Rule (class in loom.core.use_case) (class in loom.core.use_case.rule) RuleFn (class in loom.core.use_case) (class in loom.core.use_case.rule) rules (loom.core.use_case.UseCase attribute) RuleStep (class in loom.core.engine) RuleViolation RuleViolations run() (loom.etl.runner.ETLRunner method) (loom.etl.testing.PolarsStepRunner method) (loom.etl.testing.spark.SparkStepRunner method) (loom.testing.GoldenHarness method) (loom.testing.UseCaseTest method) run_with_baseline() (loom.testing.GoldenHarness method) RunContext (class in loom.etl.observability) RunStatus (class in loom.etl.observability) RuntimeEvent (class in loom.core.engine) RuntimeExecutor (class in loom.core.engine) S scd2_transform() (in module loom.etl.backends._historify) schema() (loom.etl.runtime.TableDiscovery method) (loom.etl.testing.StubCatalog method) SchemaError SchemaMode (class in loom.etl.declarative) SchemaNotFoundError scope (loom.etl.declarative.IntoTemp property) section() (in module loom.core.config) seed() (loom.etl.testing.PolarsStepRunner method) (loom.etl.testing.spark.SparkStepRunner method) (loom.etl.testing.StepRunnerProto method) (loom.testing.InMemoryRepository method) serialize_plan() (in module loom.testing) ServerDefault (class in loom.core.model) ServerOnUpdate (class in loom.core.model) session (loom.etl.testing.spark.SparkTestSession property) session() (loom.core.repository.sqlalchemy.SessionManager method) session_factory (loom.core.repository.sqlalchemy.SessionManager property) SessionManager (class in loom.core.repository.sqlalchemy) set_value() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) show() (loom.etl.testing.StepResult method) simulate_system_error() (loom.testing.GoldenHarness method) (loom.testing.HttpTestHarness method) SortSpec (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) SourceKind (class in loom.core.use_case.markers) (class in loom.etl.declarative) SourceReader (class in loom.etl.runtime) Sources (class in loom.etl.declarative) SourceSet (class in loom.etl.declarative) SparkSourceReader (class in loom.etl.backends.spark) SparkStepRunner (class in loom.etl.testing.spark) SparkTargetWriter (class in loom.etl.backends.spark) SparkTestSession (class in loom.etl.testing.spark) SQLAlchemyDefaultRepositoryBuilder (class in loom.core.repository.sqlalchemy) SQLExecutor (class in loom.etl.runtime) stamp_col() (loom.etl.backends._historify.HistorifyBackend method) start() (loom.etl.testing.spark.SparkTestSession class method) step_statuses (loom.etl.testing.StubRunObserver property) StepResult (class in loom.etl.testing) StepRunnerProto (class in loom.etl.testing) StepRunRecord (class in loom.etl.observability) steps (loom.etl.pipeline.ETLProcess attribute) StepSQL (class in loom.etl.pipeline) StorageConfig (class in loom.etl.storage) StorageDefaults (class in loom.etl.storage) StorageEngine (class in loom.etl.storage) streaming_flags (loom.etl.testing.StubTargetWriter attribute) StructField (class in loom.etl.schema) StructlogRunObserver (class in loom.etl.observability) StructType (class in loom.etl.schema) StubCatalog (class in loom.etl.testing) StubRunObserver (class in loom.etl.testing) StubSourceReader (class in loom.etl.testing) StubTargetWriter (class in loom.etl.testing) SupportsPostCommit (class in loom.core.repository.sqlalchemy) SystemError T table_ref (loom.etl.declarative.FromTable property) TableDiscovery (class in loom.etl.runtime) TableExecutionRecordStore (class in loom.etl.observability) TableLocation (class in loom.etl.storage) TableLocator (class in loom.etl.storage) TablePathConfig (class in loom.etl.storage) TableRef (class in loom.etl.schema) TableRoute (class in loom.etl.storage) TableRouteResolver (class in loom.etl.storage) TableSourceSpec (class in loom.etl.declarative) tags (loom.rest.model.RestInterface attribute) target_spec (loom.etl.testing.PolarsStepRunner property) (loom.etl.testing.spark.SparkStepRunner property) TargetExecutionRecordWriter (class in loom.etl.observability) TargetWriter (class in loom.etl.runtime) temp_name (loom.etl.declarative.FromTemp property) (loom.etl.declarative.IntoTemp property) TempCleaner (class in loom.etl.checkpoint) temporal_conflict_min_date() (loom.etl.backends._historify.HistorifyBackend method) TempSourceSpec (class in loom.etl.declarative) TimestampedModel (class in loom.core.model) TimestampMixin (class in loom.core.repository.sqlalchemy) to_file_locator() (loom.etl.storage.StorageConfig method) to_frame() (loom.etl.backends.polars.PolarsTargetWriter method) (loom.etl.backends.spark.SparkTargetWriter method) (loom.etl.observability.RecordFrameTargetWriter method) to_location() (loom.etl.storage.TablePathConfig method) to_path_locator() (loom.etl.storage.StorageConfig method) to_polars() (loom.etl.testing.StepResult method) to_row() (loom.etl.observability.PipelineRunRecord method) (loom.etl.observability.ProcessRunRecord method) (loom.etl.observability.StepRunRecord method) total_count (loom.core.repository.abc.PageResult attribute) (loom.core.repository.abc.query.PageResult attribute) transactional() (in module loom.core.repository.sqlalchemy) ttl (loom.core.cache.CacheConfig attribute) ttl_for_list() (loom.core.cache.CacheConfig method) ttl_for_single() (loom.core.cache.CacheConfig method) U Updatable (class in loom.core.repository.abc) update() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (loom.core.repository.abc.RepositoryWrite method) (loom.core.repository.abc.Updatable method) (loom.testing.InMemoryRepository method) update_schema() (loom.etl.runtime.TableDiscovery method) (loom.etl.testing.StubCatalog method) updated_at (loom.core.model.TimestampedModel attribute) upsert() (loom.etl.declarative.IntoTable method) UseCase (class in loom.core.use_case) UseCaseCompiler (class in loom.core.engine) UseCaseTest (class in loom.testing) V validate() (loom.etl.observability.ExecutionRecordStoreConfig method) (loom.etl.observability.OtelConfig method) (loom.etl.storage.FilePathConfig method) (loom.etl.storage.FileRoute method) (loom.etl.storage.StorageConfig method) (loom.etl.storage.TablePathConfig method) (loom.etl.storage.TableRoute method) W warnings (loom.etl.declarative.HistorifyRepairReport attribute) where() (loom.etl.declarative.FromTable method) with_command() (loom.testing.UseCaseTest method) with_deps() (loom.testing.UseCaseTest method) with_input() (loom.testing.UseCaseTest method) with_loaded() (loom.testing.UseCaseTest method) with_main_repo() (loom.testing.UseCaseTest method) with_options() (loom.etl.declarative.FromFile method) (loom.etl.declarative.IntoFile method) with_params() (loom.testing.UseCaseTest method) with_schema() (loom.etl.declarative.FromFile method) (loom.etl.declarative.FromTable method) with_session_scope() (in module loom.core.repository.sqlalchemy) with_table() (loom.etl.testing.ETLScenario method) write() (loom.etl.backends.polars.PolarsFileWriter method) (loom.etl.runtime.TargetWriter method) (loom.etl.testing.StubTargetWriter method) write_record() (loom.etl.observability.ExecutionRecordStore method) (loom.etl.observability.ExecutionRecordWriter method) (loom.etl.observability.TableExecutionRecordStore method) (loom.etl.observability.TargetExecutionRecordWriter method) written (loom.etl.testing.StubTargetWriter attribute)