• Home
• Index

Index

_

__aenter__() (airflow.providers.common.ai.toolsets.mcp.MCPToolset method) (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset method) __aexit__() (airflow.providers.common.ai.toolsets.mcp.MCPToolset method) (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset method)

__doc__ (airflow.providers.common.ai.policies.retry.ClassifierRetryPolicy attribute) (airflow.providers.common.ai.policies.retry.LLMRetryPolicy attribute) __post_init__() (airflow.providers.common.ai.policies.decision.BranchOption method) (airflow.providers.common.ai.policies.decision.DecisionPolicy method) (airflow.providers.common.ai.policies.retry.ErrorCategory method) __version__ (in module airflow.providers.common.ai)

A

ABSOLUTE_STATE_PATH (in module tests.system.common.ai.example_sandbox_toolset_modal) AbstractToolset (in module airflow.providers.common.ai.toolsets.skills) ACT_ABOVE (in module airflow.providers.common.ai.example_dags.example_classifier_model) action (airflow.providers.common.ai.utils.hitl_review.HumanActionData attribute) adapter (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger attribute) affected_segments (airflow.providers.common.ai.example_dags.example_sandbox_toolset.Findings attribute) agent_params (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) agent_ref (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset property) (airflow.providers.common.ai.toolsets.managed_agent.FailoverManagedAgentToolset property) AGENT_SYSTEM_PROMPT (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) agent_task() (in module airflow.providers.common.ai.decorators.agent) agent_template_fields (airflow.providers.common.ai.toolsets.hook.HookToolset attribute) (airflow.providers.common.ai.toolsets.mcp.MCPToolset attribute) (airflow.providers.common.ai.toolsets.sql.SQLToolset attribute) AgentOperator (class in airflow.providers.common.ai.operators.agent) AgentSessionData (class in airflow.providers.common.ai.utils.hitl_review) AgentSkillsToolset (class in airflow.providers.common.ai.toolsets.skills) aip_number (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) AIP_REGISTRY (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) AIPStatus (class in airflow.providers.common.ai.example_dags.example_aip_progress_tracker) airflow.providers.common.ai module airflow.providers.common.ai.batch module airflow.providers.common.ai.batch.anthropic module airflow.providers.common.ai.batch.base module airflow.providers.common.ai.batch.dispatch module airflow.providers.common.ai.batch.openai module airflow.providers.common.ai.batch.output_schema module airflow.providers.common.ai.batch.polling module airflow.providers.common.ai.batch.results module airflow.providers.common.ai.batch.state module airflow.providers.common.ai.decorators module airflow.providers.common.ai.decorators.agent module airflow.providers.common.ai.decorators.llm module airflow.providers.common.ai.decorators.llm_batch module airflow.providers.common.ai.decorators.llm_branch module airflow.providers.common.ai.decorators.llm_file_analysis module airflow.providers.common.ai.decorators.llm_schema_compare module airflow.providers.common.ai.decorators.llm_sql module airflow.providers.common.ai.durable module airflow.providers.common.ai.durable.base module airflow.providers.common.ai.durable.caching_model module airflow.providers.common.ai.durable.caching_toolset module airflow.providers.common.ai.durable.fingerprint module airflow.providers.common.ai.durable.step_counter module airflow.providers.common.ai.durable.storage module airflow.providers.common.ai.durable.task_state_store module airflow.providers.common.ai.example_dags module airflow.providers.common.ai.example_dags.example_agent module airflow.providers.common.ai.example_dags.example_agent_capabilities module airflow.providers.common.ai.example_dags.example_agent_durable module airflow.providers.common.ai.example_dags.example_agent_skills module airflow.providers.common.ai.example_dags.example_aip_progress_tracker module airflow.providers.common.ai.example_dags.example_classifier_model module airflow.providers.common.ai.example_dags.example_document_loader module airflow.providers.common.ai.example_dags.example_langchain_10k module airflow.providers.common.ai.example_dags.example_langchain_hook module airflow.providers.common.ai.example_dags.example_langchain_tool_agent module airflow.providers.common.ai.example_dags.example_langchain_toolset_bridge module airflow.providers.common.ai.example_dags.example_llamaindex_10k module airflow.providers.common.ai.example_dags.example_llamaindex_hook module airflow.providers.common.ai.example_dags.example_llamaindex_rag module airflow.providers.common.ai.example_dags.example_llm module airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline module airflow.providers.common.ai.example_dags.example_llm_batch module airflow.providers.common.ai.example_dags.example_llm_branch module airflow.providers.common.ai.example_dags.example_llm_classification module airflow.providers.common.ai.example_dags.example_llm_fallback module airflow.providers.common.ai.example_dags.example_llm_file_analysis module airflow.providers.common.ai.example_dags.example_llm_retry_policy module airflow.providers.common.ai.example_dags.example_llm_schema_compare module airflow.providers.common.ai.example_dags.example_llm_sql module airflow.providers.common.ai.example_dags.example_llm_survey_agentic module airflow.providers.common.ai.example_dags.example_llm_survey_analysis module airflow.providers.common.ai.example_dags.example_mcp module airflow.providers.common.ai.example_dags.example_pydantic_ai_hook module airflow.providers.common.ai.example_dags.example_quickstart module airflow.providers.common.ai.example_dags.example_sandbox_toolset module airflow.providers.common.ai.exceptions module airflow.providers.common.ai.get_provider_info module airflow.providers.common.ai.hooks module

airflow.providers.common.ai.hooks.langchain module airflow.providers.common.ai.hooks.llamaindex module airflow.providers.common.ai.hooks.mcp module airflow.providers.common.ai.hooks.pydantic_ai module airflow.providers.common.ai.mixins module airflow.providers.common.ai.mixins.approval module airflow.providers.common.ai.mixins.cancellable_run module airflow.providers.common.ai.mixins.hitl_review module airflow.providers.common.ai.observability module airflow.providers.common.ai.operators module airflow.providers.common.ai.operators.agent module airflow.providers.common.ai.operators.document_loader module airflow.providers.common.ai.operators.llamaindex_embedding module airflow.providers.common.ai.operators.llamaindex_retrieval module airflow.providers.common.ai.operators.llm module airflow.providers.common.ai.operators.llm_batch module airflow.providers.common.ai.operators.llm_branch module airflow.providers.common.ai.operators.llm_file_analysis module airflow.providers.common.ai.operators.llm_schema_compare module airflow.providers.common.ai.operators.llm_sql module airflow.providers.common.ai.plugins module airflow.providers.common.ai.plugins.hitl_review module airflow.providers.common.ai.policies module airflow.providers.common.ai.policies.decision module airflow.providers.common.ai.policies.retry module airflow.providers.common.ai.sandbox module airflow.providers.common.ai.sandbox.base module airflow.providers.common.ai.sandbox.modal module airflow.providers.common.ai.sandbox.output module airflow.providers.common.ai.sandbox.sbx module airflow.providers.common.ai.skills module airflow.providers.common.ai.toolsets module airflow.providers.common.ai.toolsets.datafusion module airflow.providers.common.ai.toolsets.hook module airflow.providers.common.ai.toolsets.langchain_bridge module airflow.providers.common.ai.toolsets.logging module airflow.providers.common.ai.toolsets.managed_agent module airflow.providers.common.ai.toolsets.mcp module airflow.providers.common.ai.toolsets.sandbox module airflow.providers.common.ai.toolsets.skills module airflow.providers.common.ai.toolsets.sql module airflow.providers.common.ai.triggers module airflow.providers.common.ai.triggers.llm_batch module airflow.providers.common.ai.utils module airflow.providers.common.ai.utils.dataquality module airflow.providers.common.ai.utils.decision module airflow.providers.common.ai.utils.file_analysis module airflow.providers.common.ai.utils.hitl_review module airflow.providers.common.ai.utils.logging module airflow.providers.common.ai.utils.output_type module airflow.providers.common.ai.utils.query_results module airflow.providers.common.ai.utils.sql_validation module airflow.providers.common.ai.utils.tool_definition module airflow.providers.common.ai.utils.toolsets module airflow.providers.common.ai.utils.usage module airflow.providers.common.ai.utils.validation module airflow_toolset_to_langchain_tools() (in module airflow.providers.common.ai.toolsets.langchain_bridge) AIRFLOW_WEBSITE_CONN_ID (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) allow_egress_to (airflow.providers.common.ai.sandbox.base.SandboxSpec attribute) allow_egress_to_cidrs (airflow.providers.common.ai.sandbox.base.SandboxSpec attribute) allow_modifications (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) allow_multiple_branches (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator attribute) allowed_sql_types (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) allows_per_request_model (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter attribute) (airflow.providers.common.ai.batch.base.BatchAdapter attribute) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter attribute) Analysis (class in airflow.providers.common.ai.example_dags.example_agent) ANALYSIS_IMAGE (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) ANALYSIS_SYSTEM_PROMPT (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) AnalysisReport (class in airflow.providers.common.ai.example_dags.example_langchain_10k) (class in airflow.providers.common.ai.example_dags.example_llamaindex_10k) AnthropicBatchAdapter (class in airflow.providers.common.ai.batch.anthropic) applied_timeout (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) approval_assigned_users (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) approval_notifiers (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) approval_timeout (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) APPROVE (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin attribute) APPROVED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) assemble_manifest() (in module airflow.providers.common.ai.batch.results) attachment_count (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute)

