Index

A

a2a (loom.ai.config.AiConfig attribute) a2a_agent_unknown() (in module loom.ai.errors) a2a_agent_unreachable() (in module loom.ai.errors) a2a_agents (loom.ai.config.AiConfig attribute) a2a_base_url_invalid() (in module loom.ai.errors) a2a_expose_empty() (in module loom.ai.errors) a2a_url_invalid() (in module loom.ai.errors) A2AAgentConfig (class in loom.ai.config) A2ACapability (class in loom.ai.declarative) A2AConfig (class in loom.ai.config) A2AEventProjector (class in loom.ai.a2a) accepted (loom.ai.compiler.CompiledConversation attribute) (loom.ai.compiler.CompiledOutputHook attribute) access_problems() (in module loom.core.repository.sqlalchemy.rls.integrity) affected_keys (loom.etl.declarative.HistorifyRepairReport attribute) agent (loom.ai.abc.ToolsetContext property) (loom.ai.compiler.CompiledA2ACapability attribute) Agent() (in module loom.core.use_case) (in module loom.core.use_case.markers) agent_budget_unenforceable() (loom.etl.compiler.ETLCompilationError class method) agent_column_collision() (loom.etl.compiler.ETLCompilationError class method) agent_compilation_failed() (loom.etl.compiler.ETLCompilationError class method) agent_engine_contract_suite() (in module loom.testing) agent_marker_output_mismatch() (in module loom.ai.errors) agent_marker_unknown() (in module loom.ai.errors) agent_name_duplicate() (in module loom.ai.errors) agent_name_invalid() (in module loom.ai.errors) agent_names() (loom.ai.runtime.AgentRuntime method) agent_not_found() (loom.etl.compiler.ETLCompilationError class method) agent_output_mismatch() (loom.etl.compiler.ETLCompilationError class method) agent_runner_not_configured() (loom.etl.compiler.ETLCompilationError class method) agent_spec_json_schema() (in module loom.ai.declarative) agent_spec_schema_path() (in module loom.ai.declarative) agent_specs_conflict() (in module loom.ai.errors) agent_specs_escape_root() (in module loom.ai.errors) agent_specs_missing() (in module loom.ai.errors) agent_unpriced_budget() (loom.etl.compiler.ETLCompilationError class method) agent_unsupported_engine() (loom.etl.compiler.ETLCompilationError class method) agent_url() (in module loom.ai.a2a) AgentAnswer (class in loom.ai.abc) AgentBatchRunner (class in loom.etl.runtime) AgentBinding (class in loom.etl.compiler) AgentCapabilityDescription (class in loom.ai.describe) AgentCompilationError AgentCompilationIssue (class in loom.ai.errors) AgentCompiler (class in loom.ai.compiler) AgentDescription (class in loom.ai.describe) AgentEndpointConfig (class in loom.ai.config) AgentEngine (class in loom.ai.abc) AgentEngineProvider (class in loom.ai.abc) AgentErrorCode (class in loom.ai.errors) AgentEvent (in module loom.ai.abc) AgentHandle (class in loom.ai.abc) AgentHandleDouble (class in loom.testing) AgentHealth (class in loom.ai.runtime) AgentIssue (class in loom.etl.runtime) AgentIssueKind (class in loom.etl.runtime) AgentJSONResponse (class in loom.ai.fastapi) AgentPlan (class in loom.ai.compiler) AgentResult (class in loom.ai.abc) AgentRunError AgentRunErrorClass (class in loom.ai.errors) AgentRunErrorCode (class in loom.ai.errors) AgentRuntime (class in loom.ai.runtime) AGENTS_CONTRIBUTOR (in module loom.ai.describe) AGENTS_SECTION (in module loom.ai.describe) AgentSpec (in module loom.ai.declarative) AgentSpecV1 (class in loom.ai.declarative)

AgentUsage (class in loom.ai.abc) AiConfig (class in loom.ai.config) aiocache_alias (loom.core.cache.CacheConfig attribute) aiocache_config (loom.core.cache.CacheConfig attribute) alembic_config() (in module loom.core.repository.sqlalchemy.migrations) algorithm (loom.rest.auth.JwtIssuerConfig attribute) algorithms (loom.rest.auth.JwtAuthConfig attribute) alias() (loom.etl.declarative.FromFile class method) (loom.etl.declarative.IntoFile class method) aliases (loom.etl.declarative.Sources property) allow_anonymous (loom.ai.config.AgentEndpointConfig attribute) allow_credentials (loom.rest.cors.CorsConfig attribute) allow_headers (loom.rest.cors.CorsConfig attribute) allow_methods (loom.rest.cors.CorsConfig attribute) allow_origin_regex (loom.rest.cors.CorsConfig attribute) allow_origins (loom.rest.cors.CorsConfig attribute) allow_pagination_override (loom.rest.model.RestInterface attribute) allow_symmetric_signing (loom.rest.auth.JwtIssuerConfig attribute) allowed (loom.core.authz.Decision attribute) (loom.core.authz.GrantCheck attribute) allowed_profiles (loom.rest.model.RestInterface attribute) allowed_roles (loom.core.sql.config.SqlConnectionConfig attribute) annotation_to_loom_type() (in module loom.etl.schema) anonymous_with_data_capability() (in module loom.ai.errors) AnswerT (class in loom.ai.abc) append (loom.etl.declarative.IntoTemp property) append() (loom.etl.backends.polars.PolarsTargetWriter method) (loom.etl.backends.spark.SparkTargetWriter method) (loom.etl.declarative.IntoTable method) Application (class in loom.core.locator) apply() (loom.etl.testing.ETLScenario method) apply_bootstrap() (in module loom.core.repository.sqlalchemy.rls) apply_config() (loom.core.cache.CacheGateway class method) (loom.core.cache.gateway.CacheGateway class method) apply_overwrite_cols() (loom.etl.backends._historify.HistorifyBackend method) args (loom.ai.compiler.CompiledMcpCapability attribute) (loom.ai.config.McpServerConfig attribute) arguments (loom.ai.abc.ToolCallEvent attribute) 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) assign_partition() (loom.streaming.kafka.KafkaConsumerClient method) Attachment (class in loom.ai.abc) attribute() (loom.core.identity.Identity method) attributes (loom.core.identity.Identity attribute) audience (loom.rest.auth.JwtAuthConfig attribute) (loom.rest.auth.JwtIssuerConfig attribute) AuditableModel (class in loom.core.repository.sqlalchemy) AuditActorMixin (class in loom.core.repository.sqlalchemy) auth (loom.ai.compiler.CompiledA2ACapability attribute) (loom.ai.compiler.CompiledMcpCapability attribute) (loom.ai.config.A2AAgentConfig attribute) (loom.ai.config.AgentEndpointConfig attribute) (loom.ai.config.McpServerConfig attribute) (loom.core.sql.config.SqlEndpointConfig attribute) auth_exclusion_overlaps_agents() (in module loom.ai.errors) authenticate() (loom.rest.auth.Authenticator method) (loom.rest.auth.JwtAuthenticator method) AuthenticationMiddleware (class in loom.rest.auth) AuthenticationUnavailable Authenticator (class in loom.rest.auth) AuthzProduct (class in loom.core.authz) (class in loom.core.authz.product) auto (loom.rest.model.RestInterface attribute) auto_crud_model (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) backend (loom.core.sql.config.SqlConnectionConfig attribute) Base (class in loom.core.repository.sqlalchemy) base_url (loom.ai.config.A2AConfig attribute) BaseModel (class in loom.core.model) (class in loom.core.repository.sqlalchemy) batch_size (loom.streaming.kafka.ConsumerSettings attribute) batch_size() (loom.etl.declarative.FromMongo method) BatchExpandStep (class in loom.streaming) BatchFingerprintResolver (class in loom.core.cache) BatchStep (class in loom.streaming) bind() (loom.core.cache.CachedCalls method) (loom.core.config.ConfigContext method) (loom.core.config.StructBinder method) bind_agent_endpoints() (in module loom.ai.fastapi) bind_agent_resolver() (loom.core.engine.RuntimeExecutor method) bind_commit_tracker() (loom.streaming.bytewax.KafkaPartitionedSource method) bind_interfaces() (in module loom.rest.fastapi) (in module loom.rest.fastapi.router_runtime) bind_mcp_resolver() (loom.core.engine.RuntimeExecutor method) bind_sql_endpoints() (in module loom.rest.fastapi.sql) binds_identity (loom.core.sql.config.SqlEndpointConfig property) BootstrapConfig (class in loom.core.repository.sqlalchemy.rls) BoundaryValidationError BoundedMemoryCache (class in loom.core.cache) Broadcast (class in loom.streaming) BroadcastRoute (class in loom.streaming) brokers (loom.streaming.kafka.ConsumerSettings attribute) (loom.streaming.kafka.ProducerSettings attribute) build() (loom.ai.abc.DepsFactory method) build_agent_card() (in module loom.ai.a2a)

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_part() (loom.streaming.bytewax.KafkaPartitionedSource method) build_partition() (loom.streaming.IntoSink method) (loom.streaming.IntoTable method) build_query_parameters_schema() (in module loom.rest.fastapi.openapi) 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) BulkCreatable (class in loom.core.repository.abc) 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) bypass_users (loom.core.repository.sqlalchemy.rls.BootstrapConfig property) bytes (loom.core.cache.BoundedMemoryCache property) 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_call() (in module loom.core.cache) (in module loom.core.cache.decorators) cache_hit_ratio (loom.ai.abc.AgentUsage property) cache_query() (in module loom.core.cache) (in module loom.core.cache.decorators) cache_read_tokens (loom.ai.abc.AgentUsage attribute) cache_write_tokens (loom.ai.abc.AgentUsage attribute) CacheBackend (class in loom.core.cache) CacheConfig (class in loom.core.cache) cached() (in module loom.core.cache) (in module loom.core.cache.decorators) cached_calls() (in module loom.core.cache) CachedCalls (class in loom.core.cache) CachedRepository (class in loom.core.cache) (class in loom.core.cache.repository) CacheGateway (class in loom.core.cache) (class in loom.core.cache.gateway) CacheWriteError call() (loom.ai.abc.McpHandle method) (loom.testing.McpHandleDouble method) call_id (loom.ai.abc.ToolCallEvent attribute) (loom.ai.abc.ToolResultEvent attribute) call_tool() (loom.ai.abc.McpSession method) (loom.ai.runtime.McpSession method) (loom.ai.runtime.SharedMcpSession method) call_untyped() (loom.ai.abc.McpHandle method) (loom.testing.McpHandleDouble method) Caller() (in module loom.core.use_case) (in module loom.core.use_case.markers) CallerBoundSql (class in loom.core.sql) can_grant() (in module loom.core.authz) can_revoke() (in module loom.core.authz) canonical_policies() (in module loom.core.repository.sqlalchemy.rls.integrity) capabilities (loom.ai.compiler.AgentPlan attribute) (loom.ai.describe.AgentDescription attribute) capability_empty() (in module loom.ai.errors) capability_kind_unsupported() (in module loom.ai.errors) capability_kinds() (loom.ai.runtime.AgentRuntime method) capture_errors() (loom.streaming.testing.StreamingTestRunner method) card_path() (in module loom.ai.a2a) Cardinality (class in loom.core.model) catalog_digest() (in module loom.core.repository.sqlalchemy.rls.guard_manifest) catalog_problems() (in module loom.core.repository.sqlalchemy.rls.integrity) 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) ceiling (loom.core.authz.CompositionRules attribute) check() (in module loom.core.repository.sqlalchemy.migrations) 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) checks (loom.ai.runtime.AgentHealth attribute) child() (loom.core.authz.Scope method) 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) clear_authz_product() (in module loom.core.authz.product) ClickHouseConfig (class in loom.etl.storage) ClickHouseConnectionRegistry (class in loom.core.sql.clickhouse) ClickHouseSourceSpec (class in loom.etl.declarative) ClickHouseSqlExecutor (class in loom.core.sql.clickhouse) client_host (loom.rest.auth.RequestCredentials attribute) client_id (loom.streaming.kafka.ProducerSettings attribute) ClientStep (class in loom.etl.pipeline) 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) code (loom.ai.abc.ErrorEvent attribute) (loom.ai.errors.AgentRunError attribute) (loom.etl.compiler.ETLCompilationError attribute) col() (in module loom.etl.schema) collect_future_rows() (loom.etl.backends._historify.HistorifyBackend method) CollectBatch (class in loom.streaming) collection (loom.streaming.MongoDBRef attribute) ColumnField() (in module loom.core.model) ColumnFieldInfo (class in loom.core.model) columns (loom.core.sql.abc.SqlQueryResult attribute) 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) command (loom.ai.compiler.CompiledMcpCapability attribute) (loom.ai.config.McpServerConfig attribute) 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_keepalive_ms (loom.streaming.kafka.ConsumerSettings attribute) commit_offset() (loom.streaming.kafka.KafkaConsumer method) (loom.streaming.kafka.KafkaConsumerClient method) (loom.streaming.kafka.KafkaMessageConsumer method) (loom.streaming.kafka.MessageConsumer method) committed_offset() (loom.streaming.kafka.KafkaConsumerClient method) compact() (loom.etl.maintenance.DeltaTableMaintainer method) (loom.etl.maintenance.MaintainSchema method) (loom.etl.maintenance.MaintainTable method) CompactSpec (class in loom.etl.maintenance)

