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) 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_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_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_missing() (in module loom.ai.errors) agent_url() (in module loom.ai.a2a) AgentAnswer (class in loom.ai.abc) 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) 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) 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_profiles (loom.rest.model.RestInterface attribute) allowed_roles (loom.core.sql.config.SqlConnectionConfig attribute) 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) apply() (loom.etl.testing.ETLScenario method) apply_config() (loom.core.cache.CacheGateway class method) (loom.core.cache.gateway.CacheGateway class method) apply_overwrite_cols() (loom.etl.backends._historify.HistorifyBackend method) 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) 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) Authenticator (class in loom.rest.auth) 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) 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) 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) 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) CatalogConnection (class in loom.etl.storage) CatalogRouteResolver (class in loom.etl.storage) CatalogTarget (class in loom.etl.storage) CategoricalType (class in loom.etl.schema) causation_id (loom.streaming.kafka.MessageMetadata attribute) checkpoint_root (loom.etl.storage.StorageConfig property) checkpoint_storage_options (loom.etl.storage.StorageConfig property) CheckpointCleaner (in module loom.etl.checkpoint) CheckpointCleanupError CheckpointScope (class in loom.etl.checkpoint) CheckpointStore (class in loom.etl.checkpoint) checks (loom.ai.runtime.AgentHealth attribute) cleanup_correlation() (loom.etl.checkpoint.CheckpointStore method) (loom.etl.runner.ETLRunner method) cleanup_run() (loom.etl.checkpoint.CheckpointStore method) clear() (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) ClickHouseConfig (class in loom.etl.storage) 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) 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) CompilationError

CompilationIssue (class in loom.streaming.compiler) compile() (loom.ai.compiler.AgentCompiler method) (loom.core.engine.UseCaseCompiler 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_schema() (loom.core.command.CommandAdapter method) compile_sort() (loom.core.repository.abc.QueryCompiler method) compile_sources() (loom.rest.compiler.RestInterfaceCompiler 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) CompositeRouteResolver (class in loom.etl.storage) Compute (class in loom.core.use_case) (class in loom.core.use_case.compute) computes (loom.core.use_case.UseCase attribute) ComputeStep (class in loom.core.engine) ConcurrentMcpSession (class in loom.ai.abc) (class in loom.ai.runtime) config (loom.ai.compiler.CompiledSqlCapability attribute) 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) 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) 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) 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)

D

database (loom.streaming.MongoDBRef attribute) dates_requiring_rerun (loom.etl.declarative.HistorifyRepairReport attribute) DatetimeType (class in loom.etl.schema) DecimalType (class in loom.etl.schema) 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_spec() (in module loom.ai.declarative) DecodedSpec (class in loom.ai.declarative) DecodeError (class in loom.streaming.kafka) DecodeOk (class in loom.streaming.kafka) decoder (loom.ai.abc.StateShape attribute) (loom.ai.compiler.CompiledOutput attribute) 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) DependencyResolver (class in loom.core.cache) DepsFactory (class in loom.ai.abc) 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) detail (loom.ai.abc.HealthStatus attribute) (loom.ai.runtime.AgentHealth attribute) details (loom.ai.abc.AgentUsage attribute) 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) DomainError Drain (class in loom.streaming) drain() (loom.core.engine.PostCommitChannel method) drop() (loom.etl.backends._historify.HistorifyBackend method) dumps() (loom.core.cache.MsgspecSerializer 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) 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_supported_kinds() (in module loom.ai.registry) enqueue() (loom.core.engine.PostCommitChannel method) enqueue_priority() (loom.core.engine.PostCommitChannel method) 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) ETLParams (class in loom.etl.pipeline) ETLPipeline (class in loom.etl.pipeline) ETLProcess (class in loom.etl.pipeline) ETLRunner (class in loom.etl.runner) ETLScenario (class in loom.etl.testing)

