• 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) __call__() (airflow.providers.common.ai.durable.strands.AgentFactory method) __doc__ (airflow.providers.common.ai.policies.retry.ClassifierRetryPolicy attribute) (airflow.providers.common.ai.policies.retry.LLMRetryPolicy attribute)

__enter__() (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) __exit__() (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) __post_init__() (airflow.providers.common.ai.managed_agents.base.ManagedAgentRequest method) (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_decision_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 (airflow.providers.common.ai.managed_agents.base.BoundManagedAgent attribute) agent() (airflow.providers.common.ai.managed_agents.base.BaseManagedAgentHook method) agent_framework_tracing() (in module airflow.providers.common.ai.tools.tracing) agent_params (airflow.providers.common.ai.operators.agent.AgentOperator attribute) agent_platform (airflow.providers.common.ai.managed_agents.base.BaseManagedAgentHook attribute) agent_ref (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset property) (airflow.providers.common.ai.toolsets.managed_agent.ManagedAgentToolset 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.object_storage.ObjectStorageToolset attribute) (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset attribute) (airflow.providers.common.ai.toolsets.sql.SQLToolset attribute) AgentFactory (class in airflow.providers.common.ai.durable.strands) 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.capability module airflow.providers.common.ai.durable.fingerprint module airflow.providers.common.ai.durable.journal module airflow.providers.common.ai.durable.replay_usage module airflow.providers.common.ai.durable.storage module airflow.providers.common.ai.durable.strands module airflow.providers.common.ai.durable.strands_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_adk_agent 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_memory module airflow.providers.common.ai.example_dags.example_agent_recovery module airflow.providers.common.ai.example_dags.example_agent_skills module airflow.providers.common.ai.example_dags.example_agent_tool_approval module airflow.providers.common.ai.example_dags.example_agent_tool_judge module airflow.providers.common.ai.example_dags.example_aip_progress_tracker module airflow.providers.common.ai.example_dags.example_anthropic_tool_runner module airflow.providers.common.ai.example_dags.example_datafusion_toolset module airflow.providers.common.ai.example_dags.example_decision_model module airflow.providers.common.ai.example_dags.example_document_loader module airflow.providers.common.ai.example_dags.example_hook_toolset 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_approval 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_object_storage_toolset module airflow.providers.common.ai.example_dags.example_openai_agents_agent module airflow.providers.common.ai.example_dags.example_progressive_tool_disclosure module airflow.providers.common.ai.example_dags.example_pydantic_ai_agent 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.example_dags.example_sql_toolset module airflow.providers.common.ai.example_dags.example_strands_agent module airflow.providers.common.ai.example_dags.example_strands_durable module airflow.providers.common.ai.example_dags.example_why_common_ai 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.managed_agents module

airflow.providers.common.ai.managed_agents.base module airflow.providers.common.ai.managed_agents.failover 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.mixins.usage_budget 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.plugins.model_panel 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.boat module airflow.providers.common.ai.sandbox.islo module airflow.providers.common.ai.sandbox.modal module airflow.providers.common.ai.sandbox.opensandbox module airflow.providers.common.ai.sandbox.openshell 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.tools module airflow.providers.common.ai.tools.adk module airflow.providers.common.ai.tools.anthropic module airflow.providers.common.ai.tools.openai_agents module airflow.providers.common.ai.tools.strands module airflow.providers.common.ai.tools.tracing 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.object_storage 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.coroutines 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.masking module airflow.providers.common.ai.utils.output_type module airflow.providers.common.ai.utils.prompt_cache module airflow.providers.common.ai.utils.query_results module airflow.providers.common.ai.utils.sql_validation module airflow.providers.common.ai.utils.task_logger module airflow.providers.common.ai.utils.tool_definition module airflow.providers.common.ai.utils.tool_metrics module airflow.providers.common.ai.utils.toolset_base module airflow.providers.common.ai.utils.toolsets module airflow.providers.common.ai.utils.usage module airflow.providers.common.ai.utils.usage_budget module airflow.providers.common.ai.utils.validation module airflow_tools() (airflow.providers.common.ai.tools.ToolProvider method) (airflow.providers.common.ai.toolsets.mcp.MCPToolset method) (airflow.providers.common.ai.utils.toolset_base.AirflowToolset method) 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) AirflowDurability (class in airflow.providers.common.ai.durable.capability) AirflowTool (class in airflow.providers.common.ai.tools) AirflowTools (class in airflow.providers.common.ai.tools.adk) (class in airflow.providers.common.ai.tools.anthropic) (class in airflow.providers.common.ai.tools.openai_agents) (class in airflow.providers.common.ai.tools.strands) AirflowToolset (class in airflow.providers.common.ai.utils.toolset_base) AirflowTraceProcessor (class in airflow.providers.common.ai.tools.openai_agents) allow (airflow.providers.common.ai.example_dags.example_agent_tool_judge.Verdict attribute) 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) as_messages() (airflow.providers.common.ai.managed_agents.base.ManagedAgentRequest method) assemble_manifest() (in module airflow.providers.common.ai.batch.results) AsyncAirflowTools (class in airflow.providers.common.ai.tools.anthropic) asyncpg (in module airflow.providers.common.ai.example_dags.example_agent_memory) attach() (airflow.providers.common.ai.sandbox.base.AttachableSandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) attach_to (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset attribute) AttachableSandboxBackend (class in airflow.providers.common.ai.sandbox.base) AttachedSandbox (class in airflow.providers.common.ai.sandbox.base) attachment_count (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute)

B

BARE_OUTPUT_FIELD (in module airflow.providers.common.ai.utils.decision) BaseManagedAgentHook (class in airflow.providers.common.ai.managed_agents.base) 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) before_run() (airflow.providers.common.ai.durable.capability.AirflowDurability method) begin_model_request() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) block_network (airflow.providers.common.ai.sandbox.base.SandboxSpec attribute) BoatSandboxBackend (class in airflow.providers.common.ai.sandbox.boat)