CompilationError CompilationIssue (class in loom.streaming.compiler) compile() (loom.ai.compiler.AgentCompiler method) (loom.core.engine.UseCaseCompiler method) (loom.etl.compiler.ETLCompiler method) (loom.rest.compiler.RestInterfaceCompiler method) compile_all() (loom.ai.compiler.AgentCompiler method) compile_filter() (loom.core.repository.abc.QueryCompiler method) compile_flow() (in module loom.streaming) (in module loom.streaming.compiler) compile_process() (loom.etl.compiler.ETLCompiler method) compile_schema() (loom.core.command.CommandAdapter method) compile_sort() (loom.core.repository.abc.QueryCompiler method) compile_sources() (loom.rest.compiler.RestInterfaceCompiler method) compile_step() (loom.etl.compiler.ETLCompiler method) CompiledA2ACapability (class in loom.ai.compiler) CompiledConversation (class in loom.ai.compiler) CompiledInstruction (class in loom.ai.compiler) CompiledMcpCapability (class in loom.ai.compiler) CompiledMongoCDCSource (class in loom.streaming.compiler) CompiledMultiSource (class in loom.streaming.compiler) CompiledNativeCapability (class in loom.ai.compiler) CompiledNode (class in loom.streaming.compiler) CompiledOutput (class in loom.ai.compiler) CompiledOutputHook (class in loom.ai.compiler) CompiledPlan (class in loom.streaming.compiler) CompiledPythonCapability (class in loom.ai.compiler) CompiledRemoteAuth (class in loom.ai.compiler) CompiledRoute (class in loom.rest.compiler) CompiledSingleSource (class in loom.streaming.compiler) CompiledSink (class in loom.streaming.compiler) CompiledSkillsCapability (class in loom.ai.compiler) CompiledSqlCapability (class in loom.ai.compiler) CompiledStorageSink (class in loom.streaming.compiler) CompiledUsecaseCapability (class in loom.ai.compiler) component (loom.etl.compiler.ETLCompilationError attribute) compose() (loom.core.authz.RoleCatalog class method) CompositeRouteResolver (class in loom.etl.storage) CompositionRules (class in loom.core.authz) 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) ConcurrentMcpSession (class in loom.ai.abc) (class in loom.ai.runtime) config (loom.ai.compiler.CompiledSqlCapability attribute) config_alias_conflict() (loom.etl.compiler.ETLCompilationError class method) 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) configure_engine_mcp_connect_timeout() (in module loom.ai.registry) ConfigValueBinding (class in loom.etl.compiler) ConfigValueError ConfigValueFailure (class in loom.etl.runtime) Conflict connect_timeout (loom.core.sql.config.SqlConnectionConfig attribute) connection (loom.ai.compiler.CompiledSqlCapability attribute) connections (loom.core.sql.config.SqlConfig attribute) consume_batch() (loom.streaming.kafka.KafkaConsumerClient method) consumer_for() (loom.streaming.kafka.KafkaSettings method) ConsumerSettings (class in loom.streaming.kafka) container (loom.ai.abc.ToolsetContext property) content_type (loom.streaming.kafka.MessageDescriptor attribute) ContentType (class in loom.streaming.kafka) ContextFactory (class in loom.streaming) ContractScenario (class in loom.testing) Conversation (class in loom.ai.abc) conversation (loom.ai.compiler.AgentPlan attribute) conversation_id (loom.ai.abc.Conversation attribute) CONVERSATION_ID_MAX_LENGTH (in module loom.ai.abc) conversation_input_unsatisfied() (in module loom.ai.errors) conversation_invoker_missing() (in module loom.ai.errors) CONVERSATION_LOAD_FAILED_MESSAGE (in module loom.ai.errors) CONVERSATION_LOAD_TIMEOUT_MESSAGE (in module loom.ai.errors) conversation_usecase_also_granted() (in module loom.ai.errors) conversation_usecase_unknown() (in module loom.ai.errors) ConversationSpec (class in loom.ai.declarative) correlation_id (loom.streaming.kafka.MessageMetadata attribute) CorsConfig (class in loom.rest.cors) cost (loom.ai.abc.AgentUsage attribute) count() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (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) covers() (loom.core.authz.Scope method) 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_engine() (loom.ai.abc.AgentEngineProvider method) create_fastapi_app() (in module loom.rest.fastapi) (in module loom.rest.fastapi.app) create_many() (loom.core.repository.abc.BulkCreatable method) create_schema() (in module loom.core.repository.sqlalchemy.rls) created_at (loom.core.model.TimestampedModel attribute) created_at_ms (loom.streaming.MongoObjectId attribute) credentials_ref (loom.ai.inference.InferenceTarget attribute) CRUD_OP_CAPABILITY (in module loom.rest.autocrud) crud_op_of() (in module loom.rest.autocrud) CsvReadOptions (class in loom.etl.declarative) CsvWriteOptions (class in loom.etl.declarative) current_identity() (in module loom.core.identity) Cursor (class in loom.core.repository.abc) 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) custom_prefix (loom.core.authz.CompositionRules attribute)

D