ETLStep (class in loom.etl.pipeline) eval_param_expr() (in module loom.etl.backends._historify) event_names (loom.etl.testing.StubRunObserver property) EventKind (class in loom.core.engine) events (loom.etl.testing.StubRunObserver attribute) (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.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) extra (loom.streaming.kafka.ConsumerSettings attribute) (loom.streaming.kafka.ProducerSettings attribute)

F

F() (in module loom.core.use_case) (in module loom.core.use_case.field_ref) factory (loom.ai.compiler.CompiledPythonCapability attribute) factory_ref (loom.ai.compiler.CompiledPythonCapability attribute) FakeAgentEngine (class in loom.testing) Field (class in loom.core.model) field_ref() (in module loom.core.use_case.field_ref) FieldExpr (class in loom.core.use_case.field_ref) FieldRef (class in loom.core.use_case) (class in loom.core.use_case.field_ref) FileLocation (class in loom.etl.storage) FileLocator (class in loom.etl.storage) FilePathConfig (class in loom.etl.storage) FileRoute (class in loom.etl.storage) FileSourceSpec (class in loom.etl.declarative) FilterGroup (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) FilterOp (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) FilterParams (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) filters (loom.core.repository.abc.FilterParams attribute) (loom.core.repository.abc.query.FilterParams attribute) FilterSpec (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) FinalEvent (class in loom.ai.abc) 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) flush() (loom.etl.runner.ETLRunner method) (loom.streaming.kafka.KafkaMessageProducer method) (loom.streaming.kafka.KafkaProducer method) (loom.streaming.kafka.KafkaProducerClient method) (loom.streaming.kafka.MessageProducer method) Forbidden

force_error() (loom.testing.GoldenHarness method) ForEach (class in loom.streaming) Fork (class in loom.streaming) ForkRoute (class in loom.streaming) Format (class in loom.etl.declarative) format (loom.etl.declarative.FromFile property) (loom.etl.declarative.TableSourceSpec property) (loom.streaming.kafka.SchemaRef attribute) from_config() (loom.core.config.Configurable class method) (loom.core.repository.sqlalchemy.SessionManager class method) (loom.core.sql.clickhouse.ClickHouseConnectionRegistry 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_yaml() (loom.core.config.ConfigContext class method) (loom.etl.runner.ETLRunner class method) (loom.streaming.bytewax.runner.StreamingRunner class method) (loom.streaming.bytewax.StreamingRunner class method) (loom.streaming.testing.StreamingTestRunner class method) FromClickHouse (class in loom.etl.declarative) FromFile (class in loom.etl.declarative) FromMongo (class in loom.etl.declarative) FromMongoCDC (class in loom.streaming) FromMultiTypeTopic (class in loom.streaming) FromTable (class in loom.etl.declarative) FromTemp (class in loom.etl.declarative) FromTopic (class in loom.streaming) FsspecTempCleaner (class in loom.etl.checkpoint)

G

GenerationalDependencyResolver (class in loom.core.cache) (class in loom.core.cache.dependency) get() (loom.etl.checkpoint.CheckpointStore method) get_by() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (loom.core.repository.abc.Readable method) (loom.core.repository.abc.RepositoryRead method) get_by_id() (loom.core.cache.CachedRepository method) (loom.core.cache.repository.CachedRepository method) (loom.core.repository.abc.Readable method) (loom.core.repository.abc.RepositoryRead method) (loom.testing.InMemoryRepository method) get_calculated_fields() (in module loom.core.command) get_column_fields() (in module loom.core.model) get_command_fields() (in module loom.core.command) get_id_attribute() (in module loom.core.model) get_input_fields() (in module loom.core.command)

get_internal_fields() (in module loom.core.command) get_patch_fields() (in module loom.core.command) get_plan() (loom.core.engine.UseCaseCompiler method) get_projections() (in module loom.core.model) get_relations() (in module loom.core.model) get_table_name() (in module loom.core.model) get_value() (loom.core.cache.CacheBackend method) (loom.core.cache.CacheGateway method) (loom.core.cache.gateway.CacheGateway method) GoldenHarness (class in loom.testing) grants() (loom.ai.abc.AgentHandle method) (loom.ai.runtime.AgentRuntime method) (loom.testing.AgentHandleDouble method) group_id (loom.streaming.kafka.ConsumerSettings attribute) GT (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) GTE (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute)

H

has() (loom.core.config.ConfigContext method) has_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_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_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) 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) 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) 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) 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_retriable() (in module loom.ai.errors) 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)