B

BARE_OUTPUT_FIELD (in module airflow.providers.common.ai.utils.decision) BaseManagedAgentToolset (class in airflow.providers.common.ai.toolsets.managed_agent) batch_id (airflow.providers.common.ai.batch.base.SubmitResult attribute) (airflow.providers.common.ai.batch.polling.BatchPoller attribute) (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger attribute) BatchAdapter (class in airflow.providers.common.ai.batch.base) BatchPoller (class in airflow.providers.common.ai.batch.polling) BatchProviderNotYetSupportedError BatchRequest (class in airflow.providers.common.ai.batch.base) BatchState (class in airflow.providers.common.ai.batch.base) BatchStateRecord (class in airflow.providers.common.ai.batch.state) BatchStatus (in module airflow.providers.common.ai.batch.base) block_network (airflow.providers.common.ai.sandbox.base.SandboxSpec attribute)

branch (airflow.providers.common.ai.skills.GitSkills attribute) branches (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator attribute) BranchOption (class in airflow.providers.common.ai.policies.decision) build_adapter() (in module airflow.providers.common.ai.batch.dispatch) build_adapter_from_connection() (in module airflow.providers.common.ai.batch.dispatch) build_args_validator() (in module airflow.providers.common.ai.utils.tool_definition) build_file_analysis_request() (in module airflow.providers.common.ai.utils.file_analysis) build_output_directive() (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter method) (airflow.providers.common.ai.batch.base.BatchAdapter method) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter method) build_output_spec() (in module airflow.providers.common.ai.batch.output_schema) build_query_result() (in module airflow.providers.common.ai.utils.query_results) build_result_row() (in module airflow.providers.common.ai.batch.results) build_run_identity_attributes() (in module airflow.providers.common.ai.observability) bz2 (in module airflow.providers.common.ai.utils.file_analysis)

C

cached_model (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) cached_tool (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) CachingModel (class in airflow.providers.common.ai.durable.caching_model) CachingToolset (class in airflow.providers.common.ai.durable.caching_toolset) call_tool() (airflow.providers.common.ai.durable.caching_toolset.CachingToolset method) (airflow.providers.common.ai.toolsets.datafusion.DataFusionToolset method) (airflow.providers.common.ai.toolsets.hook.HookToolset method) (airflow.providers.common.ai.toolsets.logging.LoggingToolset method) (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset method) (airflow.providers.common.ai.toolsets.mcp.MCPToolset method) (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset method) (airflow.providers.common.ai.toolsets.sql.SQLToolset method) cancel (airflow.providers.common.ai.batch.polling.PollOutcome attribute) cancel_batch() (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter method) (airflow.providers.common.ai.batch.base.BatchAdapter method) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter method) cancel_on_kill (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger attribute) cancel_on_timeout (airflow.providers.common.ai.batch.polling.BatchPoller attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger attribute) CancellableAgentRunMixin (class in airflow.providers.common.ai.mixins.cancellable_run) categories (airflow.providers.common.ai.policies.retry.ClassifierRetryPolicy attribute) category (airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline.TicketAnalysis attribute) (airflow.providers.common.ai.policies.retry.ErrorClassification attribute) CHANGES_REQUESTED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) check_bar() (in module airflow.providers.common.ai.policies.decision) check_custom_id_length() (airflow.providers.common.ai.batch.base.BatchAdapter method) check_uncertain_action() (in module airflow.providers.common.ai.utils.decision) chunk_overlap (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) chunk_size (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) claim (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ClaimValidation attribute) ClaimValidation (class in airflow.providers.common.ai.example_dags.example_aip_progress_tracker) CLASSIFIER_INSTRUCTIONS (in module airflow.providers.common.ai.policies.retry) ClassifierRetryPolicy (class in airflow.providers.common.ai.policies.retry) cleanup() (airflow.providers.common.ai.durable.base.DurableStorageProtocol method) (airflow.providers.common.ai.durable.storage.DurableStorage method) (airflow.providers.common.ai.durable.task_state_store.TaskStateStoreDurableStorage method) close() (airflow.providers.common.ai.batch.base.BatchAdapter method) code_arg_kwargs() (in module airflow.providers.common.ai.utils.tool_definition) code_mode (airflow.providers.common.ai.operators.agent.AgentOperator attribute) coerce_usage_limits() (in module airflow.providers.common.ai.utils.usage) collect_table_references() (in module airflow.providers.common.ai.utils.sql_validation) column (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute)

ColumnMapping (class in airflow.providers.common.ai.example_dags.example_sandbox_toolset) company_findings (airflow.providers.common.ai.example_dags.example_langchain_10k.AnalysisReport attribute) (airflow.providers.common.ai.example_dags.example_llamaindex_10k.AnalysisReport attribute) compatible (airflow.providers.common.ai.operators.llm_schema_compare.SchemaCompareResult attribute) completion_window (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) compute_fingerprint() (in module airflow.providers.common.ai.batch.state) compute_identity_key() (in module airflow.providers.common.ai.batch.state) compute_output_schema_digest() (in module airflow.providers.common.ai.batch.state) confidence (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.DeliverableStatus attribute) (airflow.providers.common.ai.example_dags.example_llm_batch.Sentiment attribute) (airflow.providers.common.ai.example_dags.example_sandbox_toolset.Findings attribute) (airflow.providers.common.ai.utils.decision.ModelConfidence attribute) CONFLUENCE_BASE_URL (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) confluence_update_needed (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) conn_id (airflow.providers.common.ai.skills.GitSkills attribute) (airflow.providers.common.ai.toolsets.hook.HookToolset property) conn_name_attr (airflow.providers.common.ai.hooks.langchain.LangChainHook attribute) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook attribute) (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) conn_type (airflow.providers.common.ai.hooks.langchain.LangChainHook attribute) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook attribute) (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIAzureHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIBedrockHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIVertexHook attribute) conn_types (airflow.providers.common.ai.batch.base.BatchAdapter attribute) consecutive_failures (airflow.providers.common.ai.batch.polling.BatchPoller attribute) content (airflow.providers.common.ai.utils.hitl_review.ConversationEntry attribute) context_strategy (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) conversation (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) ConversationEntry (class in airflow.providers.common.ai.utils.hitl_review) CONVERT_SCRIPT (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) correction (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ClaimValidation attribute) counter (airflow.providers.common.ai.durable.caching_model.CachingModel attribute) (airflow.providers.common.ai.durable.caching_toolset.CachingToolset attribute) counts (airflow.providers.common.ai.batch.base.BatchState attribute) create() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.sbx.SbxSandboxBackend method) create_agent() (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook method) current_output (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) custom_id (airflow.providers.common.ai.batch.base.RawResultItem attribute)

D

