Index

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)

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) auto_offset_reset (loom.streaming.kafka.ConsumerSettings attribute) avro() (loom.streaming.kafka.ContentType class method)

B

Backend (class in loom.streaming) Base (class in loom.core.repository.sqlalchemy) BaseModel (class in loom.core.model) (class in loom.core.repository.sqlalchemy) batch_size() (loom.etl.declarative.FromMongo method) BatchExpandStep (class in loom.streaming) BatchStep (class in loom.streaming) bind() (loom.core.config.ConfigContext method) (loom.core.config.StructBinder method) bind_interfaces() (in module loom.rest.fastapi) (in module loom.rest.fastapi.router_runtime) Broadcast (class in loom.streaming) BroadcastRoute (class in loom.streaming) brokers (loom.streaming.kafka.ConsumerSettings attribute) (loom.streaming.kafka.ProducerSettings attribute) build_auto_routes() (in module loom.rest.autocrud) build_dataflow() (in module loom.streaming.bytewax) (loom.streaming.bytewax.runner.StreamingRunner method) (loom.streaming.bytewax.StreamingRunner method) build_dataflow_with_shutdown() (in module loom.streaming.bytewax) build_log_boundaries() (loom.etl.backends._historify.HistorifyBackend method)

build_message() (in module loom.streaming.kafka) build_mongo_cdc_event() (in module loom.streaming) build_mongo_cdc_message() (in module loom.streaming) build_page_result() (in module loom.core.repository.abc) (in module loom.core.repository.abc.query) build_partition() (loom.streaming.IntoSink method) (loom.streaming.IntoTable method) 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) by() (loom.streaming.Fork class method) (loom.streaming.Router class method) BytewaxRecoverySettings (class in loom.streaming.bytewax) (class in loom.streaming.bytewax.runner) BytewaxRuntimeConfig (class in loom.streaming.bytewax) (class in loom.streaming.bytewax.runner)

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) capture_errors() (loom.streaming.testing.StreamingTestRunner method) 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) causation_id (loom.streaming.kafka.MessageMetadata attribute) checkpoint_root (loom.etl.storage.StorageConfig property) checkpoint_storage_options (loom.etl.storage.StorageConfig property) CheckpointCleaner (in module loom.etl.checkpoint) CheckpointCleanupError 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) ClickHouseConfig (class in loom.etl.storage) ClickHouseSourceSpec (class in loom.etl.declarative) client_id (loom.streaming.kafka.ProducerSettings attribute) close() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) (loom.streaming.kafka.KafkaConsumer method) (loom.streaming.kafka.KafkaConsumerClient method) (loom.streaming.kafka.KafkaMessageConsumer method) (loom.streaming.kafka.KafkaMessageProducer method) (loom.streaming.kafka.KafkaProducer method) (loom.streaming.kafka.KafkaProducerClient method) (loom.streaming.kafka.MessageConsumer method) (loom.streaming.kafka.MessageProducer method) (loom.streaming.ResourceFactory method) (loom.streaming.SinkPartition method) col() (in module loom.etl.schema) CollectBatch (class in loom.streaming) collection (loom.streaming.MongoDBRef attribute) ColumnField() (in module loom.core.model) ColumnFieldInfo (class in loom.core.model) columns() (loom.etl.declarative.FromClickHouse method) (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) commit() (loom.streaming.kafka.KafkaConsumer method) (loom.streaming.kafka.KafkaConsumerClient method) (loom.streaming.kafka.KafkaMessageConsumer method) (loom.streaming.kafka.MessageConsumer method)