data (loom.ai.abc.Attachment attribute) database (loom.streaming.MongoDBRef attribute) DatabaseConfig (class in loom.core.locator) DatabaseRoles (class in loom.core.repository.sqlalchemy.rls) DatabaseUser (class in loom.core.repository.sqlalchemy.rls) dates_requiring_rerun (loom.etl.declarative.HistorifyRepairReport attribute) DatetimeType (class in loom.etl.schema) DecimalType (class in loom.etl.schema) Decision (class in loom.core.authz) declared_checks() (in module loom.core.model) declared_indexes() (in module loom.core.model) declared_partial_unique() (in module loom.core.model) declared_partition() (in module loom.core.model) declared_privileges() (in module loom.core.model) declared_unique() (in module loom.core.model) declares_cache_call() (in module loom.core.cache.decorators) declares_cache_policy() (in module loom.core.cache.decorators) decode() (loom.streaming.kafka.KafkaCodec method) (loom.streaming.kafka.MsgspecCodec method) decode_cursor() (in module loom.core.repository.abc) decode_identity() (in module loom.core.identity.wire) decode_json() (loom.core.model.LoomType method) decode_json_columns() (in module loom.etl.backends.polars) decode_spec() (in module loom.ai.declarative) DecodedSpec (class in loom.ai.declarative) DecodeError (class in loom.streaming.kafka) DecodeOk (class in loom.streaming.kafka) dedup_priority() (loom.etl.backends._historify.HistorifyBackend method) default (loom.streaming.ExpandRoutes property) (loom.streaming.Fork property) (loom.streaming.Router property) default_limit (loom.core.sql.config.SqlConnectionConfig attribute) default_list_ttl (loom.core.cache.CacheConfig attribute) default_resolvers() (in module loom.core.config) default_role (loom.core.sql.config.SqlConnectionConfig 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) delivery (loom.streaming.kafka.ConsumerSettings attribute) DeltaSinkConfig (class in loom.streaming) DeltaTableMaintainer (class in loom.etl.maintenance) DependencyResolver (class in loom.core.cache) DepsFactory (class in loom.ai.abc) derived() (loom.core.repository.sqlalchemy.rls.SchemaNames class method) describe_agent() (in module loom.ai.describe) describe_agents() (in module loom.ai.describe) describe_fastapi_app() (in module loom.rest.fastapi) describe_main_repo() (loom.core.use_case.UseCase class method) description (loom.ai.compiler.AgentPlan attribute) (loom.ai.describe.AgentDescription attribute) descriptor (loom.streaming.kafka.MessageMetadata attribute) detach_range_partitions() (in module loom.core.repository.sqlalchemy.rls) DetachRangePartitionsOp (class in loom.core.repository.sqlalchemy.migrations.operations) detail (loom.ai.abc.HealthStatus attribute) (loom.ai.runtime.AgentHealth attribute) details (loom.ai.abc.AgentUsage attribute) digest() (in module loom.core.repository.sqlalchemy.rls.guard_manifest) (loom.core.authz.RoleCatalog method) directory (loom.ai.compiler.CompiledSkillsCapability attribute) discard() (loom.core.engine.PostCommitChannel method) DispatchTable (class in loom.streaming.kafka) dispose() (loom.core.repository.sqlalchemy.SessionManager method) distinct() (loom.etl.declarative.FromClickHouse method) document() (loom.core.repository.sqlalchemy.rls.BootstrapConfig method) DomainError Drain (class in loom.streaming) drain() (loom.core.engine.PostCommitChannel method) drop() (loom.etl.backends._historify.HistorifyBackend method) DropPartitionsOp (class in loom.core.repository.sqlalchemy.migrations.operations) dumps() (loom.core.cache.MsgspecSerializer method) duplicate_temp_name() (loom.etl.compiler.ETLCompilationError class method) DuplicateErrorSinkError duration_ms (loom.ai.abc.AgentUsage attribute) DurationType (class in loom.etl.schema)

E

effective_counter_alias (loom.core.cache.CacheConfig property) effective_delivery() (loom.streaming.kafka.ConsumerSettings method) elapsed_ms (loom.core.sql.abc.SqlQueryResult attribute) elevate() (in module loom.core.repository.sqlalchemy.rls) elevate_scope() (in module loom.core.authz.elevation) elevated_scopes() (in module loom.core.authz.elevation) elevation_scope() (in module loom.core.authz.elevation) ElevationSink (class in loom.core.authz.elevation) EmptyReplaceError enable_auto_commit (loom.streaming.kafka.ConsumerSettings attribute) enabled (loom.ai.config.AgentEndpointConfig attribute) (loom.core.cache.CacheConfig attribute) (loom.core.sql.config.SqlEndpointConfig attribute) encode() (loom.streaming.kafka.KafkaCodec method) (loom.streaming.kafka.MsgspecCodec method) encode_cursor() (in module loom.core.repository.abc) encode_identity() (in module loom.core.identity.wire) encode_sse_event() (in module loom.ai.fastapi) encoding (loom.streaming.kafka.ContentType attribute) endpoint (loom.ai.inference.InferenceTarget attribute) endpoint_auth_missing() (in module loom.ai.errors) endpoints (loom.ai.config.AiConfig attribute) engine (loom.ai.config.AiConfig attribute) (loom.core.repository.sqlalchemy.SessionManager property) ENGINE_API_ATTRIBUTE (in module loom.ai.registry) engine_api_mismatch() (in module loom.ai.errors) engine_client_factories() (in module loom.ai.registry) engine_duplicate() (in module loom.ai.errors) ENGINE_ENTRY_POINT_GROUP (in module loom.ai.registry) engine_native_tool_support() (in module loom.ai.registry) engine_not_found() (in module loom.ai.errors) engine_prices_model() (in module loom.ai.registry) engine_supported_kinds() (in module loom.ai.registry) enqueue() (loom.core.engine.PostCommitChannel method) enqueue_priority() (loom.core.engine.PostCommitChannel method) ensure_range_partitions() (in module loom.core.repository.sqlalchemy.rls) EnsureRangePartitionsOp (class in loom.core.repository.sqlalchemy.migrations.operations) 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) env (loom.ai.compiler.CompiledMcpCapability attribute) (loom.ai.config.McpServerConfig attribute) envelope_to_message() (in module loom.streaming.kafka) EQ (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) error_code (loom.testing.ContractScenario attribute) ErrorEnvelope (class in loom.streaming) ErrorEvent (class in loom.ai.abc) ErrorKind (class in loom.streaming) ErrorMessage (class in loom.streaming) ErrorMessageMeta (class in loom.streaming) ErrorRoute (class in loom.streaming) errors (loom.streaming.compiler.CompilationError property) (loom.streaming.StreamFlow property) (loom.streaming.testing.StreamingTestRunner property) ErrorSink (class in loom.streaming.bytewax.runner) ETLCompilationError ETLCompiler (class in loom.etl.compiler) ETLErrorCode (class in loom.etl.compiler) 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) evaluate() (in module loom.core.authz) event_names (loom.etl.testing.StubRunObserver property) EventKind (class in loom.core.engine) events (loom.etl.testing.StubRunObserver attribute) (loom.testing.ContractScenario attribute) ExcelReadOptions (class in loom.etl.declarative) exclude (loom.ai.compiler.CompiledA2ACapability attribute) (loom.ai.compiler.CompiledMcpCapability attribute) exclude_paths (loom.rest.auth.JwtAuthConfig attribute) execute() (loom.core.engine.RuntimeExecutor method) (loom.core.sql.abc.SqlExecutor method) (loom.core.sql.CallerBoundSql method) (loom.core.sql.clickhouse.ClickHouseSqlExecutor method) (loom.core.sql.NullSqlQueryService method) (loom.core.sql.SqlQueryService method) (loom.core.use_case.UseCase method) (loom.etl.pipeline.ClientStep 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) executor() (loom.core.sql.clickhouse.ClickHouseConnectionRegistry method) executor_threads (loom.core.sql.config.SqlConnectionConfig attribute) 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) expand_config_glob() (in module loom.core.config) expander (loom.streaming.ExpandRoutes property) ExpandRoutes (class in loom.streaming) ExpandStep (class in loom.streaming) expected_output (loom.testing.ContractScenario attribute) ExpectedT (class in loom.ai.abc) expires_at (loom.core.authz.Grant attribute) (loom.core.identity.IssuedToken attribute) Explode (class in loom.streaming) expose (loom.ai.config.A2AConfig attribute) expose_headers (loom.rest.cors.CorsConfig attribute) expose_profile (loom.rest.model.RestInterface attribute) extended() (loom.etl.declarative.SourceSet class method) extends (loom.core.authz.RoleSpec attribute) extra (loom.streaming.kafka.ConsumerSettings attribute) (loom.streaming.kafka.ProducerSettings attribute) extra_source_params() (loom.etl.compiler.ETLCompilationError class method)

F