J

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.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.streaming.Fork property)

L

leeway_seconds (loom.rest.auth.JwtAuthConfig attribute) library (loom.ai.compiler.CompiledSkillsCapability 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_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.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.model module

loom.core.repository.abc module loom.core.repository.abc.query module loom.core.repository.sqlalchemy 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.declarative module loom.etl.lineage module loom.etl.pipeline module loom.etl.runner module loom.etl.runtime module loom.etl.schema module loom.etl.storage module loom.etl.testing module loom.etl.testing.spark module loom.rest.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) LoomDtype (class in loom.etl.schema) LoomError LoomFrozenStruct (class in loom.core.model) LoomStruct (class in loom.core.model) LoomStructMeta (class in loom.core.model) LT (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute) LTE (loom.core.repository.abc.FilterOp attribute) (loom.core.repository.abc.query.FilterOp attribute)

M

main() (in module loom.ai.validate) main_repo (loom.core.use_case.UseCase property) MaintenanceConfig (class in loom.etl.storage) MaintenanceVacuumConfig (class in loom.etl.storage) MappingFileLocator (class in loom.etl.storage) MappingLocator (class in loom.etl.storage) matches() (loom.streaming.Predicate method) max_age (loom.rest.cors.CorsConfig attribute) max_agent_depth (loom.ai.config.AiConfig attribute) max_agent_depth_invalid() (in module loom.ai.errors) max_concurrent_runs (loom.ai.config.AiConfig attribute) 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) 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.streaming.kafka.ContentType attribute) merge_resolvers() (in module loom.core.config) Message (class in loom.streaming) message (loom.ai.abc.ErrorEvent 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) 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.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.model loom.core.repository.abc loom.core.repository.abc.query loom.core.repository.sqlalchemy 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.declarative loom.etl.lineage loom.etl.pipeline loom.etl.runner loom.etl.runtime loom.etl.schema loom.etl.storage loom.etl.testing loom.etl.testing.spark loom.rest.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) 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.config.ConfigResolver property) (loom.core.config.SecretsManagerResolver property) (loom.core.config.SsmResolver property) (loom.core.sql.abc.SqlColumn attribute) (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_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) 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) 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

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) 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) 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.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_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_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)

P