commit_offset() (loom.streaming.kafka.KafkaConsumer method) (loom.streaming.kafka.KafkaConsumerClient method) (loom.streaming.kafka.KafkaMessageConsumer method) (loom.streaming.kafka.MessageConsumer method) CompilationError compile() (loom.core.engine.UseCaseCompiler method) (loom.rest.compiler.RestInterfaceCompiler method) compile_flow() (in module loom.streaming) (in module loom.streaming.compiler) compile_schema() (loom.core.command.CommandAdapter method) CompiledMultiSource (class in loom.streaming.compiler) CompiledNode (class in loom.streaming.compiler) CompiledPlan (class in loom.streaming.compiler) CompiledRoute (class in loom.rest.compiler) CompiledSingleSource (class in loom.streaming.compiler) CompiledSink (class in loom.streaming.compiler) CompiledStorageSink (class in loom.streaming.compiler) 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) config_type (loom.streaming.bytewax.RegisteredSink attribute) ConfigBinding (class in loom.core.config) ConfigContext (class in loom.core.config) ConfigError ConfigKey (class in loom.core.config) ConfigResolver (class in loom.core.config) Configurable (class in loom.core.config) configure() (loom.core.cache.CacheGateway static method) (loom.core.cache.gateway.CacheGateway static method) (loom.core.config.Configurable class method) Conflict consumer_for() (loom.streaming.kafka.KafkaSettings method) ConsumerSettings (class in loom.streaming.kafka) content_type (loom.streaming.kafka.MessageDescriptor attribute) ContentType (class in loom.streaming.kafka) ContextFactory (class in loom.streaming) correlation_id (loom.streaming.kafka.MessageMetadata attribute) 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.streaming.ContextFactory method) (loom.streaming.ResourceFactory 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) created_at_ms (loom.streaming.MongoObjectId 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

database (loom.streaming.MongoDBRef attribute) dates_requiring_rerun (loom.etl.declarative.HistorifyRepairReport attribute) DatetimeType (class in loom.etl.schema) DecimalType (class in loom.etl.schema) decode() (loom.streaming.kafka.KafkaCodec method) (loom.streaming.kafka.MsgspecCodec method) DecodeError (class in loom.streaming.kafka) DecodeOk (class in loom.streaming.kafka) dedup_last() (loom.etl.backends._historify.HistorifyBackend method) default (loom.streaming.ExpandRoutes property) (loom.streaming.Fork property) (loom.streaming.Router property) 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) DeltaSinkConfig (class in loom.streaming) DependencyResolver (class in loom.core.cache) describe_main_repo() (loom.core.use_case.UseCase class method) descriptor (loom.streaming.kafka.MessageMetadata attribute) DispatchTable (class in loom.streaming.kafka) dispose() (loom.core.repository.sqlalchemy.SessionManager method) distinct() (loom.etl.declarative.FromClickHouse method) DomainError Drain (class in loom.streaming) drop() (loom.etl.backends._historify.HistorifyBackend method) dumps() (loom.core.cache.MsgspecSerializer method) DuplicateErrorSinkError DurationType (class in loom.etl.schema)

E

effective_counter_alias (loom.core.cache.CacheConfig property) enable_auto_commit (loom.streaming.kafka.ConsumerSettings attribute) enabled (loom.core.cache.CacheConfig attribute) encode() (loom.streaming.kafka.KafkaCodec method) (loom.streaming.kafka.MsgspecCodec method) encoding (loom.streaming.kafka.ContentType 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) envelope_to_message() (in module loom.streaming.kafka) EQ (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) ErrorEnvelope (class in loom.streaming) ErrorKind (class in loom.streaming) ErrorMessage (class in loom.streaming) ErrorMessageMeta (class in loom.streaming) ErrorRoute (class in loom.streaming) errors (loom.streaming.StreamFlow property) (loom.streaming.testing.StreamingTestRunner property) ErrorSink (class in loom.streaming.bytewax.runner) ETLParams (class in loom.etl.pipeline) ETLPipeline (class in loom.etl.pipeline) ETLProcess (class in loom.etl.pipeline) ETLRunner (class in loom.etl.runner) 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)

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) 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) expand() (loom.streaming.PayloadExpander class method) expander (loom.streaming.ExpandRoutes property) ExpandRoutes (class in loom.streaming) ExpandStep (class in loom.streaming) Explode (class in loom.streaming) expose_profile (loom.rest.model.RestInterface attribute) extended() (loom.etl.declarative.SourceSet class method) extra (loom.streaming.kafka.ConsumerSettings attribute) (loom.streaming.kafka.ProducerSettings attribute)

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) FixedKey (class in loom.streaming.kafka) FixedPathRouteResolver (class in loom.etl.storage) flush() (loom.etl.runner.ETLRunner method) (loom.streaming.kafka.KafkaMessageProducer method) (loom.streaming.kafka.KafkaProducer method) (loom.streaming.kafka.KafkaProducerClient method) (loom.streaming.kafka.MessageProducer method) Forbidden force_error() (loom.testing.GoldenHarness method) ForEach (class in loom.streaming)