F() (in module loom.core.use_case) (in module loom.core.use_case.field_ref) factory (loom.ai.compiler.CompiledPythonCapability attribute) factory_ref (loom.ai.compiler.CompiledPythonCapability attribute) failure (loom.etl.runtime.ConfigValueError attribute) FakeAgentEngine (class in loom.testing) Field (class in loom.core.model) field (loom.etl.compiler.ETLCompilationError attribute) 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) filter_plan() (in module loom.etl.compiler) 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) FinalEvent (class in loom.ai.abc) Finding (class in loom.core.repository.sqlalchemy.rls) fingerprint (loom.ai.compiler.AgentPlan property) fingerprint() (loom.core.cache.dependency.GenerationalDependencyResolver method) (loom.core.cache.DependencyResolver method) (loom.core.cache.GenerationalDependencyResolver method) fingerprint_many() (loom.core.cache.BatchFingerprintResolver method) (loom.core.cache.dependency.GenerationalDependencyResolver method) (loom.core.cache.GenerationalDependencyResolver method) FixedCatalogRouteResolver (class in loom.etl.storage) FixedKey (class in loom.streaming.kafka) FixedPathRouteResolver (class in loom.etl.storage) flatten_step_names() (in module loom.etl.compiler) 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_builtins() (loom.core.model.LoomType method) from_config() (loom.core.config.Configurable class method) (loom.core.repository.sqlalchemy.SessionManager class method) (loom.core.sql.clickhouse.ClickHouseConnectionRegistry class method) (loom.etl.maintenance.MaintenanceRunner 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_message() (in module loom.ai.errors) from_signing_key() (loom.rest.auth.JwtAuthConfig class method) from_spark() (loom.etl.runner.ETLRunner class method) from_specs() (loom.core.authz.RoleCatalog 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) FromConfig (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_id_attributes() (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) Grant (class in loom.core.authz) grant (loom.core.authz.Decision attribute) GrantCheck (class in loom.core.authz) grants() (loom.ai.abc.AgentHandle method) (loom.ai.runtime.AgentRuntime method) (loom.testing.AgentHandleDouble method) grants_for() (loom.core.authz.GrantSource method) (loom.core.authz.InMemoryGrantSource method) GrantSource (class in loom.core.authz) GrantTableOp (class in loom.core.repository.sqlalchemy.migrations.operations) 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) guard_problems() (in module loom.core.repository.sqlalchemy.rls.integrity) GuardOperations (class in loom.core.repository.sqlalchemy.migrations.operations) GuardRevision (class in loom.core.repository.sqlalchemy.rls.guard_manifest)

H

HandWrittenProtectOp (class in loom.core.repository.sqlalchemy.migrations.operations) has() (loom.core.config.ConfigContext method) has_agent() (loom.ai.runtime.AgentRuntime method) has_caller_scoped_session() (loom.core.repository.abc.SupportsCallerScopedSession method) (loom.core.repository.sqlalchemy.RepositorySQLAlchemy method) has_catalog_routes() (loom.etl.storage.StorageConfig method) has_conversation() (loom.ai.runtime.AgentRuntime method) has_errors (loom.etl.maintenance.MaintenanceReport property) has_more (loom.core.sql.abc.SqlQueryResult attribute) 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_output_schema (loom.ai.abc.McpToolInfo attribute) has_path_routes() (loom.etl.storage.StorageConfig method) has_role() (loom.core.identity.Identity method) has_session_settings (loom.core.repository.sqlalchemy.SessionManager property) has_value() (loom.core.repository.sqlalchemy.Projection method) header() (loom.rest.auth.RequestCredentials method) headers (loom.rest.auth.RequestCredentials attribute) (loom.streaming.kafka.KafkaRecord attribute)

headers_ref (loom.ai.compiler.CompiledA2ACapability attribute) (loom.ai.compiler.CompiledMcpCapability attribute) (loom.ai.config.A2AAgentConfig attribute) (loom.ai.config.McpServerConfig attribute) health() (loom.ai.abc.AgentEngine method) (loom.ai.runtime.AgentRuntime method) (loom.testing.FakeAgentEngine method) health_cache_ttl_ms (loom.ai.config.AiConfig attribute) HealthState (in module loom.ai.abc) HealthStatus (class in loom.ai.abc) 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 (loom.ai.abc.Conversation attribute) history_dtype() (loom.etl.backends._historify.HistorifyBackend method) HistoryDateType (class in loom.etl.declarative) hook_result (loom.ai.abc.AgentResult attribute) (loom.ai.abc.FinalEvent attribute)

I

id (loom.streaming.MongoDBRef attribute) (loom.streaming.MongoObjectId attribute) Identity (class in loom.core.identity) 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) in_execution_frame() (in module loom.core.authz.elevation) include (loom.ai.compiler.CompiledA2ACapability attribute) (loom.ai.compiler.CompiledMcpCapability attribute) (loom.rest.model.RestInterface attribute) include_in_schema (loom.core.sql.config.SqlEndpointConfig attribute) incr() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) inference (loom.ai.compiler.AgentPlan attribute) inference_target_incomplete() (in module loom.ai.errors) InferenceTarget (class in loom.ai.inference) inject_repo() (loom.testing.GoldenHarness method) InMemoryGrantSource (class in loom.core.authz) InMemoryRepository (class in loom.testing) Input() (in module loom.core.use_case) (in module loom.core.use_case.markers) input_tokens (loom.ai.abc.AgentUsage attribute) InputBinding (class in loom.core.engine) install_pool_reset() (in module loom.core.repository.sqlalchemy.rls) instruction_block_invalid() (in module loom.ai.errors) InstructionBlock (class in loom.ai.declarative) instructions (loom.ai.compiler.AgentPlan attribute) interaction_id (loom.ai.abc.AgentAnswer attribute) (loom.ai.abc.AgentResult attribute) (loom.ai.abc.ErrorEvent attribute) (loom.ai.abc.FinalEvent attribute) (loom.ai.errors.AgentRunError attribute) 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) invalid_params_name() (loom.etl.compiler.ETLCompilationError class method) invalid_params_type() (loom.etl.compiler.ETLCompilationError class method) invalid_process_item() (loom.etl.compiler.ETLCompilationError class method) invalid_sources_type() (loom.etl.compiler.ETLCompilationError class method) invalid_step_item() (loom.etl.compiler.ETLCompilationError class method) invalid_target_type() (loom.etl.compiler.ETLCompilationError class method) invalid_temp_append_mix() (loom.etl.compiler.ETLCompilationError class method) InvalidStageError INVOKER_MISSING_REASON (in module loom.ai.errors) is_authenticated (loom.core.identity.Identity property) is_cloud_uri() (in module loom.core.config) is_now() (loom.core.model.ServerOnUpdate class method) IS_NULL (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) is_patch_command() (in module loom.core.command) is_pydantic_model() (in module loom.core.model) is_retriable() (in module loom.ai.errors) is_row_scoped() (in module loom.core.model) issue() (loom.core.identity.TokenIssuer method) (loom.rest.auth.JwtIssuer method) IssuedToken (class in loom.core.identity) issuer (loom.rest.auth.JwtAuthConfig attribute) (loom.rest.auth.JwtIssuerConfig attribute) issues (loom.ai.errors.AgentCompilationError attribute) (loom.streaming.bytewax.RuntimeConfigurationError attribute) (loom.streaming.compiler.CompilationError attribute) 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) iter_all_steps() (in module loom.etl.compiler) iter_processes() (in module loom.etl.compiler) iter_steps_in_process() (in module loom.etl.compiler)

J

json_columns (loom.etl.declarative.FromFile property) (loom.etl.declarative.FromTable property) JsonReadOptions (class in loom.etl.declarative) JsonSchemaOutput (class in loom.ai.declarative) JsonWriteOptions (class in loom.etl.declarative)

jti (loom.core.identity.IssuedToken attribute) JwtAuthConfig (class in loom.rest.auth) JwtAuthenticator (class in loom.rest.auth) JwtAuthMiddleware (class in loom.rest.auth) JwtIssuer (class in loom.rest.auth) JwtIssuerConfig (class in loom.rest.auth)

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) KafkaPartitionedSource (class in loom.streaming.bytewax) 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.etl.declarative.FromConfig property) (loom.etl.runtime.ConfigValueError attribute) (loom.streaming.kafka.KafkaRecord attribute) key_ref_region (loom.rest.auth.JwtIssuerConfig attribute) keys (loom.ai.compiler.CompiledUsecaseCapability attribute) kid (loom.rest.auth.JwtIssuerConfig attribute) kind (loom.ai.compiler.CompiledRemoteAuth attribute) (loom.ai.describe.AgentCapabilityDescription attribute) (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.etl.runtime.AgentIssue attribute) (loom.streaming.Fork property)

L

