• 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) __version__ (in module airflow.providers.common.ai)

A

AbstractToolset (in module airflow.providers.common.ai.toolsets.skills) action (airflow.providers.common.ai.utils.hitl_review.HumanActionData attribute) agent_params (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) 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) 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.decorators module airflow.providers.common.ai.decorators.agent module airflow.providers.common.ai.decorators.llm 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_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_branch module airflow.providers.common.ai.example_dags.example_llm_classification 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.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.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_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.retry module airflow.providers.common.ai.sandbox module airflow.providers.common.ai.sandbox.base 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.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.utils module airflow.providers.common.ai.utils.dataquality 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.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_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) Analysis (class in airflow.providers.common.ai.example_dags.example_agent) 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) 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) attachment_count (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute)

B

block_network (airflow.providers.common.ai.sandbox.base.SandboxSpec attribute) branch (airflow.providers.common.ai.skills.GitSkills attribute)

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_query_result() (in module airflow.providers.common.ai.utils.query_results)

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.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) 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) 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) 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) code_arg_kwargs() (in module airflow.providers.common.ai.utils.tool_definition) code_mode (airflow.providers.common.ai.operators.agent.AgentOperator attribute) collect_table_references() (in module airflow.providers.common.ai.utils.sql_validation) column (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) 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) confidence (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.DeliverableStatus 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) 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) 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) 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) create() (airflow.providers.common.ai.sandbox.base.SandboxBackend 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)

D

dag (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_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) 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_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_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_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) 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) 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) description (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch 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.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) 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) 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) Entities (class in airflow.providers.common.ai.example_dags.example_llm) env (airflow.providers.common.ai.sandbox.base.SandboxSpec attribute) ENV_ID (in module tests.system.common.ai.example_sandbox_toolset_sbx) env_provider (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) ErrorClassification (class in airflow.providers.common.ai.policies.retry) evaluate() (airflow.providers.common.ai.policies.retry.LLMRetryPolicy method) 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_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_branch_approval() (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_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_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_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_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_full_context() (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_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_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_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)

F

fallback_rules (airflow.providers.common.ai.policies.retry.LLMRetryPolicy 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) findings (airflow.providers.common.ai.example_dags.example_llm_file_analysis.FileAnalysisSummary attribute) fingerprint_model_request() (in module airflow.providers.common.ai.durable.fingerprint) fingerprint_tool_call() (in module airflow.providers.common.ai.durable.fingerprint) 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_xcom() (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse static method)

G

genai_instrumentation_settings() (in module airflow.providers.common.ai.observability) 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.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.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) 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) InputGuard (in module airflow.providers.common.ai.example_dags.example_agent_capabilities) instructions (airflow.providers.common.ai.policies.retry.LLMRetryPolicy attribute) INTERACTIVE_PROMPT (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) 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_text_field (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute)

K

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)

L

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) 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_branch_task() (in module airflow.providers.common.ai.decorators.llm_branch) llm_conn_id (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.policies.retry.LLMRetryPolicy 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) 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.hitl_review.HITLReviewProtocol attribute) (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.sbx) (in module airflow.providers.common.ai.toolsets.datafusion) (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)

M

MARKER (in module tests.system.common.ai.example_sandbox_toolset_sbx) max_bytes (airflow.providers.common.ai.sandbox.base.SandboxFileTooLargeError attribute) max_exception_length (airflow.providers.common.ai.policies.retry.LLMRetryPolicy attribute) 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_text_chars (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator 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) message_history (airflow.providers.common.ai.operators.agent.AgentOperator attribute) metadata_fields (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) migration_query (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) mismatches (airflow.providers.common.ai.operators.llm_schema_compare.SchemaCompareResult attribute) model_id (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.policies.retry.LLMRetryPolicy attribute) module airflow.providers.common.ai airflow.providers.common.ai.decorators airflow.providers.common.ai.decorators.agent airflow.providers.common.ai.decorators.llm 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_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_branch airflow.providers.common.ai.example_dags.example_llm_classification 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.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.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_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.retry airflow.providers.common.ai.sandbox airflow.providers.common.ai.sandbox.base 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.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.utils airflow.providers.common.ai.utils.dataquality 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.validation tests.system.common.ai 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.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.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) NOTIFY_EMAIL (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis)

O

omitted_files (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) operator_extra_links (airflow.providers.common.ai.operators.agent.AgentOperator attribute) output_type (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute)

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

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) 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) priority (airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline.TicketAnalysis attribute)

prompt (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) 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

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) 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_exception (airflow.providers.common.ai.policies.retry.LLMRetryPolicy attribute) redact_registered_secrets() (in module airflow.providers.common.ai.policies.retry) redactor (airflow.providers.common.ai.policies.retry.LLMRetryPolicy attribute) 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) 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) render_file_window() (in module airflow.providers.common.ai.sandbox.output) 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) require_approval (airflow.providers.common.ai.operators.llm.LLMOperator attribute) 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) return_schema_kwargs() (in module airflow.providers.common.ai.utils.tool_definition) role (airflow.providers.common.ai.utils.hitl_review.ConversationEntry attribute) row_count (airflow.providers.common.ai.example_dags.example_agent.Analysis attribute) 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.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) 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) 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) 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)

STATE_PATH (in module tests.system.common.ai.example_sandbox_toolset_sbx) status (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) 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) 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) 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) 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.operators.llm_schema_compare.SchemaCompareResult attribute) SUPPORTED_FILE_FORMATS (in module airflow.providers.common.ai.utils.file_analysis) 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) 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.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator 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.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_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) test_connection() (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_sbx) tests.system.common.ai module

tests.system.common.ai.example_sandbox_toolset_sbx module text_file_count (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) text_truncated (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) 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) timeout (airflow.providers.common.ai.policies.retry.LLMRetryPolicy 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) 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)

U

ungrounded_claims (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ValidationResult attribute) unverifiable_sources (airflow.providers.common.ai.utils.sql_validation.TableScan 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_prompt() (in module airflow.providers.common.ai.utils.validation)

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) ValidationResult (class in airflow.providers.common.ai.example_dags.example_aip_progress_tracker)

W

wrap_toolsets_for_logging() (in module airflow.providers.common.ai.utils.logging) 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.sbx.SbxSandboxBackend method)

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?