dag (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_sbx) dag_id (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) DAG_ID (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_sbx) data_sources (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) DataFusionToolset (class in airflow.providers.common.ai.toolsets.datafusion) datasource_config (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) db_conn_id (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) DB_CONN_ID (in module airflow.providers.common.ai.example_dags.example_langchain_toolset_bridge) db_conn_ids (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) db_hook (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator property) deadline_iso (airflow.providers.common.ai.batch.polling.BatchPoller property) DecidedBy (in module airflow.providers.common.ai.utils.decision) decision_policy (airflow.providers.common.ai.operators.llm.LLMOperator attribute) decision_record() (in module airflow.providers.common.ai.utils.decision) DECISION_XCOM_KEY (in module airflow.providers.common.ai.utils.decision) DecisionPolicy (class in airflow.providers.common.ai.policies.decision) DECOMPOSE_SYSTEM_PROMPT (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) DecomposedQuestion (class in airflow.providers.common.ai.example_dags.example_langchain_10k) (class in airflow.providers.common.ai.example_dags.example_llamaindex_10k) DEFAULT_AIP_NUMBERS (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) DEFAULT_ALLOWED_TYPES (in module airflow.providers.common.ai.utils.sql_validation) DEFAULT_APP_NAME (in module airflow.providers.common.ai.sandbox.modal) DEFAULT_CATEGORIES (in module airflow.providers.common.ai.policies.retry) default_conn_name (airflow.providers.common.ai.hooks.langchain.LangChainHook attribute) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook attribute) (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIAzureHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIBedrockHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIVertexHook attribute) DEFAULT_IDLE_TIMEOUT (in module airflow.providers.common.ai.sandbox.modal) DEFAULT_IMAGE (in module airflow.providers.common.ai.sandbox.modal) DEFAULT_INSTRUCTIONS (in module airflow.providers.common.ai.policies.retry) DEFAULT_MAX_RESULT_BYTES (in module airflow.providers.common.ai.utils.query_results) DEFAULT_QUESTION (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) (in module airflow.providers.common.ai.example_dags.example_langchain_toolset_bridge) (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k)

DEFAULT_SANDBOX_TIMEOUT (in module airflow.providers.common.ai.sandbox.modal) DEFAULT_SYSTEM_PROMPT (in module airflow.providers.common.ai.operators.llm_schema_compare) DEFAULT_TICKERS (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) DEFAULT_WORKDIR (in module airflow.providers.common.ai.sandbox.modal) defer (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol attribute) defer_for_approval() (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin method) DeferForApprovalProtocol (class in airflow.providers.common.ai.mixins.approval) deferrable (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) delay (airflow.providers.common.ai.policies.retry.ErrorCategory attribute) delete_state() (in module airflow.providers.common.ai.batch.state) deliverables (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) DeliverableStatus (class in airflow.providers.common.ai.example_dags.example_aip_progress_tracker) describe_confidence() (in module airflow.providers.common.ai.utils.decision) described_choices() (in module airflow.providers.common.ai.utils.decision) description (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) (airflow.providers.common.ai.policies.decision.BranchOption attribute) (airflow.providers.common.ai.policies.retry.ErrorCategory attribute) deserialization_allowed_class_fields (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) destroy() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.sbx.SbxSandboxBackend method) detect_file_format() (in module airflow.providers.common.ai.utils.file_analysis) dialect (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) DIMENSION_KEYS (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) DOCS_PATH (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) DocumentLoaderOperator (class in airflow.providers.common.ai.operators.document_loader) documents (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) duplicate_result_count (airflow.providers.common.ai.batch.results.MergeDiagnostics attribute) durable (airflow.providers.common.ai.operators.agent.AgentOperator attribute) DURABLE_KEY_PREFIX (in module airflow.providers.common.ai.durable.base) DurableStepCounter (class in airflow.providers.common.ai.durable.step_counter) DurableStorage (class in airflow.providers.common.ai.durable.storage) DurableStorageProtocol (class in airflow.providers.common.ai.durable.base)

E

EDGAR_USER_AGENT (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) EgressEnforcement (in module airflow.providers.common.ai.sandbox.modal) embed_conn_id (airflow.providers.common.ai.hooks.langchain.LangChainHook attribute) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook attribute) (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator attribute) embed_model (airflow.providers.common.ai.hooks.langchain.LangChainHook attribute) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook attribute) (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator attribute) EMBEDDING_MODEL (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) enable_hitl_review (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) enable_tool_logging (airflow.providers.common.ai.operators.agent.AgentOperator attribute) encoding (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) encoding_errors (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) end_time (airflow.providers.common.ai.batch.polling.BatchPoller attribute) (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger attribute) Entities (class in airflow.providers.common.ai.example_dags.example_llm) ENTRY_POINT_GROUP (in module airflow.providers.common.ai.batch.dispatch) env (airflow.providers.common.ai.sandbox.base.SandboxSpec attribute) ENV_ID (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_sbx) env_provider (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) error (airflow.providers.common.ai.batch.base.RawResultItem attribute) error_message (airflow.providers.common.ai.batch.base.BatchState attribute) (airflow.providers.common.ai.batch.output_schema.ValidationOutcome attribute) ErrorCategory (class in airflow.providers.common.ai.policies.retry) ErrorClassification (class in airflow.providers.common.ai.policies.retry) evaluate() (airflow.providers.common.ai.policies.retry.ClassifierRetryPolicy method) (airflow.providers.common.ai.policies.retry.LLMRetryPolicy method) evaluate_batch_counts() (in module airflow.providers.common.ai.batch.base) event (airflow.providers.common.ai.batch.polling.PollOutcome attribute) evidence (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.DeliverableStatus attribute) evidence_found (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ClaimValidation attribute) example_agent_capabilities_composed() (in module airflow.providers.common.ai.example_dags.example_agent_capabilities) example_agent_capabilities_input_guard() (in module airflow.providers.common.ai.example_dags.example_agent_capabilities) example_agent_capabilities_thinking() (in module airflow.providers.common.ai.example_dags.example_agent_capabilities) example_agent_capabilities_web_search() (in module airflow.providers.common.ai.example_dags.example_agent_capabilities) example_agent_chain() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_decorator() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_durable_decorator() (in module airflow.providers.common.ai.example_dags.example_agent_durable) example_agent_durable_operator() (in module airflow.providers.common.ai.example_dags.example_agent_durable) example_agent_dynamic_system_prompt() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_operator_code_mode() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_operator_hitl_review() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_operator_hook() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_operator_sql() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_self_hosted() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_session() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_skills_git() (in module airflow.providers.common.ai.example_dags.example_agent_skills) example_agent_skills_local() (in module airflow.providers.common.ai.example_dags.example_agent_skills) example_agent_structured_output() (in module airflow.providers.common.ai.example_dags.example_agent) example_aip_progress_tracker() (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) example_aip_progress_tracker_skills() (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) example_classifier_model_branch() (in module airflow.providers.common.ai.example_dags.example_classifier_model) example_classifier_model_confidence() (in module airflow.providers.common.ai.example_dags.example_classifier_model) example_document_loader_basic() (in module airflow.providers.common.ai.example_dags.example_document_loader) example_document_loader_bytes() (in module airflow.providers.common.ai.example_dags.example_document_loader) example_document_loader_cloud_uri() (in module airflow.providers.common.ai.example_dags.example_document_loader) example_document_loader_directory() (in module airflow.providers.common.ai.example_dags.example_document_loader) example_document_loader_json_field() (in module airflow.providers.common.ai.example_dags.example_document_loader) example_langchain_10k_analysis() (in module airflow.providers.common.ai.example_dags.example_langchain_10k) example_langchain_10k_index() (in module airflow.providers.common.ai.example_dags.example_langchain_10k) example_langchain_chat() (in module airflow.providers.common.ai.example_dags.example_langchain_hook) example_langchain_chat_and_embedding() (in module airflow.providers.common.ai.example_dags.example_langchain_hook) example_langchain_different_conns() (in module airflow.providers.common.ai.example_dags.example_langchain_hook) example_langchain_embedding() (in module airflow.providers.common.ai.example_dags.example_langchain_hook) example_langchain_tool_agent() (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) example_langchain_toolset_bridge() (in module airflow.providers.common.ai.example_dags.example_langchain_toolset_bridge) example_llamaindex_10k_analysis() (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) example_llamaindex_10k_index() (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) example_llamaindex_byo_embed_model() (in module airflow.providers.common.ai.example_dags.example_llamaindex_hook) example_llamaindex_cloud_persist() (in module airflow.providers.common.ai.example_dags.example_llamaindex_hook) example_llamaindex_embed() (in module airflow.providers.common.ai.example_dags.example_llamaindex_hook) example_llamaindex_index_pdf() (in module airflow.providers.common.ai.example_dags.example_llamaindex_rag)