Fork (class in loom.streaming) ForkRoute (class in loom.streaming) Format (class in loom.etl.declarative) format (loom.etl.declarative.FromFile property) (loom.etl.declarative.TableSourceSpec property) (loom.streaming.kafka.SchemaRef attribute) from_config() (loom.core.config.Configurable class method) (loom.core.repository.sqlalchemy.SessionManager class method) (loom.etl.runner.ETLRunner class method) (loom.streaming.DeltaSinkConfig class method) (loom.streaming.SqlAlchemyDatabaseConfig class method) (loom.streaming.SqlAlchemySinkConfig class method) from_context() (loom.streaming.bytewax.runner.StreamingRunner class method) (loom.streaming.bytewax.StreamingRunner class method) from_dict() (loom.core.config.ConfigContext class method) (loom.etl.runner.ETLRunner class method) (loom.streaming.bytewax.runner.StreamingRunner class method) (loom.streaming.bytewax.StreamingRunner class method) (loom.streaming.testing.StreamingTestRunner class method) from_flow() (loom.streaming.testing.StreamingTestRunner class method) from_mapping() (loom.core.cache.CacheConfig class method) from_spark() (loom.etl.runner.ETLRunner class method) from_yaml() (loom.core.config.ConfigContext class method) (loom.etl.runner.ETLRunner class method) (loom.streaming.bytewax.runner.StreamingRunner class method) (loom.streaming.bytewax.StreamingRunner class method) (loom.streaming.testing.StreamingTestRunner class method) FromClickHouse (class in loom.etl.declarative) FromFile (class in loom.etl.declarative) FromMongo (class in loom.etl.declarative) FromMongoCDC (class in loom.streaming) FromMultiTypeTopic (class in loom.streaming) FromTable (class in loom.etl.declarative) FromTemp (class in loom.etl.declarative) FromTopic (class in loom.streaming) 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_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) group_id (loom.streaming.kafka.ConsumerSettings attribute) 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() (loom.core.config.ConfigContext method) 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) headers (loom.streaming.kafka.KafkaRecord attribute)

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)

I

id (loom.streaming.MongoDBRef attribute) (loom.streaming.MongoObjectId attribute) 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) 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) IntoSink (class in loom.streaming) IntoTable (class in loom.etl.declarative) (class in loom.streaming) IntoTemp (class in loom.etl.declarative) IntoTopic (class in loom.streaming) 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

KafkaClientError KafkaCodec (class in loom.streaming.kafka) KafkaCommitError KafkaConfigurationError KafkaConsumer (class in loom.streaming.kafka) KafkaConsumerClient (class in loom.streaming.kafka) KafkaConsumerError KafkaDeliveryError KafkaDeserializationError KafkaMessageConsumer (class in loom.streaming.kafka) KafkaMessageProducer (class in loom.streaming.kafka) KafkaPollError KafkaProducer (class in loom.streaming.kafka)