BoundManagedAgent (class in airflow.providers.common.ai.managed_agents.base) 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) build_run_meta_key() (in module airflow.providers.common.ai.durable.base) build_schema_result() (in module airflow.providers.common.ai.utils.query_results) build_step_key() (in module airflow.providers.common.ai.durable.base) build_task_storage() (in module airflow.providers.common.ai.durable.journal) bz2 (in module airflow.providers.common.ai.utils.file_analysis)

C

cache_prompt (airflow.providers.common.ai.operators.agent.AgentOperator attribute) call() (airflow.providers.common.ai.tools.AirflowTool method) call_tool() (airflow.providers.common.ai.toolsets.logging.LoggingToolset method) (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset method) (airflow.providers.common.ai.utils.toolset_base.AirflowToolset method) (airflow.providers.common.ai.utils.toolset_base.MaskingToolset method) calling_framework() (in module airflow.providers.common.ai.utils.tool_metrics) 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) capabilities (airflow.providers.common.ai.managed_agents.base.BoundManagedAgent property) (airflow.providers.common.ai.managed_agents.base.ManagedAgentClient property) (airflow.providers.common.ai.managed_agents.failover.FailoverManagedAgentClient property) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) 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) CHANGE (in module airflow.providers.common.ai.example_dags.example_llm_approval) 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) claim() (airflow.providers.common.ai.durable.journal.DurableRun method) 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) clean_up_after_run (airflow.providers.common.ai.durable.journal.DurableJournal attribute) cleanup() (airflow.providers.common.ai.durable.journal.DurableJournal method) (airflow.providers.common.ai.durable.journal.DurableRun method) clear() (airflow.providers.common.ai.utils.usage_budget.TaskStateStoreUsageBudget method) client (airflow.providers.common.ai.toolsets.managed_agent.ManagedAgentToolset property) close() (airflow.providers.common.ai.batch.base.BatchAdapter method) code_arg_kwargs() (in module airflow.providers.common.ai.utils.tool_definition) CodeMode (in module airflow.providers.common.ai.example_dags.example_agent) coerce_usage_limits() (in module airflow.providers.common.ai.utils.usage) collect_table_references() (in module airflow.providers.common.ai.utils.sql_validation) collect_tools() (in module airflow.providers.common.ai.tools) column (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) ColumnarSample (class in airflow.providers.common.ai.utils.file_analysis) 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) CONNECT (in module tests.system.common.ai.example_sandbox_toolset_openshell) consecutive_failures (airflow.providers.common.ai.batch.polling.BatchPoller attribute) content (airflow.providers.common.ai.tools.ToolResult attribute) (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) copy_run_usage() (in module airflow.providers.common.ai.utils.usage_budget) correction (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ClaimValidation attribute) COUNT_SLEEPERS (in module tests.system.common.ai.example_sandbox_toolset_openshell) counts (airflow.providers.common.ai.batch.base.BatchState attribute) create() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.boat.BoatSandboxBackend method) (airflow.providers.common.ai.sandbox.islo.IsloSandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend method) (airflow.providers.common.ai.sandbox.openshell.OpenShellSandboxBackend method) (airflow.providers.common.ai.sandbox.sbx.SbxSandboxBackend method) create_agent() (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook method) credit_first_replay() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) credit_request() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) credit_successors() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) credit_tool_steps() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) current_framework() (in module airflow.providers.common.ai.utils.tool_metrics) current_journal() (in module airflow.providers.common.ai.durable.journal) 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) Customer (class in airflow.providers.common.ai.example_dags.example_agent_memory) customer_id (airflow.providers.common.ai.example_dags.example_agent_memory.Customer attribute) customer_request() (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge)

D