leeway_seconds (loom.rest.auth.JwtAuthConfig attribute) library (loom.ai.compiler.CompiledSkillsCapability attribute) (loom.core.model.LoomType attribute) 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) (loom.core.sql.abc.SqlExecutionOptions attribute) (loom.core.sql.abc.SqlQueryResult 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_parts() (loom.streaming.bytewax.KafkaPartitionedSource method) list_tags() (loom.core.cache.dependency.GenerationalDependencyResolver method) (loom.core.cache.DependencyResolver method) (loom.core.cache.GenerationalDependencyResolver method) list_tools() (loom.ai.abc.McpSession method) (loom.ai.runtime.McpSession method) (loom.ai.runtime.SharedMcpSession 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_application() (in module loom.core.locator) load_authz_product() (in module loom.core.authz) (in module loom.core.authz.product) load_config() (in module loom.core.config) load_kafka_settings() (in module loom.streaming.kafka) load_signing_key() (loom.rest.auth.JwtIssuerConfig method) load_specs() (in module loom.ai.declarative) 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.ai module loom.ai.a2a module loom.ai.abc module loom.ai.compiler module loom.ai.config module loom.ai.declarative module loom.ai.describe module loom.ai.errors module loom.ai.fastapi module loom.ai.inference module loom.ai.registry module loom.ai.runtime module loom.ai.validate module loom.core.authz module loom.core.authz.elevation module loom.core.authz.product module 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.identity module loom.core.identity.wire module loom.core.locator module loom.core.model module loom.core.model.privilege module loom.core.model.scoped module loom.core.repository.abc module

loom.core.repository.abc.query module loom.core.repository.sqlalchemy module loom.core.repository.sqlalchemy.migrations module loom.core.repository.sqlalchemy.migrations.operations module loom.core.repository.sqlalchemy.rls module loom.core.repository.sqlalchemy.rls.guard_manifest module loom.core.repository.sqlalchemy.rls.integrity module loom.core.sql module loom.core.sql.abc module loom.core.sql.clickhouse module loom.core.sql.config 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.compiler module loom.etl.declarative module loom.etl.lineage module loom.etl.maintenance 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.auth module loom.rest.autocrud module loom.rest.compiler module loom.rest.cors 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.fastapi.sql module loom.rest.middleware 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_AI_ENGINE_API (loom.ai.abc.AgentEngineProvider attribute) 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) loom_type (loom.ai.abc.StateShape attribute) (loom.ai.compiler.CompiledOutput attribute) loom_type() (in module loom.core.model) loom_type_of() (in module loom.core.model) loom_type_to_polars() (in module loom.etl.backends.polars) 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) LoomType (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() (in module loom.ai.validate) main_repo (loom.core.use_case.UseCase property) MaintainSchema (class in loom.etl.maintenance) MaintainTable (class in loom.etl.maintenance) MaintenanceConfig (class in loom.etl.storage) MaintenanceError MaintenanceReport (class in loom.etl.maintenance) MaintenanceRunner (class in loom.etl.maintenance) MaintenanceSpec (class in loom.etl.maintenance) MaintenanceStep (class in loom.etl.maintenance) MaintenanceVacuumConfig (class in loom.etl.storage) map() (loom.etl.runtime.AgentBatchRunner method) MappingFileLocator (class in loom.etl.storage) MappingLocator (class in loom.etl.storage) matches() (loom.streaming.Predicate method) max_age (loom.rest.cors.CorsConfig attribute) max_agent_depth (loom.ai.config.AiConfig attribute) max_agent_depth_invalid() (in module loom.ai.errors) max_bytes (loom.core.cache.CacheConfig attribute) max_concurrent_runs (loom.ai.config.AiConfig attribute) max_concurrent_runs_invalid() (in module loom.ai.errors) max_execution_time (loom.core.sql.abc.SqlExecutionOptions attribute) (loom.core.sql.config.SqlConnectionConfig attribute) max_limit (loom.core.sql.config.SqlConnectionConfig attribute) max_prompt_bytes (loom.ai.config.AiConfig attribute) max_result_bytes (loom.ai.compiler.CompiledSqlCapability attribute) max_rows (loom.ai.compiler.CompiledSqlCapability attribute) max_size (loom.core.cache.CacheConfig attribute) max_sql_bytes (loom.core.sql.config.SqlConnectionConfig attribute) max_state_bytes (loom.ai.config.AiConfig attribute) max_usd (loom.etl.declarative.WithAgent property) may_extend_base (loom.core.authz.CompositionRules attribute) Mcp() (in module loom.core.use_case) (in module loom.core.use_case.markers) mcp() (loom.ai.abc.AgentHandle method) (loom.testing.AgentHandleDouble method) mcp_auth_conflict() (in module loom.ai.errors) mcp_auth_strategy_invalid() (in module loom.ai.errors) mcp_auth_strategy_unknown() (in module loom.ai.errors) mcp_connection() (in module loom.ai.compiler) mcp_connection_conflict() (in module loom.ai.errors) mcp_credentials_inline() (in module loom.ai.errors) mcp_headers_ref_invalid() (in module loom.ai.errors) mcp_marker_unknown() (in module loom.ai.errors) mcp_server_unknown() (in module loom.ai.errors) mcp_server_unreachable() (in module loom.ai.errors) mcp_servers (loom.ai.config.AiConfig attribute) mcp_transport_invalid() (in module loom.ai.errors) mcp_url_invalid() (in module loom.ai.errors) McpCapability (class in loom.ai.declarative) McpHandle (class in loom.ai.abc) McpHandleDouble (class in loom.testing) McpServerConfig (class in loom.ai.config) McpSession (class in loom.ai.abc) (class in loom.ai.runtime) McpToolCallResult (class in loom.ai.abc) McpToolInfo (class in loom.ai.abc) mechanism (loom.core.identity.Identity attribute) media_type (loom.ai.abc.Attachment attribute) (loom.streaming.kafka.ContentType attribute) merge_resolvers() (in module loom.core.config) Message (class in loom.streaming) message (loom.ai.abc.ErrorEvent attribute) (loom.etl.runtime.AgentIssue attribute) 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) messages (loom.ai.abc.AgentResult attribute) (loom.ai.abc.FinalEvent attribute) meta (loom.streaming.kafka.MessageEnvelope attribute) metadata (loom.ai.compiler.AgentPlan attribute) MetricsAdapter (class in loom.core.engine) missing (loom.core.authz.GrantCheck attribute) missing_config_params() (loom.etl.compiler.ETLCompilationError class method) missing_generic_param() (loom.etl.compiler.ETLCompilationError class method) missing_params_fields() (loom.etl.compiler.ETLCompilationError class method) missing_source_params() (loom.etl.compiler.ETLCompilationError class method) missing_target() (loom.etl.compiler.ETLCompilationError class method) MissingTablePolicy (class in loom.etl.storage) model (loom.ai.inference.InferenceTarget attribute) model_role_unbound() (in module loom.ai.errors) models (loom.ai.config.AiConfig attribute) module loom.ai loom.ai.a2a loom.ai.abc loom.ai.compiler loom.ai.config loom.ai.declarative loom.ai.describe loom.ai.errors loom.ai.fastapi loom.ai.inference loom.ai.registry loom.ai.runtime loom.ai.validate loom.core.authz loom.core.authz.elevation loom.core.authz.product 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.identity loom.core.identity.wire loom.core.locator loom.core.model loom.core.model.privilege loom.core.model.scoped loom.core.repository.abc loom.core.repository.abc.query loom.core.repository.sqlalchemy loom.core.repository.sqlalchemy.migrations loom.core.repository.sqlalchemy.migrations.operations loom.core.repository.sqlalchemy.rls loom.core.repository.sqlalchemy.rls.guard_manifest loom.core.repository.sqlalchemy.rls.integrity loom.core.sql loom.core.sql.abc loom.core.sql.clickhouse loom.core.sql.config 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.compiler loom.etl.declarative loom.etl.lineage loom.etl.maintenance loom.etl.pipeline loom.etl.runner loom.etl.runtime loom.etl.schema loom.etl.storage loom.etl.testing loom.etl.testing.spark loom.rest.auth loom.rest.autocrud loom.rest.compiler loom.rest.cors loom.rest.fastapi loom.rest.fastapi.app loom.rest.fastapi.openapi loom.rest.fastapi.response loom.rest.fastapi.router_runtime loom.rest.fastapi.sql loom.rest.middleware 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) msgspec_type() (in module loom.core.model) 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.ai.abc.McpToolInfo attribute) (loom.ai.compiler.AgentPlan attribute) (loom.ai.compiler.CompiledInstruction attribute) (loom.ai.describe.AgentDescription attribute) (loom.core.authz.Permission attribute) (loom.core.authz.Role attribute) (loom.core.config.ConfigResolver property) (loom.core.config.SecretsManagerResolver property) (loom.core.config.SsmResolver property) (loom.core.sql.abc.SqlColumn attribute) (loom.etl.declarative.WithAgent property) (loom.rest.auth.Authenticator property) (loom.rest.auth.JwtAuthenticator property) (loom.streaming.IntoSink property) (loom.streaming.kafka.SchemaRef attribute) (loom.streaming.StreamFlow property) names (loom.ai.compiler.CompiledSkillsCapability attribute) namespace (loom.streaming.kafka.SchemaRef attribute) native() (loom.ai.abc.AgentHandle method) (loom.ai.abc.NativeCapableEngine method) (loom.ai.runtime.AgentRuntime method) (loom.testing.AgentHandleDouble method)

native_tool_duplicate() (in module loom.ai.errors) native_tool_support (loom.ai.abc.AgentEngineProvider attribute) native_tool_unsupported() (in module loom.ai.errors) NativeCapability (class in loom.ai.declarative) NativeCapableEngine (class in loom.ai.abc) NativeToolSupport (in module loom.ai.abc) 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) non_extensible (loom.core.authz.CompositionRules attribute) normalise_storage_section() (in module loom.etl.storage) normalize_bson_value() (in module loom.streaming) normalize_extended_json() (loom.etl.declarative.FromMongo method) NOT_EXISTS (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) NotFound null_col() (loom.etl.backends._historify.HistorifyBackend method) NullSqlQueryService (class in loom.core.sql)

O