example_llamaindex_multi_source() (in module airflow.providers.common.ai.example_dags.example_llamaindex_rag) example_llamaindex_query() (in module airflow.providers.common.ai.example_dags.example_llamaindex_rag) example_llamaindex_rag_pipeline() (in module airflow.providers.common.ai.example_dags.example_llamaindex_rag) example_llamaindex_retrieve() (in module airflow.providers.common.ai.example_dags.example_llamaindex_hook) example_llm_analysis_pipeline() (in module airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline) example_llm_batch_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_batch) example_llm_batch_operator() (in module airflow.providers.common.ai.example_dags.example_llm_batch) example_llm_batch_per_request_overrides() (in module airflow.providers.common.ai.example_dags.example_llm_batch) example_llm_batch_provider_params() (in module airflow.providers.common.ai.example_dags.example_llm_batch) example_llm_branch_approval() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_decision_policy() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_decorator_multi() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_descriptions() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_multi() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_operator() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_classification() (in module airflow.providers.common.ai.example_dags.example_llm_classification) example_llm_decorator() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_decorator_structured() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_fallback() (in module airflow.providers.common.ai.example_dags.example_llm_fallback) example_llm_fallback_explicit_chain() (in module airflow.providers.common.ai.example_dags.example_llm_fallback) example_llm_fallback_operator_argument() (in module airflow.providers.common.ai.example_dags.example_llm_fallback) example_llm_file_analysis_approval() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_basic() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_multimodal() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_prefix() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_structured() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_operator() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_agent_params() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_approval() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_structured() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_templated_usage_limits() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_usage_limits() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_schema_compare_approval() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_basic() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_basic_context() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_conditional() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_with_object_storage() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_sql_basic() (in module airflow.providers.common.ai.example_dags.example_llm_sql) example_llm_survey_agentic() (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) example_llm_survey_interactive() (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) example_mcp_multiple_servers() (in module airflow.providers.common.ai.example_dags.example_mcp) example_mcp_stdio_env_provider() (in module airflow.providers.common.ai.example_dags.example_mcp) example_mcp_toolset() (in module airflow.providers.common.ai.example_dags.example_mcp) example_pydantic_ai_hook() (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_hook) example_pydantic_ai_spec_file() (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_hook) example_pydantic_ai_structured_output() (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_hook) example_sandbox_agent_local() (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) example_sandbox_task_artifact() (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) example_sandbox_toolset_modal() (in module tests.system.common.ai.example_sandbox_toolset_modal) example_sandbox_toolset_sbx() (in module tests.system.common.ai.example_sandbox_toolset_sbx) example_task_with_toolsets() (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_hook) execute() (airflow.providers.common.ai.operators.agent.AgentOperator method) (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator method) (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator method) (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator method) (airflow.providers.common.ai.operators.llm.LLMOperator method) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator method) (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator method) (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator method) (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator method) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator method) execute_complete() (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin method) (airflow.providers.common.ai.operators.llm.LLMOperator method) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator method) (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator method) (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator method) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator method) executive_summary (airflow.providers.common.ai.example_dags.example_langchain_10k.AnalysisReport attribute) (airflow.providers.common.ai.example_dags.example_llamaindex_10k.AnalysisReport attribute) exit_code (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) EXTENSION_BACKEND_MAP (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) extract_output() (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter method) (airflow.providers.common.ai.batch.base.BatchAdapter method) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter method) ExtractedOutput (class in airflow.providers.common.ai.batch.base)

F

fail_on_partial_error (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) fail_on_reject (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator attribute) FailoverManagedAgentToolset (class in airflow.providers.common.ai.toolsets.managed_agent) fallback_conn_ids (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) FALLBACK_CONN_IDS_EXTRA_KEY (in module airflow.providers.common.ai.hooks.pydantic_ai) fallback_policy (airflow.providers.common.ai.policies.retry.ClassifierRetryPolicy attribute) fastapi_apps (airflow.providers.common.ai.plugins.hitl_review.HITLReviewPlugin attribute) feedback (airflow.providers.common.ai.utils.hitl_review.HumanActionData attribute) (airflow.providers.common.ai.utils.hitl_review.HumanFeedbackRequest attribute) fetch_confluence_page() (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) file_conn_id (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) file_extensions (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) file_path (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) file_type (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) FileAnalysisRequest (class in airflow.providers.common.ai.utils.file_analysis) FileAnalysisSummary (class in airflow.providers.common.ai.example_dags.example_llm_file_analysis)

FilePathT (in module airflow.providers.common.ai.operators.document_loader) finalize_record() (in module airflow.providers.common.ai.utils.decision) find_orphaned_batch() (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter method) (airflow.providers.common.ai.batch.base.BatchAdapter method) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter method) find_toolset() (in module airflow.providers.common.ai.utils.toolsets) findings (airflow.providers.common.ai.example_dags.example_llm_file_analysis.FileAnalysisSummary attribute) Findings (class in airflow.providers.common.ai.example_dags.example_sandbox_toolset) fingerprint_model_request() (in module airflow.providers.common.ai.durable.fingerprint) fingerprint_tool_call() (in module airflow.providers.common.ai.durable.fingerprint) finish_reason (airflow.providers.common.ai.batch.base.RawResultItem attribute) finish_timeout() (airflow.providers.common.ai.batch.polling.BatchPoller method) for_run() (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset method) format_size() (in module airflow.providers.common.ai.sandbox.output) from_dict() (airflow.providers.common.ai.batch.state.BatchStateRecord class method) from_result() (airflow.providers.common.ai.utils.decision.ModelConfidence class method) from_xcom() (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse static method)

G

gates (airflow.providers.common.ai.policies.decision.DecisionPolicy property) genai_instrumentation_settings() (in module airflow.providers.common.ai.observability) get_adapter_class() (in module airflow.providers.common.ai.batch.dispatch) get_batch() (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter method) (airflow.providers.common.ai.batch.base.BatchAdapter method) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter method) get_chat_model() (airflow.providers.common.ai.hooks.langchain.LangChainHook method) get_conn() (airflow.providers.common.ai.hooks.mcp.MCPHook method) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook method) get_embedding_model() (airflow.providers.common.ai.hooks.langchain.LangChainHook method) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook method) get_instructions() (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset method) get_link() (airflow.providers.common.ai.operators.agent.HITLReviewLink method) get_llm() (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook method) get_provider_info() (in module airflow.providers.common.ai.get_provider_info) get_repo_file_tree() (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) get_tools() (airflow.providers.common.ai.toolsets.datafusion.DataFusionToolset method) (airflow.providers.common.ai.toolsets.hook.HookToolset method) (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset method) (airflow.providers.common.ai.toolsets.mcp.MCPToolset method) (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset method) (airflow.providers.common.ai.toolsets.sql.SQLToolset method)

get_ui_field_behaviour() (airflow.providers.common.ai.hooks.langchain.LangChainHook static method) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook static method) (airflow.providers.common.ai.hooks.mcp.MCPHook static method) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIAzureHook static method) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIBedrockHook static method) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook static method) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIVertexHook static method) GITHUB_API_DELAY (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) GITHUB_REPO (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) GitSkills (class in airflow.providers.common.ai.skills) grounded (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ClaimValidation attribute)

H

hallucination_risk (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ValidationResult attribute) highest_severity (airflow.providers.common.ai.example_dags.example_llm_file_analysis.FileAnalysisSummary attribute) hitl_poll_interval (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) hitl_timeout (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) HITLMaxIterationsError HITLReviewLink (class in airflow.providers.common.ai.operators.agent) HITLReviewMixin (class in airflow.providers.common.ai.mixins.hitl_review) HITLReviewPlugin (class in airflow.providers.common.ai.plugins.hitl_review) HITLReviewProtocol (class in airflow.providers.common.ai.mixins.hitl_review) HITLReviewResponse (class in airflow.providers.common.ai.utils.hitl_review)

hook_name (airflow.providers.common.ai.hooks.langchain.LangChainHook attribute) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook attribute) (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIAzureHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIBedrockHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIVertexHook attribute) HookToolset (class in airflow.providers.common.ai.toolsets.hook) HostNetworkPolicy (in module airflow.providers.common.ai.sandbox.sbx) HumanActionData (class in airflow.providers.common.ai.utils.hitl_review) HumanActionType (in module airflow.providers.common.ai.utils.hitl_review) HumanFeedbackRequest (class in airflow.providers.common.ai.utils.hitl_review)

I