KafkaProducerClient (class in loom.streaming.kafka) KafkaProducerError KafkaRecord (class in loom.streaming.kafka) KafkaSecuritySettings (class in loom.streaming.kafka) KafkaSerializationError KafkaSettings (class in loom.streaming.kafka) key (loom.streaming.kafka.KafkaRecord attribute) kind (loom.etl.declarative.ClickHouseSourceSpec property) (loom.etl.declarative.FileSourceSpec property) (loom.etl.declarative.MongoSourceSpec property) (loom.etl.declarative.TableSourceSpec property) (loom.etl.declarative.TempSourceSpec property) (loom.streaming.Fork 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) limit() (loom.etl.declarative.FromMongo method) LineageConfig (class in loom.etl.lineage) 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) load_kafka_settings() (in module loom.streaming.kafka) 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) log (loom.streaming.ContextFactory property) (loom.streaming.Step property) logical_ref (loom.streaming.FromMongoCDC property) (loom.streaming.FromMultiTypeTopic property) (loom.streaming.FromTopic property) (loom.streaming.IntoTopic property) 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.lineage 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.streaming module loom.streaming.bytewax module loom.streaming.bytewax.runner module loom.streaming.compiler module loom.streaming.kafka module loom.streaming.testing module loom.testing module loom_message_type() (loom.core.model.LoomFrozenStruct class method) (loom.core.model.LoomStruct class method) (loom.streaming.kafka.DecodeError class method) 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 LoomFrozenStruct (class in loom.core.model) 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) MaintenanceConfig (class in loom.etl.storage) MaintenanceVacuumConfig (class in loom.etl.storage) MappingFileLocator (class in loom.etl.storage) MappingLocator (class in loom.etl.storage) matches() (loom.streaming.Predicate method) max_size (loom.core.cache.CacheConfig attribute) media_type (loom.streaming.kafka.ContentType attribute) Message (class in loom.streaming) message_type (loom.streaming.kafka.MessageDescriptor attribute) message_version (loom.streaming.kafka.MessageDescriptor attribute) MessageConsumer (class in loom.streaming.kafka) MessageDescriptor (class in loom.streaming.kafka) MessageEnvelope (class in loom.streaming.kafka) MessageMeta (class in loom.streaming) MessageMetadata (class in loom.streaming.kafka) MessageProducer (class in loom.streaming.kafka) meta (loom.streaming.kafka.MessageEnvelope 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.lineage 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.streaming loom.streaming.bytewax loom.streaming.bytewax.runner loom.streaming.compiler loom.streaming.kafka loom.streaming.testing loom.testing

MongoBsonTimestamp (class in loom.streaming) MongoCDCEvent (class in loom.streaming) MongoCDCNamespace (class in loom.streaming) MongoConfig (class in loom.etl.storage) (class in loom.streaming) MongoDBRef (class in loom.streaming) MongoObjectId (class in loom.streaming) MongoSourceConfig (class in loom.streaming) MongoSourceSpec (class in loom.etl.declarative) msgpack() (loom.streaming.kafka.ContentType class method) MsgspecCodec (class in loom.streaming.kafka) 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) (loom.core.config.SecretsManagerResolver property) (loom.core.config.SsmResolver property) (loom.streaming.kafka.SchemaRef attribute) (loom.streaming.StreamFlow property) namespace (loom.streaming.kafka.SchemaRef attribute) 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) nodes (loom.streaming.Process property) normalize_bson_value() (in module loom.streaming) 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

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) offset (loom.streaming.kafka.KafkaRecord attribute) on_event() (loom.core.engine.MetricsAdapter method) (loom.etl.testing.StubRunObserver method) on_extra_fields() (loom.etl.declarative.FromMongo 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.core.config) output (loom.streaming.StreamFlow property) (loom.streaming.testing.StreamingTestRunner property)

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) parent_trace_id (loom.streaming.kafka.MessageMetadata attribute) 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) partition (loom.streaming.kafka.KafkaRecord attribute) partition_key() (loom.streaming.PartitionStrategy method) PartitionGuarantee (class in loom.streaming) PartitionKeyResolver (class in loom.streaming.kafka) PartitionPolicy (class in loom.streaming) PartitionStrategy (class in loom.streaming) path (loom.etl.declarative.FromFile property) (loom.etl.pipeline.ParamExpr property) PathRouteResolver (class in loom.etl.storage) PathTarget (class in loom.etl.storage) payload (loom.streaming.kafka.MessageEnvelope attribute) PayloadExpander (class in loom.streaming) pipeline_statuses (loom.etl.testing.StubRunObserver property) 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) poll() (loom.streaming.kafka.KafkaConsumer method) (loom.streaming.kafka.KafkaConsumerClient method) (loom.streaming.kafka.KafkaMessageConsumer method) (loom.streaming.kafka.MessageConsumer method) poll_timeout_ms (loom.streaming.kafka.ConsumerSettings attribute) Predicate (class in loom.streaming) predicate_routes (loom.streaming.Fork property) (loom.streaming.Router property) PredicateOp (class in loom.core.use_case) (class in loom.core.use_case.field_ref) predicates (loom.etl.declarative.FromClickHouse property) (loom.etl.declarative.FromTable property) prefix (loom.rest.model.RestInterface attribute) PrefixLocator (class in loom.etl.storage) prepare_run() (loom.streaming.bytewax.runner.StreamingRunner method) (loom.streaming.bytewax.StreamingRunner method) PreserveKey (class in loom.streaming.kafka) prev_period_value() (in module loom.etl.backends._historify) Process (class in loom.streaming) process (loom.streaming.StreamFlow property) processes (loom.etl.pipeline.ETLPipeline attribute) produced_at_ms (loom.streaming.kafka.MessageMetadata attribute) producer_for() (loom.streaming.kafka.KafkaSettings method) ProducerSettings (class in loom.streaming.kafka) profile_default (loom.rest.model.RestInterface attribute) project() (loom.etl.declarative.FromMongo method) Projection (class in loom.core.model) (class in loom.core.repository.sqlalchemy) ProjectionField() (in module loom.core.model) protocol (loom.streaming.kafka.KafkaSecuritySettings attribute) 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) read_streaming() (loom.etl.backends.polars.PolarsSourceReader method) (loom.etl.testing.StubSourceReader method) Readable (class in loom.core.repository.abc) RecordStep (class in loom.streaming) ref (loom.etl.schema.TableRef property) register_sink() (loom.streaming.bytewax.runner.StreamingRunner method) (loom.streaming.bytewax.StreamingRunner method) RegisteredSink (class in loom.streaming.bytewax) 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) reset() (loom.streaming.testing.StreamingTestRunner method) resolve() (loom.core.config.ConfigContext method) (loom.core.config.ConfigResolver method) (loom.core.config.SecretsManagerResolver method) (loom.core.config.SsmResolver method) (loom.etl.storage.TableRouteResolver method) (loom.streaming.kafka.FixedKey method) (loom.streaming.kafka.PartitionKeyResolver method) (loom.streaming.kafka.PreserveKey method) resolve_consumer_topics() (in module loom.streaming.kafka) resolve_effective_date() (in module loom.etl.backends._historify)