dag (in module tests.system.common.ai.example_sandbox_toolset_boat) (in module tests.system.common.ai.example_sandbox_toolset_islo) (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (in module tests.system.common.ai.example_sandbox_toolset_openshell) (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_boat) (in module tests.system.common.ai.example_sandbox_toolset_islo) (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (in module tests.system.common.ai.example_sandbox_toolset_openshell) (in module tests.system.common.ai.example_sandbox_toolset_sbx) dag_run_owner() (in module airflow.providers.common.ai.sandbox.base) data_sources (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) DataFusionToolset (class in airflow.providers.common.ai.toolsets.datafusion) (in module airflow.providers.common.ai.example_dags.example_datafusion_toolset) 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_adk_agent) (in module airflow.providers.common.ai.example_dags.example_anthropic_tool_runner) (in module airflow.providers.common.ai.example_dags.example_langchain_toolset_bridge) (in module airflow.providers.common.ai.example_dags.example_openai_agents_agent) (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_agent) (in module airflow.providers.common.ai.example_dags.example_strands_agent) (in module airflow.providers.common.ai.example_dags.example_strands_durable) 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) decode_network_policy() (in module airflow.providers.common.ai.sandbox.base) 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_COLUMNS (in module airflow.providers.common.ai.utils.query_results) DEFAULT_MAX_RESULT_BYTES (in module airflow.providers.common.ai.utils.query_results) DEFAULT_QUESTION (in module airflow.providers.common.ai.example_dags.example_adk_agent) (in module airflow.providers.common.ai.example_dags.example_anthropic_tool_runner) (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_openai_agents_agent) (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_agent) (in module airflow.providers.common.ai.example_dags.example_strands_agent) (in module airflow.providers.common.ai.example_dags.example_strands_durable)

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() (airflow.providers.common.ai.durable.strands_storage.TaskStateStoreStorage method) delete_state() (in module airflow.providers.common.ai.batch.state) delete_steps() (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) delete_usage_record() (in module airflow.providers.common.ai.utils.usage_budget) 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) deny (airflow.providers.common.ai.example_dags.example_agent_tool_judge.Verdict attribute) describe() (in module airflow.providers.common.ai.managed_agents.base) 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) (airflow.providers.common.ai.tools.AirflowTool 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.boat.BoatSandboxBackend method) (airflow.providers.common.ai.sandbox.islo.IsloSandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend method) (airflow.providers.common.ai.sandbox.openshell.OpenShellSandboxBackend method) (airflow.providers.common.ai.sandbox.sbx.SbxSandboxBackend method) detect_compression() (in module airflow.providers.common.ai.utils.file_analysis) 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) diverged (airflow.providers.common.ai.durable.journal.DurableRun attribute) 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) dump_output_for_display() (in module airflow.providers.common.ai.utils.output_type) dump_output_to_json() (in module airflow.providers.common.ai.utils.output_type) dump_run_usage() (in module airflow.providers.common.ai.utils.usage_budget) dumps_masked() (in module airflow.providers.common.ai.utils.masking) 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) durable_run (airflow.providers.common.ai.durable.journal.JournalStep attribute) DurableJournal (class in airflow.providers.common.ai.durable.journal) DurableJournalError DurableRun (class in airflow.providers.common.ai.durable.journal) 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_kwargs (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) encode_network_policy() (in module airflow.providers.common.ai.sandbox.base) 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) engine_spec (airflow.providers.common.ai.durable.capability.AirflowDurability attribute) ensure_masked() (in module airflow.providers.common.ai.utils.toolset_base) 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_boat) (in module tests.system.common.ai.example_sandbox_toolset_islo) (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (in module tests.system.common.ai.example_sandbox_toolset_openshell) (in module tests.system.common.ai.example_sandbox_toolset_sbx) ENV_MARKER (in module tests.system.common.ai.example_sandbox_toolset_boat) 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_adk_agent() (in module airflow.providers.common.ai.example_dags.example_adk_agent) 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_memory() (in module airflow.providers.common.ai.example_dags.example_agent_memory) 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_recovery() (in module airflow.providers.common.ai.example_dags.example_agent_recovery) 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_skills_restricted() (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_agent_tool_approval() (in module airflow.providers.common.ai.example_dags.example_agent_tool_approval) example_agent_tool_judge() (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge) 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_airflow_durability_capability() (in module airflow.providers.common.ai.example_dags.example_agent_durable) example_anthropic_tool_runner() (in module airflow.providers.common.ai.example_dags.example_anthropic_tool_runner) example_datafusion_toolset_restricted() (in module airflow.providers.common.ai.example_dags.example_datafusion_toolset) example_decision_model_branch() (in module airflow.providers.common.ai.example_dags.example_decision_model) example_decision_model_confidence() (in module airflow.providers.common.ai.example_dags.example_decision_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_hook_toolset_restricted() (in module airflow.providers.common.ai.example_dags.example_hook_toolset) 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_approval() (in module airflow.providers.common.ai.example_dags.example_llm_approval) 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_approval() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_model_settings() (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_filtered_tools() (in module airflow.providers.common.ai.example_dags.example_mcp) 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_object_storage_toolset() (in module airflow.providers.common.ai.example_dags.example_object_storage_toolset) example_object_storage_toolset_restricted() (in module airflow.providers.common.ai.example_dags.example_object_storage_toolset) example_openai_agents_agent() (in module airflow.providers.common.ai.example_dags.example_openai_agents_agent) example_pydantic_ai_agent() (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_agent) 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_export() (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) example_sandbox_agent_local() (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) example_sandbox_attach() (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_boat() (in module tests.system.common.ai.example_sandbox_toolset_boat) example_sandbox_toolset_islo() (in module tests.system.common.ai.example_sandbox_toolset_islo) example_sandbox_toolset_modal() (in module tests.system.common.ai.example_sandbox_toolset_modal) example_sandbox_toolset_opensandbox() (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) example_sandbox_toolset_openshell() (in module tests.system.common.ai.example_sandbox_toolset_openshell) example_sandbox_toolset_sbx() (in module tests.system.common.ai.example_sandbox_toolset_sbx) example_sql_toolset_restricted() (in module airflow.providers.common.ai.example_dags.example_sql_toolset) example_strands_agent() (in module airflow.providers.common.ai.example_dags.example_strands_agent) example_strands_durable() (in module airflow.providers.common.ai.example_dags.example_strands_durable) example_task_with_toolsets() (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_hook) example_why_common_ai() (in module airflow.providers.common.ai.example_dags.example_why_common_ai) 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_sql.LLMSQLQueryOperator method) execute_tool() (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.object_storage.ObjectStorageToolset method) (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) (airflow.providers.common.ai.toolsets.sql.SQLToolset method) (airflow.providers.common.ai.utils.toolset_base.AirflowToolset method) executing() (airflow.providers.common.ai.durable.journal.JournalStep 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) EXPIRES_AT_TAG (in module airflow.providers.common.ai.sandbox.base) export_file() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.islo.IsloSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend method) (airflow.providers.common.ai.sandbox.sbx.SbxSandboxBackend method) 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() (airflow.providers.common.ai.durable.journal.DurableRun method) (airflow.providers.common.ai.durable.journal.JournalStep method) 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) FailoverManagedAgentClient (class in airflow.providers.common.ai.managed_agents.failover) FailureCause (class in airflow.providers.common.ai.example_dags.example_decision_model) 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) (airflow.providers.common.ai.plugins.model_panel.ModelPanelPlugin 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) FILES (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_agent)

FILES_CONN_ID (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_agent) fill_replayed_cost() (in module airflow.providers.common.ai.durable.replay_usage) 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 (airflow.providers.common.ai.durable.journal.JournalStep attribute) 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) force_flush() (airflow.providers.common.ai.tools.openai_agents.AirflowTraceProcessor method) format_size() (in module airflow.providers.common.ai.sandbox.output) format_usage_for_xcom() (in module airflow.providers.common.ai.utils.logging) Framework (in module airflow.providers.common.ai.utils.tool_metrics) 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) function (airflow.providers.common.ai.tools.AirflowTool attribute)

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_agent_capabilities() (airflow.providers.common.ai.managed_agents.base.BaseManagedAgentHook method) 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_durable_operation_backend() (airflow.providers.common.ai.durable.capability.AirflowDurability method) get_embedding_model() (airflow.providers.common.ai.hooks.langchain.LangChainHook method) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook method) GET_FILE_INFO (in module airflow.providers.common.ai.toolsets.object_storage) get_hook() (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook class 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_model_settings() (airflow.providers.common.ai.utils.prompt_cache.PromptCaching method) get_ordering() (airflow.providers.common.ai.toolsets.logging.ToolLoggingCapability method) (airflow.providers.common.ai.utils.toolset_base.MaskingCapability 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_run_id() (airflow.providers.common.ai.durable.journal.DurableJournal method)

GET_SCHEMA_TOOL_DESCRIPTION (in module airflow.providers.common.ai.utils.query_results) get_serialization_name() (airflow.providers.common.ai.toolsets.logging.ToolLoggingCapability class method) get_task_logger() (in module airflow.providers.common.ai.utils.task_logger) get_tools() (airflow.providers.common.ai.tools.adk.AirflowTools method) (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.object_storage.ObjectStorageToolset 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) get_wrapper_toolset() (airflow.providers.common.ai.durable.capability.AirflowDurability method) (airflow.providers.common.ai.toolsets.logging.ToolLoggingCapability 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) HOLDER_TAG (in module airflow.providers.common.ai.sandbox.base)

hook (airflow.providers.common.ai.managed_agents.base.BoundManagedAgent attribute) 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.object_storage.ObjectStorageToolset 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) (airflow.providers.common.ai.utils.prompt_cache.PromptCaching attribute) 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_durable_context (airflow.providers.common.ai.durable.capability.AirflowDurability property) 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) input_tokens (airflow.providers.common.ai.managed_agents.base.ManagedAgentUsage 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.managed_agents.base.BoundManagedAgent method) (airflow.providers.common.ai.managed_agents.base.ManagedAgentClient method) (airflow.providers.common.ai.managed_agents.failover.FailoverManagedAgentClient method) (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset method) invoke_agent() (airflow.providers.common.ai.managed_agents.base.BaseManagedAgentHook method) invoke_durably() (in module airflow.providers.common.ai.durable.strands) invoke_sync() (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset method) (airflow.providers.common.ai.toolsets.managed_agent.ManagedAgentToolset method) is_error (airflow.providers.common.ai.tools.ToolResult attribute) is_sandbox_handle() (in module airflow.providers.common.ai.sandbox.base) is_structured (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute) is_successful_tool_payload() (in module airflow.providers.common.ai.durable.replay_usage) IsloSandboxBackend (class in airflow.providers.common.ai.sandbox.islo) 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