page (loom.core.repository.abc.PageParams attribute) (loom.core.repository.abc.PageResult attribute) (loom.core.repository.abc.query.PageParams attribute) (loom.core.repository.abc.query.PageResult attribute) PageParams (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) PageResult (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) pagination_mode (loom.rest.model.RestInterface attribute) PaginationMode (class in loom.core.repository.abc) (class in loom.core.repository.abc.query) ParamBinding (class in loom.core.engine) ParamExpr (class in loom.etl.pipeline) 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.command.CommandAdapter method) parse_json() (loom.etl.declarative.FromFile method) (loom.etl.declarative.FromTable method) partition (loom.streaming.kafka.KafkaRecord attribute) partition_key() (loom.streaming.PartitionStrategy method) PartitionGuarantee (class in loom.streaming) PartitionKeyResolver (class in loom.streaming.kafka) PartitionPolicy (class in loom.streaming) PartitionStrategy (class in loom.streaming) password (loom.core.sql.config.SqlConnectionConfig attribute) path (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) pipeline_statuses (loom.etl.testing.StubRunObserver property) plan (loom.testing.UseCaseTest property) PolarsFileWriter (class in loom.etl.backends.polars) PolarsPhysicalSchema (class in loom.etl.backends.polars) PolarsSourceReader (class in loom.etl.backends.polars) PolarsStepRunner (class in loom.etl.testing) PolarsTargetWriter (class in loom.etl.backends.polars) 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) 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) private_key_path (loom.rest.auth.JwtIssuerConfig attribute) private_key_ref (loom.rest.auth.JwtIssuerConfig attribute) Process (class in loom.streaming) process (loom.streaming.StreamFlow property) processes (loom.etl.pipeline.ETLPipeline attribute) produced_at_ms (loom.streaming.kafka.MessageMetadata attribute) producer_for() (loom.streaming.kafka.KafkaSettings method) ProducerSettings (class in loom.streaming.kafka) profile_default (loom.rest.model.RestInterface attribute) project() (loom.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) protocol (loom.streaming.kafka.KafkaSecuritySettings attribute) provider (loom.ai.inference.InferenceTarget 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) 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

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_sink() (loom.streaming.bytewax.runner.StreamingRunner method) (loom.streaming.bytewax.StreamingRunner method) 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) 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_attribute() (loom.core.identity.Identity method) require_provider_sdk() (in module loom.ai.registry) require_provider_setting() (in module loom.ai.registry) 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.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) rewind_to() (loom.etl.backends._historify.HistorifyBackend method) RoleNotAllowedError RoleRequiredError roles (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) RolesNotBoundError 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) 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.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_error_class() (in module loom.ai.errors) 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.etl.runtime.TableDiscovery method) (loom.etl.testing.StubCatalog method) schema_ref (loom.streaming.kafka.MessageDescriptor attribute) SchemaError SchemaMode (class in loom.etl.declarative) SchemaNotFoundError SchemaRef (class in loom.streaming.kafka) scope (loom.etl.declarative.IntoTemp property) 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) 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.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) 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_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) StepContext (class in loom.streaming) StepResult (class in loom.etl.testing) StepRunnerProto (class in loom.etl.testing) steps (loom.etl.pipeline.ETLProcess attribute) StepSQL (class in loom.etl.pipeline) StorageConfig (class in loom.etl.storage) StorageDefaults (class in loom.etl.storage) StorageEngine (class in loom.etl.storage) StorageProfile (class in loom.etl.storage) stream_sse() (in module loom.ai.fastapi) StreamFlow (class in loom.streaming) streaming_flags (loom.etl.testing.StubTargetWriter attribute) 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.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) SystemError

T

table (loom.etl.declarative.ClickHouseSourceSpec property) table_ref (loom.etl.declarative.FromClickHouse property) (loom.etl.declarative.FromTable property) TableDiscovery (class in loom.etl.runtime) TableLocation (class in loom.etl.storage) TableLocator (class in loom.etl.storage) TablePathConfig (class in loom.etl.storage) TableRef (class in loom.etl.schema) TableRoute (class in loom.etl.storage) TableRouteResolver (class in loom.etl.storage) TableSourceSpec (class in loom.etl.declarative) tags (loom.rest.model.RestInterface attribute) target_spec (loom.etl.testing.PolarsStepRunner property) (loom.etl.testing.spark.SparkStepRunner property) TargetWriter (class in loom.etl.runtime) temp_name (loom.etl.declarative.FromTemp property) (loom.etl.declarative.IntoTemp property) TempCleaner (class in loom.etl.checkpoint) 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_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.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) UnknownConnectionError 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_schema() (loom.etl.runtime.TableDiscovery method) (loom.etl.testing.StubCatalog method) updated_at (loom.core.model.TimestampedModel attribute) upsert() (loom.etl.declarative.IntoTable 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

validate() (loom.core.config.OtelConfig method) (loom.etl.lineage.LineageConfig method) (loom.etl.storage.FilePathConfig method) (loom.etl.storage.FileRoute method) (loom.etl.storage.StorageConfig method) (loom.etl.storage.TablePathConfig method) (loom.etl.storage.TableRoute method)

validate_patterns() (in module loom.ai.validate) value (loom.streaming.kafka.KafkaRecord attribute) verification_key() (loom.rest.auth.JwtAuthConfig method) version (loom.streaming.kafka.SchemaRef attribute)

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_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) 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)