resolve_json_type() (in module loom.etl.schema) resolve_producer_topic() (in module loom.streaming.kafka) resolve_schema() (in module loom.etl.schema) resolve_track_cols() (in module loom.etl.backends._historify) resolved_predicate (loom.etl.testing.PolarsStepRunner property) resource (loom.streaming.StepContext property) ResourceFactory (class in loom.streaming) ResourceScope (class in loom.streaming) 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) Route (class in loom.streaming) RoutedCatalog (class in loom.etl.storage) Router (class in loom.streaming) routes (loom.rest.model.RestInterface attribute) (loom.streaming.Broadcast property) (loom.streaming.ExpandRoutes property) (loom.streaming.Fork property) (loom.streaming.Router property) 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.streaming.bytewax.runner.StreamingRunner method) (loom.streaming.bytewax.StreamingRunner method) (loom.streaming.testing.StreamingTestRunner method) (loom.testing.GoldenHarness method) (loom.testing.UseCaseTest method) run_with_baseline() (loom.testing.GoldenHarness method) RuntimeEvent (class in loom.core.engine) RuntimeExecutor (class in loom.core.engine) RuntimeSinkBinding (class in loom.streaming.bytewax)

S

sasl_mechanism (loom.streaming.kafka.KafkaSecuritySettings attribute) sasl_password (loom.streaming.kafka.KafkaSecuritySettings attribute) sasl_username (loom.streaming.kafka.KafkaSecuritySettings attribute) scd2_transform() (in module loom.etl.backends._historify) schema() (loom.etl.runtime.TableDiscovery method) (loom.etl.testing.StubCatalog method) schema_ref (loom.streaming.kafka.MessageDescriptor attribute) SchemaError SchemaMode (class in loom.etl.declarative) SchemaNotFoundError SchemaRef (class in loom.streaming.kafka) scope (loom.etl.declarative.IntoTemp property) SecretsManagerResolver (class in loom.core.config) section() (in module loom.core.config) (loom.core.config.ConfigContext method) section_optional() (loom.core.config.ConfigContext method) section_or_default() (loom.core.config.ConfigContext method) security (loom.streaming.kafka.ConsumerSettings attribute) (loom.streaming.kafka.ProducerSettings attribute) seed() (loom.etl.testing.PolarsStepRunner method) (loom.etl.testing.spark.SparkStepRunner method) (loom.etl.testing.StepRunnerProto method) (loom.testing.InMemoryRepository method) select() (loom.etl.declarative.FromClickHouse method) (loom.streaming.Selector method) Selector (class in loom.streaming) selector (loom.streaming.Fork property) (loom.streaming.Router property) send() (loom.streaming.kafka.KafkaMessageProducer method) (loom.streaming.kafka.KafkaProducer method) (loom.streaming.kafka.KafkaProducerClient method) (loom.streaming.kafka.MessageProducer 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) shutdown() (loom.streaming.bytewax.runner.StreamingRunner method) (loom.streaming.bytewax.StreamingRunner method) simulate_system_error() (loom.testing.GoldenHarness method) sink_type (loom.streaming.bytewax.RegisteredSink attribute) SinkPartition (class in loom.streaming)