journal (airflow.providers.common.ai.durable.journal.DurableRun attribute) journal_scope() (in module airflow.providers.common.ai.durable.journal) JournalStats (class in airflow.providers.common.ai.durable.journal)

JournalStep (class in airflow.providers.common.ai.durable.journal) json_schema (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute) json_text_field (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) judge_tool_calls() (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge)

K

key (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) (airflow.providers.common.ai.durable.journal.DurableRun 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) (airflow.providers.common.ai.durable.journal.JournalStep 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() (airflow.providers.common.ai.durable.strands_storage.TaskStateStoreStorage method) 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.boat.BoatSandboxBackend method) (airflow.providers.common.ai.sandbox.islo.IsloSandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend method) (airflow.providers.common.ai.sandbox.openshell.OpenShellSandboxBackend method) LIST_FILES (in module airflow.providers.common.ai.toolsets.object_storage) 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_adk_agent) (in module airflow.providers.common.ai.example_dags.example_agent_memory) (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) (in module airflow.providers.common.ai.example_dags.example_anthropic_tool_runner) (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) (in module airflow.providers.common.ai.example_dags.example_openai_agents_agent) (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_agent) (in module airflow.providers.common.ai.example_dags.example_strands_agent) (in module airflow.providers.common.ai.example_dags.example_strands_durable) 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_adk_agent) (in module airflow.providers.common.ai.example_dags.example_anthropic_tool_runner) (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_openai_agents_agent) (in module airflow.providers.common.ai.example_dags.example_strands_agent) (in module airflow.providers.common.ai.example_dags.example_strands_durable) 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() (airflow.providers.common.ai.utils.usage_budget.TaskStateStoreUsageBudget method) load_run_usage() (in module airflow.providers.common.ai.utils.usage_budget) load_step() (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) (airflow.providers.common.ai.mixins.usage_budget.UsageBudgetHostProtocol 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.fingerprint) (in module airflow.providers.common.ai.durable.journal) (in module airflow.providers.common.ai.durable.storage) (in module airflow.providers.common.ai.durable.task_state_store) (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge) (in module airflow.providers.common.ai.managed_agents.failover) (in module airflow.providers.common.ai.mixins.approval) (in module airflow.providers.common.ai.mixins.hitl_review) (in module airflow.providers.common.ai.sandbox.base) (in module airflow.providers.common.ai.sandbox.boat) (in module airflow.providers.common.ai.sandbox.islo) (in module airflow.providers.common.ai.sandbox.modal) (in module airflow.providers.common.ai.sandbox.opensandbox) (in module airflow.providers.common.ai.sandbox.openshell) (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) (in module airflow.providers.common.ai.utils.output_type) (in module airflow.providers.common.ai.utils.toolset_base) (in module airflow.providers.common.ai.utils.usage_budget) log_run_summary() (in module airflow.providers.common.ai.utils.logging) log_run_usage() (in module airflow.providers.common.ai.utils.logging) log_summary() (airflow.providers.common.ai.durable.journal.DurableJournal method) logger (airflow.providers.common.ai.toolsets.logging.LoggingToolset attribute) (airflow.providers.common.ai.toolsets.logging.ToolLoggingCapability attribute) LoggingToolset (class in airflow.providers.common.ai.toolsets.logging) LogNotifier (class in airflow.providers.common.ai.example_dags.example_llm) lookup_order() (in module airflow.providers.common.ai.example_dags.example_agent_tool_approval) (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge) LowConfidenceError lowest() (airflow.providers.common.ai.utils.decision.ModelConfidence method) lzma (in module airflow.providers.common.ai.utils.file_analysis)