of() (loom.core.authz.Scope class method) 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.core.sql.abc.SqlExecutionOptions attribute) (loom.core.sql.abc.SqlQueryResult attribute) (loom.streaming.kafka.KafkaRecord attribute) ok (loom.ai.abc.McpToolCallResult attribute) (loom.ai.abc.ToolResultEvent attribute) (loom.etl.maintenance.TableMaintenanceResult property) on_call() (loom.testing.McpHandleDouble method) on_call_untyped() (loom.testing.McpHandleDouble method) on_event() (loom.core.engine.MetricsAdapter method) (loom.etl.testing.StubRunObserver method) on_extra_fields() (loom.etl.declarative.FromMongo method) on_output (loom.ai.compiler.AgentPlan attribute) on_output_input_unsatisfied() (in module loom.ai.errors) on_output_invoker_missing() (in module loom.ai.errors) on_output_usecase_also_granted() (in module loom.ai.errors) on_output_usecase_unknown() (in module loom.ai.errors) on_query() (loom.testing.SqlGrantHandleDouble method) on_run() (loom.testing.AgentHandleDouble method) on_run_text() (loom.testing.AgentHandleDouble method) on_transaction_committed() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (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) OpenHatchOp (class in loom.core.repository.sqlalchemy.migrations.operations) OperationDeclaration (class in loom.etl.maintenance) operations_for() (loom.etl.maintenance.MaintenanceStep method) OpSpec (class in loom.etl.maintenance) OptimizeResult (class in loom.etl.maintenance) options (loom.ai.inference.InferenceTarget attribute) OtelConfig (class in loom.core.config) output (loom.ai.abc.AgentAnswer attribute) (loom.ai.abc.AgentResult attribute) (loom.ai.abc.FinalEvent attribute) (loom.ai.compiler.AgentPlan attribute) (loom.etl.declarative.WithAgent property) (loom.streaming.StreamFlow property) (loom.streaming.testing.StreamingTestRunner property) output_check (loom.ai.compiler.AgentPlan attribute) output_check_unresolvable() (in module loom.ai.errors) output_mode (loom.ai.inference.InferenceTarget attribute) output_mode_unknown() (in module loom.ai.errors) output_mode_unsupported() (in module loom.ai.errors) OUTPUT_MODES (in module loom.ai.inference) output_schema (loom.ai.describe.AgentDescription attribute) output_schema_invalid() (in module loom.ai.errors) output_tokens (loom.ai.abc.AgentUsage attribute) output_type() (loom.ai.runtime.AgentRuntime method) output_type_ref_unresolvable() (in module loom.ai.errors) output_type_ref_unsupported() (in module loom.ai.errors) OutputCheck (in module loom.ai.abc) OutputHookSpec (class in loom.ai.declarative) OutputMode (in module loom.ai.inference) owner_problems() (in module loom.core.repository.sqlalchemy.rls.integrity)

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) ParallelProcessGroup (class in loom.etl.compiler) ParallelStepGroup (class in loom.etl.compiler) ParamBinding (class in loom.core.engine) ParamExpr (class in loom.etl.pipeline) params (loom.ai.compiler.CompiledPythonCapability attribute) parent_trace_id (loom.streaming.kafka.MessageMetadata attribute) ParquetReadOptions (class in loom.etl.declarative) ParquetWriteOptions (class in loom.etl.declarative) parse() (loom.core.authz.Scope class method) (loom.core.command.CommandAdapter method) parse_json() (loom.etl.declarative.FromFile method) (loom.etl.declarative.FromTable method) PartialUnique (class in loom.core.model) 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) PartitionRange (class in loom.core.model) PartitionStrategy (class in loom.streaming) password (loom.core.sql.config.SqlConnectionConfig attribute) path (loom.core.authz.Scope attribute) (loom.core.sql.config.SqlEndpointConfig attribute) (loom.etl.declarative.FromFile property) (loom.etl.pipeline.ParamExpr property) (loom.rest.auth.RequestCredentials attribute) PathRouteResolver (class in loom.etl.storage) PathTarget (class in loom.etl.storage) payload (loom.streaming.IntoSink property) (loom.streaming.kafka.MessageEnvelope attribute) PayloadExpander (class in loom.streaming) pending_revisions() (in module loom.core.repository.sqlalchemy.rls.guard_manifest) Permission (class in loom.core.authz) permissions (loom.core.authz.Role attribute) (loom.core.authz.RoleCatalog property) (loom.core.authz.RoleSpec attribute) permissions_of() (loom.core.authz.RoleCatalog method) pipeline_statuses (loom.etl.testing.StubRunObserver property) PipelinePlan (class in loom.etl.compiler) plan (loom.testing.UseCaseTest property) plans (loom.ai.runtime.AgentRuntime property) polars_to_loom_type() (in module loom.etl.backends.polars) 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) policies (loom.ai.compiler.AgentPlan attribute) (loom.ai.describe.AgentDescription attribute) policy_out_of_range() (in module loom.ai.errors) PolicySpec (class in loom.ai.declarative) poll() (loom.streaming.kafka.KafkaConsumer method) (loom.streaming.kafka.KafkaConsumerClient method) (loom.streaming.kafka.KafkaMessageConsumer method) (loom.streaming.kafka.MessageConsumer method)

poll_backoff_ms (loom.streaming.kafka.ConsumerSettings attribute) poll_timeout_ms (loom.streaming.kafka.ConsumerSettings attribute) pool_size (loom.core.sql.config.SqlConnectionConfig attribute) PostCommitChannel (class in loom.core.engine) PostCommitError 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) prefixed() (loom.streaming.compiler.CompilationIssue method) PrefixLocator (class in loom.etl.storage) preflight_sql() (in module loom.core.repository.sqlalchemy.rls.guard_manifest) 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) price (loom.ai.compiler.AgentPlan attribute) prices (loom.ai.config.AiConfig attribute) private_key_path (loom.rest.auth.JwtIssuerConfig attribute) private_key_ref (loom.rest.auth.JwtIssuerConfig attribute) Privilege (class in loom.core.model) (class in loom.core.model.privilege) Problem (class in loom.core.repository.sqlalchemy.rls.integrity) Process (class in loom.streaming) process (loom.streaming.StreamFlow property) processes (loom.etl.pipeline.ETLPipeline attribute) ProcessPlan (class in loom.etl.compiler) 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.ai.a2a.A2AEventProjector method) (loom.etl.declarative.FromMongo method) Projection (class in loom.core.model) (class in loom.core.repository.sqlalchemy) ProjectionField() (in module loom.core.model) Prompt (in module loom.ai.abc) ProtectScopedTableOp (class in loom.core.repository.sqlalchemy.migrations.operations) protocol (loom.streaming.kafka.KafkaSecuritySettings attribute) provider (loom.ai.inference.InferenceTarget attribute) provider_details (loom.ai.abc.AgentAnswer attribute) (loom.ai.abc.AgentResult attribute) (loom.ai.abc.FinalEvent attribute) provider_not_installed() (in module loom.ai.errors) provider_setting_missing() (in module loom.ai.errors) provider_unknown() (in module loom.ai.errors) provides_roles (loom.rest.auth.Authenticator property) (loom.rest.auth.JwtAuthenticator property) public_keys (loom.rest.auth.JwtAuthConfig attribute) put() (loom.etl.checkpoint.CheckpointStore method) pydantic_type() (in module loom.core.model) python_factory_failed() (in module loom.ai.errors) python_factory_not_callable() (in module loom.ai.errors) python_factory_params_rejected() (in module loom.ai.errors) python_factory_unresolvable() (in module loom.ai.errors) python_remote_not_granted() (in module loom.ai.errors) PythonCapability (class in loom.ai.declarative)

Q

qualify() (loom.etl.schema.TableRef method) query() (loom.ai.abc.SqlGrantHandle method) (loom.testing.SqlGrantHandleDouble method)

QueryCompiler (class in loom.core.repository.abc) QuerySpec (class in loom.core.repository.abc) (class in loom.core.repository.abc.query)

R