id (airflow.providers.common.ai.toolsets.datafusion.DataFusionToolset property) (airflow.providers.common.ai.toolsets.hook.HookToolset property) (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset property) (airflow.providers.common.ai.toolsets.mcp.MCPToolset property) (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset property) (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset property) (airflow.providers.common.ai.toolsets.sql.SQLToolset property) ignore_downstream_trigger_rules (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator attribute) import_adapter_class() (in module airflow.providers.common.ai.batch.dispatch) IN_PROGRESS_STATUSES (in module airflow.providers.common.ai.batch.base) index (airflow.providers.common.ai.batch.base.RawResultItem attribute) INDEX_BASE_DIR (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) index_persist_dir (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator attribute) INDEX_PERSIST_DIR (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) inherits_from_skipmixin (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator attribute)

initial_decided_by() (in module airflow.providers.common.ai.utils.decision) input_fingerprint (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) InputGuard (in module airflow.providers.common.ai.example_dags.example_agent_capabilities) intent_at (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) INTERACTIVE_PROMPT (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) invoke() (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset method) (airflow.providers.common.ai.toolsets.managed_agent.FailoverManagedAgentToolset method) invoke_sync() (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset method) is_structured (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute) iter_results() (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter method) (airflow.providers.common.ai.batch.base.BatchAdapter method) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter method) iter_toolsets() (in module airflow.providers.common.ai.utils.toolsets) iteration (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.ConversationEntry attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) (airflow.providers.common.ai.utils.hitl_review.HumanActionData attribute)

J

json_schema (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute)

json_text_field (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute)

K

key (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) key16() (in module airflow.providers.common.ai.batch.state) key_prs (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute)

key_risks (airflow.providers.common.ai.example_dags.example_langchain_10k.AnalysisReport attribute) (airflow.providers.common.ai.example_dags.example_llamaindex_10k.AnalysisReport attribute) kind (airflow.providers.common.ai.batch.base.ExtractedOutput attribute)

L

label (airflow.providers.common.ai.example_dags.example_llm_batch.Sentiment attribute) LANGCHAIN_CONN_ID (in module airflow.providers.common.ai.example_dags.example_langchain_10k) LangChainHook (class in airflow.providers.common.ai.hooks.langchain) LIST_DIRECTORY (in module airflow.providers.common.ai.toolsets.sandbox) list_directory() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) LLAMAINDEX_CONN_ID (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) LlamaIndexEmbeddingOperator (class in airflow.providers.common.ai.operators.llamaindex_embedding) LlamaIndexHook (class in airflow.providers.common.ai.hooks.llamaindex) LlamaIndexRetrievalOperator (class in airflow.providers.common.ai.operators.llamaindex_retrieval) llm_batch_task() (in module airflow.providers.common.ai.decorators.llm_batch) llm_branch_task() (in module airflow.providers.common.ai.decorators.llm_branch) llm_conn_id (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) (airflow.providers.common.ai.hooks.langchain.LangChainHook attribute) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger attribute) LLM_CONN_ID (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) (in module airflow.providers.common.ai.example_dags.example_langchain_toolset_bridge) (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) llm_file_analysis_task() (in module airflow.providers.common.ai.decorators.llm_file_analysis) llm_hook (airflow.providers.common.ai.operators.agent.AgentOperator property) (airflow.providers.common.ai.operators.llm.LLMOperator property) llm_model (airflow.providers.common.ai.hooks.langchain.LangChainHook attribute) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook attribute) LLM_MODEL (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) (in module airflow.providers.common.ai.example_dags.example_langchain_toolset_bridge) llm_policy (in module airflow.providers.common.ai.example_dags.example_llm_retry_policy) llm_schema_compare_task() (in module airflow.providers.common.ai.decorators.llm_schema_compare) llm_sql_task() (in module airflow.providers.common.ai.decorators.llm_sql) llm_task() (in module airflow.providers.common.ai.decorators.llm) LLMApprovalMixin (class in airflow.providers.common.ai.mixins.approval) LLMBatchCancelledError LLMBatchInputError LLMBatchJobError LLMBatchLimitExceededError LLMBatchModelMismatchError LLMBatchOperator (class in airflow.providers.common.ai.operators.llm_batch) LLMBatchOrphanedIntentError LLMBatchOrphanLookupError LLMBatchOutputTypeError