M

make_task_instance_run_key() (in module airflow.providers.common.ai.observability) ManagedAgentCapabilities (class in airflow.providers.common.ai.managed_agents.base) ManagedAgentClient (class in airflow.providers.common.ai.managed_agents.base) ManagedAgentInvocationError ManagedAgentRef (class in airflow.providers.common.ai.managed_agents.base) ManagedAgentRejected ManagedAgentRequest (class in airflow.providers.common.ai.managed_agents.base) ManagedAgentResponse (class in airflow.providers.common.ai.managed_agents.base) ManagedAgentToolset (class in airflow.providers.common.ai.toolsets.managed_agent) ManagedAgentUsage (class in airflow.providers.common.ai.managed_agents.base) mapped (airflow.providers.common.ai.example_dags.example_sandbox_toolset.ColumnMapping attribute) MARKER (in module tests.system.common.ai.example_sandbox_toolset_boat) (in module tests.system.common.ai.example_sandbox_toolset_islo) (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (in module tests.system.common.ai.example_sandbox_toolset_openshell) (in module tests.system.common.ai.example_sandbox_toolset_sbx) mask_secrets() (in module airflow.providers.common.ai.utils.masking) MaskingCapability (class in airflow.providers.common.ai.utils.toolset_base) MaskingToolset (class in airflow.providers.common.ai.utils.toolset_base) 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) members (airflow.providers.common.ai.managed_agents.failover.FailoverManagedAgentClient property) Memory (in module airflow.providers.common.ai.example_dags.example_agent_memory) MEMORY_CONN_ID (in module airflow.providers.common.ai.example_dags.example_agent_memory) MEMORY_DB (in module airflow.providers.common.ai.example_dags.example_agent_memory) 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) messages (airflow.providers.common.ai.managed_agents.base.ManagedAgentRequest 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) MIN_CONFIDENCE (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge) 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_NAME_XCOM_KEY (in module airflow.providers.common.ai.utils.logging) model_panel_app (in module airflow.providers.common.ai.plugins.model_panel) 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) model_settings (airflow.providers.common.ai.operators.llm.LLMOperator attribute) ModelConfidence (class in airflow.providers.common.ai.utils.decision) ModelPanelPlugin (class in airflow.providers.common.ai.plugins.model_panel) 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.capability airflow.providers.common.ai.durable.fingerprint airflow.providers.common.ai.durable.journal airflow.providers.common.ai.durable.replay_usage airflow.providers.common.ai.durable.storage airflow.providers.common.ai.durable.strands airflow.providers.common.ai.durable.strands_storage airflow.providers.common.ai.durable.task_state_store airflow.providers.common.ai.example_dags airflow.providers.common.ai.example_dags.example_adk_agent 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_memory airflow.providers.common.ai.example_dags.example_agent_recovery airflow.providers.common.ai.example_dags.example_agent_skills airflow.providers.common.ai.example_dags.example_agent_tool_approval airflow.providers.common.ai.example_dags.example_agent_tool_judge airflow.providers.common.ai.example_dags.example_aip_progress_tracker airflow.providers.common.ai.example_dags.example_anthropic_tool_runner airflow.providers.common.ai.example_dags.example_datafusion_toolset airflow.providers.common.ai.example_dags.example_decision_model airflow.providers.common.ai.example_dags.example_document_loader airflow.providers.common.ai.example_dags.example_hook_toolset 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_approval 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_object_storage_toolset airflow.providers.common.ai.example_dags.example_openai_agents_agent airflow.providers.common.ai.example_dags.example_progressive_tool_disclosure airflow.providers.common.ai.example_dags.example_pydantic_ai_agent 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.example_dags.example_sql_toolset airflow.providers.common.ai.example_dags.example_strands_agent airflow.providers.common.ai.example_dags.example_strands_durable airflow.providers.common.ai.example_dags.example_why_common_ai 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.managed_agents airflow.providers.common.ai.managed_agents.base airflow.providers.common.ai.managed_agents.failover 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.mixins.usage_budget 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.plugins.model_panel 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.boat airflow.providers.common.ai.sandbox.islo airflow.providers.common.ai.sandbox.modal airflow.providers.common.ai.sandbox.opensandbox airflow.providers.common.ai.sandbox.openshell airflow.providers.common.ai.sandbox.output airflow.providers.common.ai.sandbox.sbx airflow.providers.common.ai.skills airflow.providers.common.ai.tools airflow.providers.common.ai.tools.adk airflow.providers.common.ai.tools.anthropic airflow.providers.common.ai.tools.openai_agents airflow.providers.common.ai.tools.strands airflow.providers.common.ai.tools.tracing 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.object_storage 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.coroutines 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.masking airflow.providers.common.ai.utils.output_type airflow.providers.common.ai.utils.prompt_cache airflow.providers.common.ai.utils.query_results airflow.providers.common.ai.utils.sql_validation airflow.providers.common.ai.utils.task_logger airflow.providers.common.ai.utils.tool_definition airflow.providers.common.ai.utils.tool_metrics airflow.providers.common.ai.utils.toolset_base airflow.providers.common.ai.utils.toolsets airflow.providers.common.ai.utils.usage airflow.providers.common.ai.utils.usage_budget airflow.providers.common.ai.utils.validation tests.system.common.ai tests.system.common.ai.example_sandbox_toolset_boat tests.system.common.ai.example_sandbox_toolset_islo tests.system.common.ai.example_sandbox_toolset_modal tests.system.common.ai.example_sandbox_toolset_opensandbox tests.system.common.ai.example_sandbox_toolset_openshell 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.durable.journal.JournalStep attribute) (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.DeliverableStatus attribute) (airflow.providers.common.ai.managed_agents.base.ManagedAgentRef attribute) (airflow.providers.common.ai.operators.agent.HITLReviewLink attribute) (airflow.providers.common.ai.plugins.hitl_review.HITLReviewPlugin attribute) (airflow.providers.common.ai.plugins.model_panel.ModelPanelPlugin attribute) (airflow.providers.common.ai.sandbox.base.SandboxBackend attribute) (airflow.providers.common.ai.sandbox.boat.BoatSandboxBackend attribute) (airflow.providers.common.ai.sandbox.islo.IsloSandboxBackend attribute) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend attribute) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend attribute) (airflow.providers.common.ai.sandbox.openshell.OpenShellSandboxBackend attribute) (airflow.providers.common.ai.sandbox.sbx.SbxSandboxBackend attribute) (airflow.providers.common.ai.tools.AirflowTool attribute) (airflow.providers.common.ai.tools.strands.AirflowTools property)