raise_if_errors() (loom.etl.maintenance.MaintenanceReport method) range_partitions() (in module loom.core.model) RangePartition (class in loom.core.model) 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) readonly (loom.core.sql.abc.SqlExecutionOptions attribute) (loom.core.sql.config.SqlConnectionConfig attribute) RecordStep (class in loom.streaming) ref (loom.etl.schema.TableRef property) region (loom.ai.inference.InferenceTarget attribute) register_authz_product() (in module loom.core.authz.product) register_scope_source() (in module loom.core.repository.sqlalchemy.rls) register_sink() (loom.streaming.bytewax.runner.StreamingRunner method) (loom.streaming.bytewax.StreamingRunner method) registered_model_tables() (in module loom.core.model.scoped) registered_repository_type() (in module loom.rest.autocrud) RegisteredSink (class in loom.streaming.bytewax) Relation (class in loom.core.model) RelationField() (in module loom.core.model) remote() (loom.ai.abc.ToolsetContext method) remote_clients (loom.ai.config.AiConfig attribute) remote_clients_unknown() (in module loom.ai.errors) rename() (loom.etl.backends._historify.HistorifyBackend method) render() (loom.ai.fastapi.AgentJSONResponse method) (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_matching() (loom.etl.declarative.IntoTable method) replace_partition() (loom.etl.declarative.IntoTable method) replace_partitions() (loom.etl.declarative.IntoTable method) replace_physical_partitions() (loom.etl.declarative.IntoTable method) replace_where() (loom.etl.declarative.IntoTable method) RepoFor (class in loom.core.repository.abc) Report (class in loom.core.repository.sqlalchemy.rls) Repository (class in loom.core.repository.abc) RepositoryRead (class in loom.core.repository.abc) RepositorySQLAlchemy (class in loom.core.repository.sqlalchemy) RepositoryWrite (class in loom.core.repository.abc) RequestCredentials (class in loom.rest.auth) requests (loom.ai.abc.AgentUsage attribute) require() (loom.core.authz.RoleCatalog method) require_attribute() (loom.core.identity.Identity method) require_guard_revision() (in module loom.core.repository.sqlalchemy.rls.integrity) require_guard_revision_sync() (in module loom.core.repository.sqlalchemy.rls.integrity) require_provider_sdk() (in module loom.ai.registry) require_provider_setting() (in module loom.ai.registry) require_revision() (in module loom.core.repository.sqlalchemy.rls.integrity) require_subject() (loom.core.identity.Identity method) requires_roles (loom.rest.model.RestInterface attribute) reset() (loom.streaming.testing.StreamingTestRunner method) reset_identity() (in module loom.core.identity) resolve() (loom.core.config.ConfigContext method) (loom.core.config.ConfigResolver method) (loom.core.config.SecretsManagerResolver method) (loom.core.config.SsmResolver method) (loom.etl.maintenance.MaintainSchema method) (loom.etl.maintenance.MaintainTable 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_engine_provider() (in module loom.ai.registry) resolve_json_type() (in module loom.etl.schema) resolve_producer_topic() (in module loom.streaming.kafka) resolve_query_roles() (in module loom.core.sql) 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) revision_of() (in module loom.core.repository.sqlalchemy.rls.integrity) rewind_to() (loom.etl.backends._historify.HistorifyBackend method) rls_session_settings() (in module loom.core.repository.sqlalchemy.rls) Role (class in loom.core.authz) role (loom.core.authz.Grant attribute) role() (loom.core.authz.RoleCatalog method) RoleCatalog (class in loom.core.authz) RoleNotAllowedError RoleRequiredError roles (loom.core.authz.RoleCatalog property) (loom.core.identity.Identity attribute) (loom.core.sql.abc.SqlExecutionOptions attribute) roles_claim (loom.rest.auth.JwtAuthConfig attribute) (loom.rest.auth.JwtIssuerConfig attribute) roles_need_identity_binding() (in module loom.core.sql.config) roles_with() (loom.core.authz.RoleCatalog method) RolesNotBoundError RoleSpec (class in loom.core.authz) root() (loom.core.authz.Scope class method) Route (class in loom.streaming) RoutedCatalog (class in loom.etl.storage) Router (class in loom.streaming) router_branch_safe (loom.streaming.IntoSink property) routes (loom.rest.model.RestInterface attribute) (loom.streaming.Broadcast property) (loom.streaming.ExpandRoutes property) (loom.streaming.Fork property) (loom.streaming.Router property) RouteSources (class in loom.rest.compiler) row_count (loom.core.sql.abc.SqlQueryResult attribute) rows (loom.core.sql.abc.SqlQueryResult attribute) RowScoped (class in loom.core.model) (class in loom.core.model.scoped) 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.ai.abc.AgentEngine method) (loom.ai.abc.AgentHandle method) (loom.ai.runtime.AgentRuntime method) (loom.core.engine.RuntimeExecutor method) (loom.etl.maintenance.MaintenanceRunner method) (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.AgentHandleDouble method) (loom.testing.FakeAgentEngine method) (loom.testing.GoldenHarness method) (loom.testing.UseCaseTest method) run_data_migrations() (in module loom.core.repository.sqlalchemy.migrations) run_error_class() (in module loom.ai.errors) run_from_config() (loom.etl.maintenance.MaintenanceRunner method) run_guard_operation() (in module loom.core.repository.sqlalchemy.migrations.operations) run_migrations() (in module loom.core.repository.sqlalchemy.migrations) run_stream() (loom.ai.abc.AgentEngine method) (loom.ai.runtime.AgentRuntime method) (loom.testing.FakeAgentEngine method) run_text() (loom.ai.abc.AgentHandle method) (loom.testing.AgentHandleDouble method) run_with_baseline() (loom.testing.GoldenHarness method) RuntimeConfigurationError 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.ai.abc.StateShape attribute) (loom.ai.compiler.CompiledOutput attribute) schema() (loom.core.model.LoomType method) (loom.etl.runtime.TableDiscovery method) (loom.etl.testing.StubCatalog method) schema_ref (loom.streaming.kafka.MessageDescriptor attribute) SchemaConfig (class in loom.core.locator) SchemaError SchemaMode (class in loom.etl.declarative) SchemaNames (class in loom.core.repository.sqlalchemy.rls) SchemaNotFoundError SchemaRef (class in loom.streaming.kafka) Scope (class in loom.core.authz) scope (loom.core.authz.Grant attribute) (loom.etl.declarative.IntoTemp property) scope_columns() (in module loom.core.model) scope_protection_hook() (in module loom.core.repository.sqlalchemy.migrations) ScopeColumn (class in loom.core.model) (class in loom.core.model.scoped) ScopedField() (in module loom.core.model) ScopedTable (class in loom.core.model) (class in loom.core.model.scoped) scopes_with() (in module loom.core.authz) secret_path (loom.rest.auth.JwtAuthConfig attribute) (loom.rest.auth.JwtIssuerConfig attribute) 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) send_receive_timeout (loom.core.sql.config.SqlConnectionConfig attribute) serialize_plan() (in module loom.testing) server (loom.ai.compiler.CompiledMcpCapability attribute) 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_identity() (in module loom.core.identity) set_value() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) settings (loom.ai.compiler.CompiledRemoteAuth attribute) (loom.ai.describe.AgentCapabilityDescription attribute) (loom.core.sql.config.SqlConnectionConfig attribute) SharedMcpSession (class in loom.ai.runtime) 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) skills_library_escapes() (in module loom.ai.errors) skills_library_invalid() (in module loom.ai.errors) skills_name_collision() (in module loom.ai.errors) skills_root (loom.ai.config.AiConfig attribute) skills_root_missing() (in module loom.ai.errors) SkillsCapability (class in loom.ai.declarative) 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) source_path (loom.ai.compiler.AgentPlan attribute) (loom.ai.describe.AgentDescription attribute) SourceBinding (class in loom.etl.compiler) 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) spec_malformed() (in module loom.ai.errors) spec_unknown_field() (in module loom.ai.errors) spec_version (loom.ai.compiler.AgentPlan attribute) (loom.ai.describe.AgentDescription attribute) spec_version_deprecated() (in module loom.ai.errors) spec_version_missing() (in module loom.ai.errors) spec_version_unsupported() (in module loom.ai.errors) specs (loom.ai.config.AiConfig attribute) sql() (loom.ai.abc.AgentHandle method) (loom.core.repository.sqlalchemy.rls.guard_manifest.GuardRevision method) (loom.testing.AgentHandleDouble method) sql_config_missing() (in module loom.ai.errors) sql_connection_not_readonly() (in module loom.ai.errors) sql_connection_roles_unbound() (in module loom.ai.errors) sql_connection_unknown() (in module loom.ai.errors) sql_endpoint (loom.core.sql.config.SqlConnectionConfig attribute) sql_readonly_drift() (in module loom.ai.errors) sql_result_bound_missing() (in module loom.ai.errors) SqlAlchemyDatabaseConfig (class in loom.streaming) SQLAlchemyDefaultRepositoryBuilder (class in loom.core.repository.sqlalchemy) SQLAlchemyElevationSink (class in loom.core.repository.sqlalchemy.rls) SqlAlchemySinkConfig (class in loom.streaming) SqlCapability (class in loom.ai.declarative) SqlColumn (class in loom.core.sql.abc) SqlConfig (class in loom.core.sql.config) SqlConnectionConfig (class in loom.core.sql.config) SqlEndpointConfig (class in loom.core.sql.config) SqlExecutionError SqlExecutionOptions (class in loom.core.sql.abc) SqlExecutor (class in loom.core.sql.abc) SQLExecutor (class in loom.etl.runtime) SqlGrantHandle (class in loom.ai.abc) SqlGrantHandleDouble (class in loom.testing) SqlQueryResult (class in loom.core.sql.abc) SqlQueryService (class in loom.core.sql) 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) startup_problems() (in module loom.core.repository.sqlalchemy.rls.integrity) startup_timeout_ms (loom.ai.config.AiConfig attribute) state (loom.ai.compiler.AgentPlan attribute) state_declaration_conflict() (in module loom.ai.errors) state_schema_invalid() (in module loom.ai.errors) state_shape() (loom.ai.runtime.AgentRuntime method) state_surface_unsupported() (in module loom.ai.errors) state_type_ref_unresolvable() (in module loom.ai.errors) state_type_ref_unsupported() (in module loom.ai.errors) StateShape (class in loom.ai.abc) status (loom.ai.abc.HealthStatus attribute) (loom.ai.runtime.AgentHealth attribute) Step (class in loom.streaming) step_name() (loom.streaming.Step class method) step_statuses (loom.etl.testing.StubRunObserver property) StepCompilationContext (class in loom.etl.compiler) StepContext (class in loom.streaming) StepPlan (class in loom.etl.compiler) 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) StorageProfile (class in loom.etl.storage) stream_sse() (in module loom.ai.fastapi) StreamFlow (class in loom.streaming) streaming (loom.ai.inference.InferenceTarget attribute) streaming_flags (loom.etl.testing.StubTargetWriter attribute) streaming_required_by_capability() (in module loom.ai.errors) StreamingErrorCode (class in loom.streaming.compiler) 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) structured (loom.ai.abc.McpToolCallResult attribute) StubCatalog (class in loom.etl.testing) StubRunObserver (class in loom.etl.testing) StubSourceReader (class in loom.etl.testing) StubTargetWriter (class in loom.etl.testing) subject (loom.core.authz.Grant attribute) (loom.core.identity.Identity attribute) summary (loom.ai.abc.ToolResultEvent attribute) supported_capability_kinds() (loom.ai.abc.AgentEngineProvider method) supported_crud_ops() (in module loom.rest.autocrud) SUPPORTED_ENGINE_APIS (in module loom.ai.registry) SupportsCallerScopedSession (class in loom.core.repository.abc) SupportsPostCommit (class in loom.core.repository.sqlalchemy) SyncExecutor (class in loom.core.repository.sqlalchemy.rls.integrity) SystemError