LLMBatchPartialFailureError LLMBatchStaleStateError LLMBatchStateReadError LLMBatchTimeoutError LLMBatchTrigger (class in airflow.providers.common.ai.triggers.llm_batch) LLMBranchOperator (class in airflow.providers.common.ai.operators.llm_branch) LLMFileAnalysisError LLMFileAnalysisLimitExceededError LLMFileAnalysisMultimodalRequiredError LLMFileAnalysisOperator (class in airflow.providers.common.ai.operators.llm_file_analysis) LLMFileAnalysisUnsupportedFormatError LLMOperator (class in airflow.providers.common.ai.operators.llm) LLMRetryPolicy (class in airflow.providers.common.ai.policies.retry) LLMSchemaCompareOperator (class in airflow.providers.common.ai.operators.llm_schema_compare) LLMSQLQueryOperator (class in airflow.providers.common.ai.operators.llm_sql) (in module airflow.providers.common.ai.example_dags.example_llm_sql) (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) load_model_response() (airflow.providers.common.ai.durable.base.DurableStorageProtocol method) (airflow.providers.common.ai.durable.storage.DurableStorage method) (airflow.providers.common.ai.durable.task_state_store.TaskStateStoreDurableStorage method) load_tool_result() (airflow.providers.common.ai.durable.base.DurableStorageProtocol method) (airflow.providers.common.ai.durable.storage.DurableStorage method) (airflow.providers.common.ai.durable.task_state_store.TaskStateStoreDurableStorage method) locations (airflow.providers.common.ai.example_dags.example_llm.Entities attribute) log (airflow.providers.common.ai.mixins.cancellable_run.CancellableAgentRunMixin attribute) (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (in module airflow.providers.common.ai.batch.anthropic) (in module airflow.providers.common.ai.batch.openai) (in module airflow.providers.common.ai.batch.results) (in module airflow.providers.common.ai.durable.caching_model) (in module airflow.providers.common.ai.durable.caching_toolset) (in module airflow.providers.common.ai.durable.fingerprint) (in module airflow.providers.common.ai.durable.storage) (in module airflow.providers.common.ai.durable.task_state_store) (in module airflow.providers.common.ai.mixins.approval) (in module airflow.providers.common.ai.mixins.hitl_review) (in module airflow.providers.common.ai.sandbox.modal) (in module airflow.providers.common.ai.sandbox.sbx) (in module airflow.providers.common.ai.toolsets.datafusion) (in module airflow.providers.common.ai.toolsets.managed_agent) (in module airflow.providers.common.ai.toolsets.sandbox) (in module airflow.providers.common.ai.utils.file_analysis) log_run_summary() (in module airflow.providers.common.ai.utils.logging) logger (airflow.providers.common.ai.toolsets.logging.LoggingToolset attribute) LoggingToolset (class in airflow.providers.common.ai.toolsets.logging) LogNotifier (class in airflow.providers.common.ai.example_dags.example_llm) LowConfidenceError lowest() (airflow.providers.common.ai.utils.decision.ModelConfidence method) lzma (in module airflow.providers.common.ai.utils.file_analysis)

M

ManagedAgentInvocationError mapped (airflow.providers.common.ai.example_dags.example_sandbox_toolset.ColumnMapping attribute) MARKER (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_sbx) max_bytes (airflow.providers.common.ai.sandbox.base.SandboxFileTooLargeError attribute) MAX_CONSECUTIVE_POLL_FAILURES (in module airflow.providers.common.ai.batch.polling) max_file_size_bytes (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) max_files (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) max_hitl_iterations (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) max_iterations (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) MAX_ITERATIONS_EXCEEDED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) max_payload_bytes (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter attribute) (airflow.providers.common.ai.batch.base.BatchAdapter attribute) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter attribute) max_requests (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter attribute) (airflow.providers.common.ai.batch.base.BatchAdapter attribute) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter attribute) max_text_chars (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) max_tokens (airflow.providers.common.ai.batch.base.BatchRequest attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) max_total_size_bytes (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) mcp_conn_id (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) MCPHook (class in airflow.providers.common.ai.hooks.mcp) MCPToolset (class in airflow.providers.common.ai.toolsets.mcp) MergeDiagnostics (class in airflow.providers.common.ai.batch.results) message (airflow.providers.common.ai.example_dags.example_llm.LogNotifier attribute) message_history (airflow.providers.common.ai.operators.agent.AgentOperator attribute) metadata_fields (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) MIB (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) migration_query (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) min_confidence (airflow.providers.common.ai.policies.decision.BranchOption attribute) (airflow.providers.common.ai.policies.decision.DecisionPolicy attribute) (airflow.providers.common.ai.policies.retry.ClassifierRetryPolicy attribute) (airflow.providers.common.ai.policies.retry.ErrorCategory attribute) mismatches (airflow.providers.common.ai.operators.llm_schema_compare.SchemaCompareResult attribute) missing_indexes() (in module airflow.providers.common.ai.batch.results) modal (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) ModalSandboxBackend (class in airflow.providers.common.ai.sandbox.modal) model (airflow.providers.common.ai.batch.base.BatchRequest attribute) (airflow.providers.common.ai.batch.base.RawResultItem attribute) (airflow.providers.common.ai.utils.decision.ModelConfidence attribute) model_id (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) model_provider (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIAzureHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIBedrockHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIVertexHook attribute) ModelConfidence (class in airflow.providers.common.ai.utils.decision) module airflow.providers.common.ai airflow.providers.common.ai.batch airflow.providers.common.ai.batch.anthropic airflow.providers.common.ai.batch.base airflow.providers.common.ai.batch.dispatch airflow.providers.common.ai.batch.openai airflow.providers.common.ai.batch.output_schema airflow.providers.common.ai.batch.polling airflow.providers.common.ai.batch.results airflow.providers.common.ai.batch.state airflow.providers.common.ai.decorators airflow.providers.common.ai.decorators.agent airflow.providers.common.ai.decorators.llm airflow.providers.common.ai.decorators.llm_batch airflow.providers.common.ai.decorators.llm_branch airflow.providers.common.ai.decorators.llm_file_analysis airflow.providers.common.ai.decorators.llm_schema_compare airflow.providers.common.ai.decorators.llm_sql airflow.providers.common.ai.durable airflow.providers.common.ai.durable.base airflow.providers.common.ai.durable.caching_model airflow.providers.common.ai.durable.caching_toolset airflow.providers.common.ai.durable.fingerprint airflow.providers.common.ai.durable.step_counter airflow.providers.common.ai.durable.storage airflow.providers.common.ai.durable.task_state_store airflow.providers.common.ai.example_dags airflow.providers.common.ai.example_dags.example_agent airflow.providers.common.ai.example_dags.example_agent_capabilities airflow.providers.common.ai.example_dags.example_agent_durable airflow.providers.common.ai.example_dags.example_agent_skills airflow.providers.common.ai.example_dags.example_aip_progress_tracker airflow.providers.common.ai.example_dags.example_classifier_model airflow.providers.common.ai.example_dags.example_document_loader airflow.providers.common.ai.example_dags.example_langchain_10k airflow.providers.common.ai.example_dags.example_langchain_hook airflow.providers.common.ai.example_dags.example_langchain_tool_agent airflow.providers.common.ai.example_dags.example_langchain_toolset_bridge airflow.providers.common.ai.example_dags.example_llamaindex_10k airflow.providers.common.ai.example_dags.example_llamaindex_hook airflow.providers.common.ai.example_dags.example_llamaindex_rag airflow.providers.common.ai.example_dags.example_llm airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline airflow.providers.common.ai.example_dags.example_llm_batch airflow.providers.common.ai.example_dags.example_llm_branch airflow.providers.common.ai.example_dags.example_llm_classification airflow.providers.common.ai.example_dags.example_llm_fallback airflow.providers.common.ai.example_dags.example_llm_file_analysis airflow.providers.common.ai.example_dags.example_llm_retry_policy airflow.providers.common.ai.example_dags.example_llm_schema_compare airflow.providers.common.ai.example_dags.example_llm_sql airflow.providers.common.ai.example_dags.example_llm_survey_agentic airflow.providers.common.ai.example_dags.example_llm_survey_analysis airflow.providers.common.ai.example_dags.example_mcp airflow.providers.common.ai.example_dags.example_pydantic_ai_hook airflow.providers.common.ai.example_dags.example_quickstart airflow.providers.common.ai.example_dags.example_sandbox_toolset airflow.providers.common.ai.exceptions airflow.providers.common.ai.get_provider_info airflow.providers.common.ai.hooks airflow.providers.common.ai.hooks.langchain airflow.providers.common.ai.hooks.llamaindex airflow.providers.common.ai.hooks.mcp airflow.providers.common.ai.hooks.pydantic_ai airflow.providers.common.ai.mixins airflow.providers.common.ai.mixins.approval airflow.providers.common.ai.mixins.cancellable_run airflow.providers.common.ai.mixins.hitl_review airflow.providers.common.ai.observability airflow.providers.common.ai.operators airflow.providers.common.ai.operators.agent airflow.providers.common.ai.operators.document_loader airflow.providers.common.ai.operators.llamaindex_embedding airflow.providers.common.ai.operators.llamaindex_retrieval airflow.providers.common.ai.operators.llm airflow.providers.common.ai.operators.llm_batch airflow.providers.common.ai.operators.llm_branch airflow.providers.common.ai.operators.llm_file_analysis airflow.providers.common.ai.operators.llm_schema_compare airflow.providers.common.ai.operators.llm_sql airflow.providers.common.ai.plugins airflow.providers.common.ai.plugins.hitl_review airflow.providers.common.ai.policies airflow.providers.common.ai.policies.decision airflow.providers.common.ai.policies.retry airflow.providers.common.ai.sandbox airflow.providers.common.ai.sandbox.base airflow.providers.common.ai.sandbox.modal airflow.providers.common.ai.sandbox.output airflow.providers.common.ai.sandbox.sbx airflow.providers.common.ai.skills airflow.providers.common.ai.toolsets airflow.providers.common.ai.toolsets.datafusion airflow.providers.common.ai.toolsets.hook airflow.providers.common.ai.toolsets.langchain_bridge airflow.providers.common.ai.toolsets.logging airflow.providers.common.ai.toolsets.managed_agent airflow.providers.common.ai.toolsets.mcp airflow.providers.common.ai.toolsets.sandbox airflow.providers.common.ai.toolsets.skills airflow.providers.common.ai.toolsets.sql airflow.providers.common.ai.triggers airflow.providers.common.ai.triggers.llm_batch airflow.providers.common.ai.utils airflow.providers.common.ai.utils.dataquality airflow.providers.common.ai.utils.decision airflow.providers.common.ai.utils.file_analysis airflow.providers.common.ai.utils.hitl_review airflow.providers.common.ai.utils.logging airflow.providers.common.ai.utils.output_type airflow.providers.common.ai.utils.query_results airflow.providers.common.ai.utils.sql_validation airflow.providers.common.ai.utils.tool_definition airflow.providers.common.ai.utils.toolsets airflow.providers.common.ai.utils.usage airflow.providers.common.ai.utils.validation tests.system.common.ai tests.system.common.ai.example_sandbox_toolset_modal tests.system.common.ai.example_sandbox_toolset_sbx

multi_modal (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute)

N

name (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter attribute) (airflow.providers.common.ai.batch.base.BatchAdapter attribute) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter attribute) (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.DeliverableStatus attribute) (airflow.providers.common.ai.operators.agent.HITLReviewLink attribute) (airflow.providers.common.ai.plugins.hitl_review.HITLReviewPlugin attribute) (airflow.providers.common.ai.sandbox.base.SandboxBackend attribute) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend attribute) (airflow.providers.common.ai.sandbox.sbx.SbxSandboxBackend attribute)

names (airflow.providers.common.ai.example_dags.example_llm.Entities attribute) next_step() (airflow.providers.common.ai.durable.step_counter.DurableStepCounter method) notes (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) (airflow.providers.common.ai.example_dags.example_sandbox_toolset.ColumnMapping attribute) notify() (airflow.providers.common.ai.example_dags.example_llm.LogNotifier method) NOTIFY_EMAIL (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis)

O

ok (airflow.providers.common.ai.batch.output_schema.ValidationOutcome attribute) omitted_files (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) on_approval_timeout (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) on_error() (airflow.providers.common.ai.batch.polling.BatchPoller method) on_kill() (airflow.providers.common.ai.mixins.cancellable_run.CancellableAgentRunMixin method) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator method) (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger method) on_orphaned_intent (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) on_stale_state (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) on_state() (airflow.providers.common.ai.batch.polling.BatchPoller method) on_uncertain (airflow.providers.common.ai.policies.decision.DecisionPolicy attribute)