names (airflow.providers.common.ai.example_dags.example_llm.Entities attribute) nested_runs (airflow.providers.common.ai.durable.journal.JournalStep attribute) network (airflow.providers.common.ai.sandbox.base.AttachedSandbox attribute) NETWORK_TAG (in module airflow.providers.common.ai.sandbox.base) normalize_assigned_users() (in module airflow.providers.common.ai.mixins.approval) not_recorded (airflow.providers.common.ai.durable.journal.JournalStats attribute) 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

ObjectStorageToolset (class in airflow.providers.common.ai.toolsets.object_storage) 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_span_end() (airflow.providers.common.ai.tools.openai_agents.AirflowTraceProcessor method) on_span_start() (airflow.providers.common.ai.tools.openai_agents.AirflowTraceProcessor method) on_stale_state (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) on_state() (airflow.providers.common.ai.batch.polling.BatchPoller method) on_tool_approval_timeout (airflow.providers.common.ai.operators.agent.AgentOperator attribute) on_trace_end() (airflow.providers.common.ai.tools.openai_agents.AirflowTraceProcessor method) on_trace_start() (airflow.providers.common.ai.tools.openai_agents.AirflowTraceProcessor method) on_uncertain (airflow.providers.common.ai.policies.decision.DecisionPolicy attribute) OpenAIBatchAdapter (class in airflow.providers.common.ai.batch.openai)

OpenSandboxBackend (class in airflow.providers.common.ai.sandbox.opensandbox) OpenShellSandboxBackend (class in airflow.providers.common.ai.sandbox.openshell) operator_extra_links (airflow.providers.common.ai.operators.agent.AgentOperator attribute) ORDERS (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge) out_of_range_result_count (airflow.providers.common.ai.batch.results.MergeDiagnostics attribute) output_retries (airflow.providers.common.ai.operators.llm.LLMOperator attribute) output_schema_digest (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) output_tokens (airflow.providers.common.ai.managed_agents.base.ManagedAgentUsage 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) owner (airflow.providers.common.ai.sandbox.base.SandboxSpec attribute) OWNER_TAG (in module airflow.providers.common.ai.sandbox.base)

P

P (in module airflow.providers.common.ai.utils.toolset_base) parameters (airflow.providers.common.ai.tools.AirflowTool attribute) 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) payload (airflow.providers.common.ai.durable.journal.JournalStep attribute) peek() (airflow.providers.common.ai.durable.journal.DurableRun method) PENDING_REVIEW (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) permanent (airflow.providers.common.ai.example_dags.example_decision_model.FailureCause attribute) PERMISSION_FAILURE (in module airflow.providers.common.ai.example_dags.example_decision_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) platform (airflow.providers.common.ai.managed_agents.base.ManagedAgentRef attribute) 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) position (airflow.providers.common.ai.durable.journal.DurableRun property) (airflow.providers.common.ai.durable.journal.JournalStep attribute) 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.managed_agents.base.ManagedAgentRequest 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) PROMPT_CACHE_SETTING_NAMES (in module airflow.providers.common.ai.utils.prompt_cache) PromptCaching (class in airflow.providers.common.ai.utils.prompt_cache) 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