T

table (loom.etl.declarative.ClickHouseSourceSpec property) table_problems() (in module loom.core.repository.sqlalchemy.rls.integrity) table_ref (loom.etl.declarative.EmptyReplaceError attribute) (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) TableMaintenanceResult (class in loom.etl.maintenance) 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) TargetBinding (class in loom.etl.compiler) TargetWriter (class in loom.etl.runtime) temp_name (loom.etl.declarative.FromTemp property) (loom.etl.declarative.IntoTemp property) temp_not_produced() (loom.etl.compiler.ETLCompilationError class method) TempCleaner (class in loom.etl.checkpoint) template (loom.ai.compiler.CompiledInstruction attribute) template_compilation_failed() (in module loom.ai.errors) template_extra_missing() (in module loom.ai.errors) temporal_conflict_min_date() (loom.etl.backends._historify.HistorifyBackend method) TempSourceSpec (class in loom.etl.declarative) text (loom.ai.abc.TextDeltaEvent attribute) (loom.ai.compiler.CompiledInstruction attribute) TextDeltaEvent (class in loom.ai.abc) timeout_ms (loom.ai.compiler.CompiledMcpCapability attribute) (loom.ai.config.McpServerConfig attribute) timestamp_ms (loom.streaming.kafka.KafkaRecord attribute) TimestampedModel (class in loom.core.model) TimestampMixin (class in loom.core.repository.sqlalchemy) to_builtins() (loom.core.model.LoomType method) 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) token (loom.core.identity.IssuedToken attribute) TokenIssuer (class in loom.core.identity) tool (loom.ai.abc.ToolCallEvent attribute) (loom.ai.compiler.CompiledNativeCapability attribute) tool_calls (loom.ai.abc.AgentUsage attribute) tool_filter_matches_nothing() (in module loom.ai.errors) ToolCallEvent (class in loom.ai.abc) ToolResultEvent (class in loom.ai.abc) ToolResultT (class in loom.ai.abc) tools() (loom.ai.abc.McpHandle method) (loom.testing.McpHandleDouble method) ToolsetContext (class in loom.ai.abc) ToolsetFactory (in module loom.ai.abc) 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) total_tokens (loom.ai.abc.AgentUsage property) trace_id (loom.streaming.kafka.MessageMetadata attribute) TraceIdMiddleware (class in loom.rest.middleware) transactional() (in module loom.core.repository.sqlalchemy) transport (loom.ai.compiler.CompiledMcpCapability attribute) (loom.ai.config.McpServerConfig attribute) 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) ttl_jitter (loom.core.cache.CacheConfig attribute) ttl_seconds (loom.rest.auth.JwtIssuerConfig attribute) type (loom.core.model.LoomType attribute) (loom.core.sql.abc.SqlColumn attribute) TypeRefOutput (class in loom.ai.declarative)

U

unassigned() (loom.streaming.kafka.KafkaConsumerClient class method) Unauthenticated unbounded() (loom.etl.declarative.FromClickHouse method) unknown (loom.etl.runner.InvalidStageError attribute) unknown_param_field() (loom.etl.compiler.ETLCompilationError class method) unknown_source_table() (loom.etl.compiler.ETLCompilationError class method) unknown_target_table() (loom.etl.compiler.ETLCompilationError class method) unknown_template_field() (loom.etl.compiler.ETLCompilationError class method) UnknownConnectionError UnknownPermission UnknownRole UnprotectScopedTableOp (class in loom.core.repository.sqlalchemy.migrations.operations) unresolved_config_value() (loom.etl.compiler.ETLCompilationError class method) unsupported_config_value() (loom.etl.compiler.ETLCompilationError class method) UnsupportedBoundaryType UnsupportedQuery 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.etl.declarative.IntoTable method) (loom.testing.InMemoryRepository method) update_empty_update_set() (loom.etl.compiler.ETLCompilationError class 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) upsert_exclude_include_conflict() (loom.etl.compiler.ETLCompilationError class method) upsert_key_in_exclude() (loom.etl.compiler.ETLCompilationError class method) upsert_no_keys() (loom.etl.compiler.ETLCompilationError class method) url (loom.ai.compiler.CompiledA2ACapability attribute) (loom.ai.compiler.CompiledMcpCapability attribute) (loom.ai.config.A2AAgentConfig attribute) (loom.ai.config.McpServerConfig attribute) (loom.core.sql.config.SqlConnectionConfig attribute) usage (loom.ai.abc.AgentAnswer attribute) (loom.ai.abc.AgentResult attribute) (loom.ai.abc.ErrorEvent attribute) (loom.ai.abc.FinalEvent attribute) (loom.ai.errors.AgentRunError attribute) use_case (loom.ai.compiler.CompiledConversation attribute) (loom.ai.compiler.CompiledOutputHook attribute) use_case_mcp_grant() (loom.ai.runtime.AgentRuntime method) use_case_tool_filter_matches_nothing() (in module loom.ai.errors) use_cases (loom.ai.compiler.CompiledUsecaseCapability attribute) UseCase (class in loom.core.use_case) usecase (loom.ai.compiler.CompiledConversation attribute) (loom.ai.compiler.CompiledOutputHook attribute) usecase_key_unknown() (in module loom.ai.errors) UsecaseCapability (class in loom.ai.declarative) UseCaseCompiler (class in loom.core.engine) UseCaseMcpGrant (class in loom.ai.runtime) UseCaseTest (class in loom.testing) username (loom.core.sql.config.SqlConnectionConfig attribute)

V

vacuum() (loom.etl.maintenance.DeltaTableMaintainer method) (loom.etl.maintenance.MaintainSchema method) (loom.etl.maintenance.MaintainTable method) VacuumResult (class in loom.etl.maintenance) VacuumSpec (class in loom.etl.maintenance) validate() (loom.core.config.OtelConfig method) (loom.etl.lineage.LineageConfig method) (loom.etl.runtime.AgentBatchRunner 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) validate_elevations() (in module loom.core.repository.sqlalchemy.rls) validate_execute_signature() (in module loom.etl.compiler)

validate_param_exprs() (in module loom.etl.compiler) validate_params_compat() (in module loom.etl.compiler) validate_patterns() (in module loom.ai.validate) validate_plan_catalog() (in module loom.etl.compiler) validate_plan_temps() (in module loom.etl.compiler) validate_process_catalog() (in module loom.etl.compiler) validate_step() (in module loom.etl.compiler) validate_step_catalog() (in module loom.etl.compiler) validate_upsert_spec() (in module loom.etl.compiler) validated() (loom.core.repository.sqlalchemy.rls.BootstrapConfig method) value (loom.streaming.kafka.KafkaRecord attribute) value_type (loom.etl.declarative.FromConfig property) verification_key() (loom.rest.auth.JwtAuthConfig method) verify() (in module loom.core.repository.sqlalchemy.rls) version (loom.streaming.kafka.SchemaRef attribute) version() (loom.etl.runtime.AgentBatchRunner method)

W

walk_process_nodes() (in module loom.streaming.compiler) 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_agent() (loom.testing.UseCaseTest method) with_caller() (loom.testing.UseCaseTest method) with_command() (loom.testing.UseCaseTest method) with_config() (loom.etl.testing.PolarsStepRunner method) (loom.etl.testing.spark.SparkStepRunner method) with_default_resolvers() (in module loom.core.config) with_deps() (loom.testing.UseCaseTest method) with_grants() (loom.testing.AgentHandleDouble method) with_input() (loom.testing.UseCaseTest method) with_loaded() (loom.testing.UseCaseTest method) with_main_repo() (loom.testing.UseCaseTest method)

with_mcp() (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) with_tools() (loom.testing.McpHandleDouble method) WithAgent (class in loom.etl.declarative) WithAsync (class in loom.streaming) wrap() (loom.core.cache.CachedCalls method) 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)

Z

z_order() (loom.etl.maintenance.DeltaTableMaintainer method) z_order_by() (loom.etl.maintenance.MaintainSchema method) (loom.etl.maintenance.MaintainTable method)

ZOrderSpec (class in loom.etl.maintenance)