OpenAIBatchAdapter (class in airflow.providers.common.ai.batch.openai) operator_extra_links (airflow.providers.common.ai.operators.agent.AgentOperator attribute) out_of_range_result_count (airflow.providers.common.ai.batch.results.MergeDiagnostics attribute) output_schema_digest (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) output_type (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) output_type_ref (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) output_type_ref() (in module airflow.providers.common.ai.batch.results) OutputSpec (class in airflow.providers.common.ai.batch.output_schema) OutputT (in module airflow.providers.common.ai.hooks.pydantic_ai) overall_verdict (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ValidationResult attribute)

P

params (airflow.providers.common.ai.batch.base.BatchRequest attribute) parse_sql() (in module airflow.providers.common.ai.utils.sql_validation) parser (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) path (airflow.providers.common.ai.sandbox.base.SandboxFileTooLargeError attribute) (airflow.providers.common.ai.skills.GitSkills attribute) PENDING_REVIEW (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) PERMISSION_FAILURE (in module airflow.providers.common.ai.example_dags.example_classifier_model) persist_conn_id (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator attribute) persist_dir (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) picked_key() (in module airflow.providers.common.ai.utils.decision) policy_fails() (in module airflow.providers.common.ai.utils.decision) policy_record() (in module airflow.providers.common.ai.utils.decision) poll_interval (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger attribute) PollOutcome (class in airflow.providers.common.ai.batch.polling)

priority (airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline.TicketAnalysis attribute) probabilities (airflow.providers.common.ai.utils.decision.ModelConfidence attribute) prompt (airflow.providers.common.ai.batch.base.BatchRequest attribute) (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol attribute) (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) provider_input_ref (airflow.providers.common.ai.batch.base.SubmitResult attribute) (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) provider_status (airflow.providers.common.ai.batch.base.RawResultItem attribute) PydanticAIAzureHook (class in airflow.providers.common.ai.hooks.pydantic_ai) PydanticAIBedrockHook (class in airflow.providers.common.ai.hooks.pydantic_ai) PydanticAIHook (class in airflow.providers.common.ai.hooks.pydantic_ai) PydanticAIVertexHook (class in airflow.providers.common.ai.hooks.pydantic_ai)

Q

query (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator attribute)

QUERY_TOOL_DESCRIPTION (in module airflow.providers.common.ai.utils.query_results) quickstart_llm() (in module airflow.providers.common.ai.example_dags.example_quickstart)

R

raw (airflow.providers.common.ai.batch.base.RawResultItem attribute) raw_text (airflow.providers.common.ai.batch.output_schema.ValidationOutcome attribute) RawResultItem (class in airflow.providers.common.ai.batch.base) react_apps (airflow.providers.common.ai.plugins.hitl_review.HITLReviewPlugin attribute) READ_FILE (in module airflow.providers.common.ai.toolsets.sandbox) read_file() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) READ_ONLY_METADATA_TYPES (in module airflow.providers.common.ai.utils.sql_validation) read_state() (in module airflow.providers.common.ai.batch.state) reason (airflow.providers.common.ai.example_dags.example_llm_batch.Sentiment attribute) reasoning (airflow.providers.common.ai.policies.retry.ErrorClassification attribute) recommendations (airflow.providers.common.ai.example_dags.example_langchain_10k.AnalysisReport attribute) (airflow.providers.common.ai.example_dags.example_llamaindex_10k.AnalysisReport attribute) redact_registered_secrets() (in module airflow.providers.common.ai.policies.retry) REFERENCE_CSV_PATH (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) REFERENCE_CSV_URI (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) reference_datasource (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) regenerate_with_feedback() (airflow.providers.common.ai.mixins.hitl_review.HITLReviewMixin method) (airflow.providers.common.ai.operators.agent.AgentOperator method) register_adapter() (in module airflow.providers.common.ai.batch.dispatch) rehydrate_pydantic_output() (in module airflow.providers.common.ai.utils.output_type) REJECT (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin attribute) reject_sequence_with_unsupported_feature() (in module airflow.providers.common.ai.utils.validation) REJECTED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) RELEASE_NOTES (in module airflow.providers.common.ai.example_dags.example_quickstart) render_file_window() (in module airflow.providers.common.ai.sandbox.output) replayable (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset attribute) (airflow.providers.common.ai.toolsets.managed_agent.FailoverManagedAgentToolset attribute) replayed_model (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) replayed_tool (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) repo_url (airflow.providers.common.ai.skills.GitSkills attribute)

REPORT_SYSTEM_PROMPT (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) request() (airflow.providers.common.ai.durable.caching_model.CachingModel method) request_count (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) request_params (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) requests (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) require_approval (airflow.providers.common.ai.operators.llm.LLMOperator attribute) resolve_adapter_name() (in module airflow.providers.common.ai.batch.dispatch) resolve_request_model() (airflow.providers.common.ai.batch.base.BatchAdapter method) resolve_skills() (in module airflow.providers.common.ai.skills) resolve_sqlglot_dialect() (in module airflow.providers.common.ai.utils.sql_validation) resolved_paths (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) result_path (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) RESULT_ROOT (in module airflow.providers.common.ai.example_dags.example_llm_batch) retry (airflow.providers.common.ai.policies.retry.ErrorCategory attribute) return_schema_kwargs() (in module airflow.providers.common.ai.utils.tool_definition) REVIEW_ABOVE (in module airflow.providers.common.ai.example_dags.example_classifier_model) review_reason() (in module airflow.providers.common.ai.utils.decision) ReviewReason (in module airflow.providers.common.ai.utils.decision) reviews (airflow.providers.common.ai.policies.decision.DecisionPolicy property) REVIEWS (in module airflow.providers.common.ai.example_dags.example_llm_batch) role (airflow.providers.common.ai.utils.hitl_review.ConversationEntry attribute) row_count (airflow.providers.common.ai.example_dags.example_agent.Analysis attribute) run() (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger method) run_agent_sync() (airflow.providers.common.ai.mixins.cancellable_run.CancellableAgentRunMixin method) RUN_COMMAND (in module airflow.providers.common.ai.toolsets.sandbox) run_command() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.sbx.SbxSandboxBackend method) run_hitl_review() (airflow.providers.common.ai.mixins.hitl_review.HITLReviewMixin method) run_id (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute)

S

SAMPLE_DOCUMENTS (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) sample_rows (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) sandbox_terminated (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) SandboxBackend (class in airflow.providers.common.ai.sandbox.base) SandboxError SandboxExecResult (class in airflow.providers.common.ai.sandbox.base) SandboxFileTooLargeError SandboxSpec (class in airflow.providers.common.ai.sandbox.base) SandboxTerminalError SandboxToolset (class in airflow.providers.common.ai.toolsets.sandbox) save_model_response() (airflow.providers.common.ai.durable.base.DurableStorageProtocol method) (airflow.providers.common.ai.durable.storage.DurableStorage method) (airflow.providers.common.ai.durable.task_state_store.TaskStateStoreDurableStorage method) save_tool_result() (airflow.providers.common.ai.durable.base.DurableStorageProtocol method) (airflow.providers.common.ai.durable.storage.DurableStorage method) (airflow.providers.common.ai.durable.task_state_store.TaskStateStoreDurableStorage method) SbxSandboxBackend (class in airflow.providers.common.ai.sandbox.sbx) SCHEDULED_PROMPT (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) schema_context (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) schema_name (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute) schema_version (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) SCHEMA_VERSION (in module airflow.providers.common.ai.batch.state) SchemaCompareResult (class in airflow.providers.common.ai.operators.llm_schema_compare) SchemaMismatch (class in airflow.providers.common.ai.operators.llm_schema_compare) search_github_prs() (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) SECTION (in module airflow.providers.common.ai.durable.storage) (in module airflow.providers.common.ai.observability) Sentiment (class in airflow.providers.common.ai.example_dags.example_llm_batch) serialize() (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger method) serialize_for_llm() (in module airflow.providers.common.ai.utils.tool_definition) serialize_output (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) SessionStatus (class in airflow.providers.common.ai.utils.hitl_review) severity (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) shipped_count (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) should_retry (airflow.providers.common.ai.policies.retry.ErrorClassification attribute) size_bytes (airflow.providers.common.ai.sandbox.base.SandboxFileTooLargeError attribute) SKILLS_DIR (in module airflow.providers.common.ai.example_dags.example_agent_skills) (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) SkillSource (in module airflow.providers.common.ai.skills) SMTP_CONN_ID (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) source (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) source_bytes (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) source_conn_id (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) source_path (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) source_type (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) spec_summary (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) split_model_id() (in module airflow.providers.common.ai.batch.dispatch) SQL_SYSTEM_PROMPT (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) SQLSafetyError SQLToolset (class in airflow.providers.common.ai.toolsets.sql) (in module airflow.providers.common.ai.example_dags.example_agent) (in module airflow.providers.common.ai.example_dags.example_agent_capabilities) (in module airflow.providers.common.ai.example_dags.example_agent_durable) (in module airflow.providers.common.ai.example_dags.example_agent_skills) (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) stamp_identity_on_agent_spans() (in module airflow.providers.common.ai.observability) STATE_PATH (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_sbx) status (airflow.providers.common.ai.batch.base.BatchState attribute) (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.DeliverableStatus attribute) (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute)