R (in module airflow.providers.common.ai.utils.toolset_base) raw (airflow.providers.common.ai.batch.base.RawResultItem attribute) (airflow.providers.common.ai.managed_agents.base.ManagedAgentResponse 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) (airflow.providers.common.ai.plugins.model_panel.ModelPanelPlugin attribute) read() (airflow.providers.common.ai.durable.strands_storage.TaskStateStoreStorage method) read_bytes() (in module airflow.providers.common.ai.utils.file_analysis) READ_FILE (in module airflow.providers.common.ai.toolsets.object_storage) (in module airflow.providers.common.ai.toolsets.sandbox) read_file() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.boat.BoatSandboxBackend method) (airflow.providers.common.ai.sandbox.islo.IsloSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend method) (airflow.providers.common.ai.sandbox.openshell.OpenShellSandboxBackend method) READ_ONLY_METADATA_TYPES (in module airflow.providers.common.ai.utils.sql_validation) READ_ONLY_WEATHER_TOOLS (in module airflow.providers.common.ai.example_dags.example_mcp) read_state() (in module airflow.providers.common.ai.batch.state) read_tags() (airflow.providers.common.ai.sandbox.base.AttachableSandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) 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) record() (airflow.providers.common.ai.durable.journal.JournalStep method) record_capability_replay() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) record_live_model_request() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) record_live_tool_call() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) record_model_replay() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) record_tool_call() (in module airflow.providers.common.ai.utils.tool_metrics) record_tool_replay() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) recorded (airflow.providers.common.ai.durable.journal.JournalStats attribute) redact_registered_secrets() (in module airflow.providers.common.ai.policies.retry) ref (airflow.providers.common.ai.managed_agents.base.BoundManagedAgent property) (airflow.providers.common.ai.managed_agents.base.ManagedAgentClient property) (airflow.providers.common.ai.managed_agents.failover.FailoverManagedAgentClient property) 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) refund_order() (in module airflow.providers.common.ai.example_dags.example_agent_tool_approval) (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge) refused_earlier() (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge) 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() (airflow.providers.common.ai.durable.journal.DurableRun method) reject_sequence_with_unsupported_feature() (in module airflow.providers.common.ai.utils.validation) REJECTED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) release() (airflow.providers.common.ai.sandbox.base.AttachableSandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) RELEASE_NOTES (in module airflow.providers.common.ai.example_dags.example_quickstart) remaining_lifetime (airflow.providers.common.ai.sandbox.base.AttachedSandbox attribute) render_file_window() (in module airflow.providers.common.ai.sandbox.output)

replayable (airflow.providers.common.ai.durable.journal.JournalStep attribute) (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset attribute) (airflow.providers.common.ai.toolsets.managed_agent.ManagedAgentToolset attribute) (airflow.providers.common.ai.utils.toolset_base.AirflowToolset attribute) replayed (airflow.providers.common.ai.durable.journal.JournalStats attribute) (airflow.providers.common.ai.durable.journal.JournalStep attribute) ReplayUsageLedger (class in airflow.providers.common.ai.durable.replay_usage) repo_url (airflow.providers.common.ai.skills.GitSkills attribute) REPORT_METHODS (in module airflow.providers.common.ai.example_dags.example_progressive_tool_disclosure) REPORT_SYSTEM_PROMPT (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) 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_agent() (airflow.providers.common.ai.managed_agents.base.BaseManagedAgentHook method) 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) resource (airflow.providers.common.ai.example_dags.example_decision_model.FailureCause 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) resume_after_tool_approval() (airflow.providers.common.ai.operators.agent.AgentOperator method) retry (airflow.providers.common.ai.policies.retry.ErrorCategory attribute) return_schema_kwargs() (in module airflow.providers.common.ai.utils.tool_definition) review (airflow.providers.common.ai.example_dags.example_agent_tool_judge.Verdict attribute) REVIEW_ABOVE (in module airflow.providers.common.ai.example_dags.example_decision_model) review_reason() (in module airflow.providers.common.ai.utils.decision) ReviewedOutputValidationError 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.durable.journal.DurableRun method) (airflow.providers.common.ai.durable.journal.JournalStep method) (airflow.providers.common.ai.tools.anthropic.AirflowTools method) (airflow.providers.common.ai.tools.anthropic.AsyncAirflowTools method) (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger method) run_agent_sync() (airflow.providers.common.ai.mixins.cancellable_run.CancellableAgentRunMixin method) (airflow.providers.common.ai.mixins.usage_budget.UsageBudgetHostProtocol method) run_blocking() (airflow.providers.common.ai.utils.toolset_base.AirflowToolset static 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.boat.BoatSandboxBackend method) (airflow.providers.common.ai.sandbox.islo.IsloSandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend method) (airflow.providers.common.ai.sandbox.openshell.OpenShellSandboxBackend method) (airflow.providers.common.ai.sandbox.sbx.SbxSandboxBackend method) run_coroutine_sync() (in module airflow.providers.common.ai.utils.coroutines) run_hitl_review() (airflow.providers.common.ai.mixins.hitl_review.HITLReviewMixin method) run_id (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) RUN_ID_KEY (in module airflow.providers.common.ai.durable.base) run_usage (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger attribute) RUNS_KEY (in module airflow.providers.common.ai.durable.base)

S