SortSpec (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) source (loom.streaming.StreamFlow property) source_for() (loom.streaming.MongoConfig method) SourceKind (class in loom.core.use_case.markers) (class in loom.etl.declarative) SourceReader (class in loom.etl.runtime) SourceRef (class in loom.etl.declarative) 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) SqlAlchemyDatabaseConfig (class in loom.streaming) SQLAlchemyDefaultRepositoryBuilder (class in loom.core.repository.sqlalchemy) SqlAlchemySinkConfig (class in loom.streaming) SQLExecutor (class in loom.etl.runtime) ssl_ca_location (loom.streaming.kafka.KafkaSecuritySettings attribute) SsmResolver (class in loom.core.config) stamp_col() (loom.etl.backends._historify.HistorifyBackend method) start() (loom.etl.testing.spark.SparkTestSession class method) Step (class in loom.streaming) step_name() (loom.streaming.Step class method) step_statuses (loom.etl.testing.StubRunObserver property) StepContext (class in loom.streaming) StepResult (class in loom.etl.testing) StepRunnerProto (class in loom.etl.testing) 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) StreamFlow (class in loom.streaming) streaming_flags (loom.etl.testing.StubTargetWriter attribute) StreamingRunner (class in loom.streaming.bytewax) (class in loom.streaming.bytewax.runner) StreamingTestRunner (class in loom.streaming.testing) StreamShape (class in loom.streaming) StructBinder (class in loom.core.config) StructField (class in loom.etl.schema) 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 (loom.etl.declarative.ClickHouseSourceSpec property) table_ref (loom.etl.declarative.FromClickHouse property) (loom.etl.declarative.FromTable property) TableDiscovery (class in loom.etl.runtime) 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) 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) timestamp_ms (loom.streaming.kafka.KafkaRecord attribute) TimestampedModel (class in loom.core.model)

TimestampMixin (class in loom.core.repository.sqlalchemy) to_confluent_config() (loom.streaming.kafka.ConsumerSettings method) (loom.streaming.kafka.KafkaSecuritySettings method) (loom.streaming.kafka.ProducerSettings method) to_file_locator() (loom.etl.storage.StorageConfig method) to_frame() (loom.etl.backends.polars.PolarsTargetWriter method) (loom.etl.backends.spark.SparkTargetWriter method) to_location() (loom.etl.storage.TablePathConfig method) to_path_locator() (loom.etl.storage.StorageConfig method) to_polars() (loom.etl.testing.StepResult method) to_session_manager_config() (loom.streaming.SqlAlchemyDatabaseConfig method) topic (loom.streaming.kafka.KafkaRecord attribute) (loom.streaming.kafka.ProducerSettings attribute) topics (loom.streaming.kafka.ConsumerSettings attribute) total_count (loom.core.repository.abc.PageResult attribute) (loom.core.repository.abc.query.PageResult attribute) trace_id (loom.streaming.kafka.MessageMetadata attribute) transactional() (in module loom.core.repository.sqlalchemy) try_decode_multi_record() (in module loom.streaming.kafka) try_decode_record() (in module loom.streaming.kafka) ttl (loom.core.cache.CacheConfig attribute) ttl_for_list() (loom.core.cache.CacheConfig method) ttl_for_single() (loom.core.cache.CacheConfig method)

U

unbounded() (loom.etl.declarative.FromClickHouse method) 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.core.config.OtelConfig method) (loom.etl.lineage.LineageConfig 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)

value (loom.streaming.kafka.KafkaRecord attribute) version (loom.streaming.kafka.SchemaRef attribute)

W

warnings (loom.etl.declarative.HistorifyRepairReport attribute) when() (loom.streaming.Fork class method) (loom.streaming.Router class method) where() (loom.etl.declarative.FromClickHouse method) (loom.etl.declarative.FromMongo method) (loom.etl.declarative.FromTable method) WindowStrategy (class in loom.streaming) With (class in loom.streaming) 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_messages() (loom.streaming.testing.StreamingTestRunner method) with_options() (loom.etl.declarative.FromFile method) (loom.etl.declarative.IntoFile method)

with_params() (loom.testing.UseCaseTest method) with_payloads() (loom.streaming.testing.StreamingTestRunner method) with_schema() (loom.etl.declarative.FromClickHouse method) (loom.etl.declarative.FromFile method) (loom.etl.declarative.FromMongo method) (loom.etl.declarative.FromTable method) with_session_scope() (in module loom.core.repository.sqlalchemy) with_table() (loom.etl.testing.ETLScenario method) WithAsync (class in loom.streaming) write() (loom.etl.backends.polars.PolarsFileWriter method) (loom.etl.runtime.TargetWriter method) (loom.etl.testing.StubTargetWriter method) write_batch() (loom.streaming.SinkPartition method) written (loom.etl.testing.StubTargetWriter attribute)