STATUS_CANCELLED (in module airflow.providers.common.ai.batch.results) STATUS_ERROR (in module airflow.providers.common.ai.batch.results) STATUS_EXPIRED (in module airflow.providers.common.ai.batch.results) STATUS_INVALID_OUTPUT (in module airflow.providers.common.ai.batch.results) STATUS_MISSING (in module airflow.providers.common.ai.batch.results) STATUS_SUCCESS (in module airflow.providers.common.ai.batch.results) stderr (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) stderr_truncated (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) stdout (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) stdout_truncated (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) storage (airflow.providers.common.ai.durable.caching_model.CachingModel attribute) (airflow.providers.common.ai.durable.caching_toolset.CachingToolset attribute) stream_results_to_jsonl() (in module airflow.providers.common.ai.batch.results) sub_question (airflow.providers.common.ai.example_dags.example_langchain_10k.SubQuestion attribute) (airflow.providers.common.ai.example_dags.example_llamaindex_10k.SubQuestion attribute) sub_questions (airflow.providers.common.ai.example_dags.example_langchain_10k.DecomposedQuestion attribute) (airflow.providers.common.ai.example_dags.example_llamaindex_10k.DecomposedQuestion attribute) submit() (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter method) (airflow.providers.common.ai.batch.base.BatchAdapter method) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter method) SubmitResult (class in airflow.providers.common.ai.batch.base) submitted_at (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) SubQuestion (class in airflow.providers.common.ai.example_dags.example_langchain_10k) (class in airflow.providers.common.ai.example_dags.example_llamaindex_10k) suggested_action (airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline.TicketAnalysis attribute) (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) suggested_delay_seconds (airflow.providers.common.ai.policies.retry.ErrorClassification attribute) summarize_manifest() (in module airflow.providers.common.ai.example_dags.example_llm_batch) summary (airflow.providers.common.ai.example_dags.example_agent.Analysis attribute) (airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline.TicketAnalysis attribute) (airflow.providers.common.ai.example_dags.example_sandbox_toolset.Findings attribute) (airflow.providers.common.ai.operators.llm_schema_compare.SchemaCompareResult attribute) SUPPORTED_FILE_FORMATS (in module airflow.providers.common.ai.utils.file_analysis) supports_decision_policy (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) SURVEY_CSV_ENDPOINT (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) SURVEY_CSV_PATH (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) SURVEY_CSV_URI (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) survey_datasource (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) SURVEY_SCHEMA (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) suspected_cause (airflow.providers.common.ai.example_dags.example_sandbox_toolset.Findings attribute) SYNTHESIS_SYSTEM_PROMPT (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) system_prompt (airflow.providers.common.ai.batch.base.BatchRequest attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute)

T

table_names (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) tables (airflow.providers.common.ai.utils.sql_validation.TableScan attribute) TableScan (class in airflow.providers.common.ai.utils.sql_validation) target (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) target_type (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) task_completed (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) task_id (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol attribute) (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) TaskStateStoreDurableStorage (class in airflow.providers.common.ai.durable.task_state_store) template_fields (airflow.providers.common.ai.example_dags.example_llm.LogNotifier attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator attribute) (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) (airflow.providers.common.ai.policies.decision.BranchOption attribute) terminal_event() (in module airflow.providers.common.ai.batch.polling) TERMINAL_STATUS_MAP (in module airflow.providers.common.ai.batch.base) test_connection() (airflow.providers.common.ai.hooks.langchain.LangChainHook method) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook method) (airflow.providers.common.ai.hooks.mcp.MCPHook method) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook method) test_run (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_sbx) tests.system.common.ai module

tests.system.common.ai.example_sandbox_toolset_modal module tests.system.common.ai.example_sandbox_toolset_sbx module text (airflow.providers.common.ai.batch.base.ExtractedOutput attribute) text_file_count (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) text_truncated (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) threshold_for() (in module airflow.providers.common.ai.utils.decision) ticker (airflow.providers.common.ai.example_dags.example_langchain_10k.SubQuestion attribute) (airflow.providers.common.ai.example_dags.example_llamaindex_10k.SubQuestion attribute) TicketAnalysis (class in airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline) timed_out (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) timed_out_record() (in module airflow.providers.common.ai.utils.decision) timeout (airflow.providers.common.ai.batch.polling.BatchPoller attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger attribute) TIMEOUT_DEFAULTS (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin attribute) TIMEOUT_EXCEEDED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) timestamp (airflow.providers.common.ai.utils.hitl_review.ConversationEntry attribute) title (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) to_dict() (airflow.providers.common.ai.batch.state.BatchStateRecord method) token_provider (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) tool_prefix (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) TOOL_RESULT_SENTINEL (in module airflow.providers.common.ai.durable.base) toolsets (airflow.providers.common.ai.operators.agent.AgentOperator attribute) top_items (airflow.providers.common.ai.example_dags.example_agent.Analysis attribute) top_k (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator attribute) total_count (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) total_size_bytes (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) total_steps (airflow.providers.common.ai.durable.step_counter.DurableStepCounter property) truncate_output() (in module airflow.providers.common.ai.sandbox.output) truncated_inputs (airflow.providers.common.ai.example_dags.example_llm_file_analysis.FileAnalysisSummary attribute) type_adapter (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute)

U

UNCERTAIN_ACTIONS (in module airflow.providers.common.ai.policies.decision) UncertainAction (in module airflow.providers.common.ai.policies.decision) UNDERDETERMINED_INCIDENT (in module airflow.providers.common.ai.example_dags.example_classifier_model) ungrounded_claims (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ValidationResult attribute) unmapped (airflow.providers.common.ai.example_dags.example_sandbox_toolset.ColumnMapping attribute)

UnsupportedBatchProviderError unverifiable_sources (airflow.providers.common.ai.utils.sql_validation.TableScan attribute) usage (airflow.providers.common.ai.batch.base.RawResultItem attribute) usage_limits (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) user_content (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute)

V

validate_approval_prompt() (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol method) (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin method) validate_decision_policy() (in module airflow.providers.common.ai.utils.decision) validate_extracted_output() (in module airflow.providers.common.ai.batch.output_schema) validate_prompt() (in module airflow.providers.common.ai.utils.validation) validate_requests() (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter method) (airflow.providers.common.ai.batch.base.BatchAdapter method) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter method)

validate_sql (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) validate_sql() (in module airflow.providers.common.ai.utils.sql_validation) VALIDATION_SYSTEM_PROMPT (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) ValidationOutcome (class in airflow.providers.common.ai.batch.output_schema) ValidationResult (class in airflow.providers.common.ai.example_dags.example_aip_progress_tracker) value (airflow.providers.common.ai.batch.base.ExtractedOutput attribute) (airflow.providers.common.ai.batch.output_schema.ValidationOutcome attribute) VENDOR_SAMPLE (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset)

W

wrap_toolsets_for_logging() (in module airflow.providers.common.ai.utils.logging) wrapped (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute) WRITE_FILE (in module airflow.providers.common.ai.toolsets.sandbox) write_file() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.sbx.SbxSandboxBackend method)

write_intent() (in module airflow.providers.common.ai.batch.state) write_submitted() (in module airflow.providers.common.ai.batch.state)

X

XCOM_AGENT_OUTPUT_PREFIX (in module airflow.providers.common.ai.utils.hitl_review) XCOM_AGENT_SESSION (in module airflow.providers.common.ai.utils.hitl_review)

XCOM_HUMAN_ACTION (in module airflow.providers.common.ai.utils.hitl_review) XCOM_HUMAN_FEEDBACK_PREFIX (in module airflow.providers.common.ai.utils.hitl_review)

PreviousNext

Was this entry helpful?