S3Hook (in module airflow.providers.common.ai.example_dags.example_hook_toolset) (in module airflow.providers.common.ai.example_dags.example_progressive_tool_disclosure) sample_columnar_file() (in module airflow.providers.common.ai.utils.file_analysis) 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() (airflow.providers.common.ai.durable.journal.DurableRun method) (airflow.providers.common.ai.utils.usage_budget.TaskStateStoreUsageBudget method) save_step() (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) session_id (airflow.providers.common.ai.managed_agents.base.ManagedAgentRequest attribute) (airflow.providers.common.ai.managed_agents.base.ManagedAgentResponse attribute) sessions (airflow.providers.common.ai.managed_agents.base.ManagedAgentCapabilities attribute) SessionStatus (class in airflow.providers.common.ai.utils.hitl_review) settle() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) 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) shop (in module airflow.providers.common.ai.example_dags.example_agent_tool_approval) (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge) should_retry (airflow.providers.common.ai.policies.retry.ErrorClassification attribute) shutdown() (airflow.providers.common.ai.tools.openai_agents.AirflowTraceProcessor method) 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_recovery) (in module airflow.providers.common.ai.example_dags.example_agent_skills) (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) (in module airflow.providers.common.ai.example_dags.example_sql_toolset) STAGING_URI (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) stamp_identity_on_agent_spans() (in module airflow.providers.common.ai.observability) start_run() (airflow.providers.common.ai.durable.journal.DurableJournal method) STATE_PATH (in module tests.system.common.ai.example_sandbox_toolset_boat) (in module tests.system.common.ai.example_sandbox_toolset_islo) (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (in module tests.system.common.ai.example_sandbox_toolset_openshell) (in module tests.system.common.ai.example_sandbox_toolset_sbx)

stats (airflow.providers.common.ai.durable.journal.DurableJournal attribute) 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) StepKind (in module airflow.providers.common.ai.durable.journal) storage (airflow.providers.common.ai.durable.journal.DurableJournal attribute) stream_results_to_jsonl() (in module airflow.providers.common.ai.batch.results) structured (airflow.providers.common.ai.managed_agents.base.ManagedAgentResponse attribute) structured_output (airflow.providers.common.ai.managed_agents.base.ManagedAgentCapabilities 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) 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) subtract_request_usage() (in module airflow.providers.common.ai.durable.replay_usage) subtract_run_usage() (in module airflow.providers.common.ai.utils.usage_budget) SUCCESSFUL_TOOL_RESULT_KINDS (in module airflow.providers.common.ai.durable.replay_usage) 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) TaskStateStoreStorage (class in airflow.providers.common.ai.durable.strands_storage) TaskStateStoreUsageBudget (class in airflow.providers.common.ai.utils.usage_budget) 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_boat) (in module tests.system.common.ai.example_sandbox_toolset_islo) (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (in module tests.system.common.ai.example_sandbox_toolset_openshell) (in module tests.system.common.ai.example_sandbox_toolset_sbx) tests.system.common.ai module tests.system.common.ai.example_sandbox_toolset_boat module tests.system.common.ai.example_sandbox_toolset_islo module tests.system.common.ai.example_sandbox_toolset_modal module tests.system.common.ai.example_sandbox_toolset_opensandbox module tests.system.common.ai.example_sandbox_toolset_openshell module tests.system.common.ai.example_sandbox_toolset_sbx module

text (airflow.providers.common.ai.batch.base.ExtractedOutput attribute) (airflow.providers.common.ai.managed_agents.base.ManagedAgentResponse attribute) (airflow.providers.common.ai.utils.file_analysis.ColumnarSample 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.managed_agents.base.ManagedAgentRequest attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset property) (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_approval_assigned_users (airflow.providers.common.ai.operators.agent.AgentOperator attribute) tool_approval_timeout (airflow.providers.common.ai.operators.agent.AgentOperator attribute) TOOL_DESCRIPTIONS (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge) tool_prefix (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) ToolApprovalAlreadyRequestedError ToolApprovalError ToolCallError ToolLoggingCapability (class in airflow.providers.common.ai.toolsets.logging) ToolProvider (class in airflow.providers.common.ai.tools) ToolResult (class in airflow.providers.common.ai.tools) ToolRunnerMaxIterationsError tools (airflow.providers.common.ai.tools.anthropic.AirflowTools attribute) (airflow.providers.common.ai.tools.anthropic.AsyncAirflowTools attribute) (airflow.providers.common.ai.tools.strands.AirflowTools property) 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_rows (airflow.providers.common.ai.utils.file_analysis.ColumnarSample attribute) total_size_bytes (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) trace (airflow.providers.common.ai.managed_agents.base.ManagedAgentCapabilities attribute) trace_ref (airflow.providers.common.ai.managed_agents.base.ManagedAgentResponse attribute) track_chain() (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger method) transient (airflow.providers.common.ai.example_dags.example_decision_model.FailureCause attribute) 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_decision_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 UnsupportedToolDeferralError unverifiable_sources (airflow.providers.common.ai.utils.sql_validation.TableScan attribute) usage (airflow.providers.common.ai.batch.base.RawResultItem attribute) (airflow.providers.common.ai.managed_agents.base.ManagedAgentCapabilities attribute) (airflow.providers.common.ai.managed_agents.base.ManagedAgentResponse attribute)

USAGE_BUDGET_KEY (in module airflow.providers.common.ai.utils.usage_budget) usage_limits (airflow.providers.common.ai.mixins.usage_budget.UsageBudgetHostProtocol attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) UsageBudgetHostProtocol (class in airflow.providers.common.ai.mixins.usage_budget) UsageBudgetMixin (class in airflow.providers.common.ai.mixins.usage_budget) 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_max_retries() (in module airflow.providers.common.ai.utils.toolset_base) 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_options (airflow.providers.common.ai.managed_agents.base.ManagedAgentRequest attribute) VENDOR_SAMPLE (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) Verdict (class in airflow.providers.common.ai.example_dags.example_agent_tool_judge) version (airflow.providers.common.ai.managed_agents.base.ManagedAgentRef attribute)

W

within_order_total() (in module airflow.providers.common.ai.example_dags.example_agent_tool_judge) workdir (airflow.providers.common.ai.sandbox.base.AttachedSandbox attribute) WORKDIR_TAG (in module airflow.providers.common.ai.sandbox.base) wrap_run() (airflow.providers.common.ai.durable.capability.AirflowDurability method) wrap_tool_execute() (airflow.providers.common.ai.utils.toolset_base.MaskingCapability method) wrapped (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute) write() (airflow.providers.common.ai.durable.strands_storage.TaskStateStoreStorage method) 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.boat.BoatSandboxBackend method) (airflow.providers.common.ai.sandbox.islo.IsloSandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend method) (airflow.providers.common.ai.sandbox.openshell.OpenShellSandboxBackend 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) write_tags() (airflow.providers.common.ai.sandbox.base.AttachableSandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend 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?