• Home
• Index

Index

_

__aenter__() (airflow.providers.common.ai.toolsets.mcp.MCPToolset method) (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset method) __aexit__() (airflow.providers.common.ai.toolsets.mcp.MCPToolset method) (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset method) __doc__ (airflow.providers.common.ai.policies.retry.ClassifierRetryPolicy attribute) (airflow.providers.common.ai.policies.retry.LLMRetryPolicy attribute)

__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) (airflow.providers.common.ai.operators.llm.LLMOperator 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) AgentOperator (class in airflow.providers.common.ai.operators.agent) AgentSessionData (class in airflow.providers.common.ai.utils.hitl_review) AgentSkillsToolset (class in airflow.providers.common.ai.toolsets.skills) aip_number (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) AIP_REGISTRY (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) AIPStatus (class in airflow.providers.common.ai.example_dags.example_aip_progress_tracker) airflow.providers.common.ai module airflow.providers.common.ai.batch module airflow.providers.common.ai.batch.anthropic module airflow.providers.common.ai.batch.base module airflow.providers.common.ai.batch.dispatch module airflow.providers.common.ai.batch.openai module airflow.providers.common.ai.batch.output_schema module airflow.providers.common.ai.batch.polling module airflow.providers.common.ai.batch.results module airflow.providers.common.ai.batch.state module airflow.providers.common.ai.decorators module airflow.providers.common.ai.decorators.agent module airflow.providers.common.ai.decorators.llm module airflow.providers.common.ai.decorators.llm_batch module airflow.providers.common.ai.decorators.llm_branch module airflow.providers.common.ai.decorators.llm_file_analysis module airflow.providers.common.ai.decorators.llm_schema_compare module airflow.providers.common.ai.decorators.llm_sql module airflow.providers.common.ai.durable module airflow.providers.common.ai.durable.base module airflow.providers.common.ai.durable.caching_model module airflow.providers.common.ai.durable.caching_toolset module airflow.providers.common.ai.durable.fingerprint module airflow.providers.common.ai.durable.replay_usage module airflow.providers.common.ai.durable.step_counter module airflow.providers.common.ai.durable.storage module airflow.providers.common.ai.durable.task_state_store module airflow.providers.common.ai.example_dags module airflow.providers.common.ai.example_dags.example_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_skills module airflow.providers.common.ai.example_dags.example_agent_tool_approval module airflow.providers.common.ai.example_dags.example_aip_progress_tracker 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_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_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.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.observability module airflow.providers.common.ai.operators module airflow.providers.common.ai.operators.agent module airflow.providers.common.ai.operators.document_loader module airflow.providers.common.ai.operators.llamaindex_embedding module airflow.providers.common.ai.operators.llamaindex_retrieval module airflow.providers.common.ai.operators.llm module airflow.providers.common.ai.operators.llm_batch module airflow.providers.common.ai.operators.llm_branch module airflow.providers.common.ai.operators.llm_file_analysis module airflow.providers.common.ai.operators.llm_schema_compare module airflow.providers.common.ai.operators.llm_sql module airflow.providers.common.ai.plugins module airflow.providers.common.ai.plugins.hitl_review module airflow.providers.common.ai.policies module airflow.providers.common.ai.policies.decision module airflow.providers.common.ai.policies.retry module airflow.providers.common.ai.sandbox module airflow.providers.common.ai.sandbox.base module airflow.providers.common.ai.sandbox.modal module airflow.providers.common.ai.sandbox.opensandbox 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.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_V_3_4_PLUS (in module airflow.providers.common.ai.plugins.hitl_review) AIRFLOW_WEBSITE_CONN_ID (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) AirflowTool (class in airflow.providers.common.ai.tools) AirflowTools (class in airflow.providers.common.ai.tools.adk) (class in airflow.providers.common.ai.tools.strands) AirflowToolset (class in airflow.providers.common.ai.utils.toolset_base) 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) 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) block_network (airflow.providers.common.ai.sandbox.base.SandboxSpec attribute) 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_model_step_key() (in module airflow.providers.common.ai.durable.base) 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_schema_result() (in module airflow.providers.common.ai.utils.query_results) build_tool_step_key() (in module airflow.providers.common.ai.durable.base) bz2 (in module airflow.providers.common.ai.utils.file_analysis)

C

cache_prompt (airflow.providers.common.ai.operators.agent.AgentOperator attribute) cached_model (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) cached_tool (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) CachingModel (class in airflow.providers.common.ai.durable.caching_model) CachingToolset (class in airflow.providers.common.ai.durable.caching_toolset) call() (airflow.providers.common.ai.tools.AirflowTool method) call_tool() (airflow.providers.common.ai.durable.caching_toolset.CachingToolset method) (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) CHANGES_REQUESTED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) check_bar() (in module airflow.providers.common.ai.policies.decision) check_custom_id_length() (airflow.providers.common.ai.batch.base.BatchAdapter method) check_uncertain_action() (in module airflow.providers.common.ai.utils.decision) chunk_overlap (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) chunk_size (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) claim (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ClaimValidation attribute) ClaimValidation (class in airflow.providers.common.ai.example_dags.example_aip_progress_tracker) CLASSIFIER_INSTRUCTIONS (in module airflow.providers.common.ai.policies.retry) ClassifierRetryPolicy (class in airflow.providers.common.ai.policies.retry) cleanup() (airflow.providers.common.ai.durable.base.DurableStorageProtocol method) (airflow.providers.common.ai.durable.storage.DurableStorage method) (airflow.providers.common.ai.durable.task_state_store.TaskStateStoreDurableStorage method) 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) 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) counter (airflow.providers.common.ai.durable.caching_model.CachingModel attribute) (airflow.providers.common.ai.durable.caching_toolset.CachingToolset attribute) counts (airflow.providers.common.ai.batch.base.BatchState attribute) create() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend 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.caching_model.CachingModel method) credit_request() (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_output (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) custom_id (airflow.providers.common.ai.batch.base.RawResultItem attribute)

D

dag (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (in module tests.system.common.ai.example_sandbox_toolset_sbx) dag_id (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) DAG_ID (in module tests.system.common.ai.example_sandbox_toolset_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (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_langchain_toolset_bridge) (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_agent) (in module airflow.providers.common.ai.example_dags.example_strands_agent) 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_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_pydantic_ai_agent) (in module airflow.providers.common.ai.example_dags.example_strands_agent)

DEFAULT_SANDBOX_TIMEOUT (in module airflow.providers.common.ai.sandbox.modal) DEFAULT_SYSTEM_PROMPT (in module airflow.providers.common.ai.operators.llm_schema_compare) DEFAULT_TICKERS (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) DEFAULT_WORKDIR (in module airflow.providers.common.ai.sandbox.modal) defer (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol attribute) defer_for_approval() (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin method) DeferForApprovalProtocol (class in airflow.providers.common.ai.mixins.approval) deferrable (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) delay (airflow.providers.common.ai.policies.retry.ErrorCategory attribute) delete_state() (in module airflow.providers.common.ai.batch.state) deliverables (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) DeliverableStatus (class in airflow.providers.common.ai.example_dags.example_aip_progress_tracker) describe() (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.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend 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) 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_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) DurableStepCounter (class in airflow.providers.common.ai.durable.step_counter) DurableStorage (class in airflow.providers.common.ai.durable.storage) DurableStorageProtocol (class in airflow.providers.common.ai.durable.base)

E

EDGAR_USER_AGENT (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) EgressEnforcement (in module airflow.providers.common.ai.sandbox.modal) embed_conn_id (airflow.providers.common.ai.hooks.langchain.LangChainHook attribute) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook attribute) (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator attribute) embed_model (airflow.providers.common.ai.hooks.langchain.LangChainHook attribute) (airflow.providers.common.ai.hooks.llamaindex.LlamaIndexHook attribute) (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator attribute) (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator attribute) embedding_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) 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_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (in module tests.system.common.ai.example_sandbox_toolset_sbx) env_provider (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) error (airflow.providers.common.ai.batch.base.RawResultItem attribute) error_message (airflow.providers.common.ai.batch.base.BatchState attribute) (airflow.providers.common.ai.batch.output_schema.ValidationOutcome attribute) ErrorCategory (class in airflow.providers.common.ai.policies.retry) ErrorClassification (class in airflow.providers.common.ai.policies.retry) evaluate() (airflow.providers.common.ai.policies.retry.ClassifierRetryPolicy method) (airflow.providers.common.ai.policies.retry.LLMRetryPolicy method) evaluate_batch_counts() (in module airflow.providers.common.ai.batch.base) event (airflow.providers.common.ai.batch.polling.PollOutcome attribute) evidence (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.DeliverableStatus attribute) evidence_found (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.ClaimValidation attribute) example_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_operator_code_mode() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_operator_hitl_review() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_operator_hook() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_operator_sql() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_self_hosted() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_session() (in module airflow.providers.common.ai.example_dags.example_agent) example_agent_skills_git() (in module airflow.providers.common.ai.example_dags.example_agent_skills) example_agent_skills_local() (in module airflow.providers.common.ai.example_dags.example_agent_skills) example_agent_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_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_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_batch_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_batch) example_llm_batch_operator() (in module airflow.providers.common.ai.example_dags.example_llm_batch) example_llm_batch_per_request_overrides() (in module airflow.providers.common.ai.example_dags.example_llm_batch) example_llm_batch_provider_params() (in module airflow.providers.common.ai.example_dags.example_llm_batch) example_llm_branch_approval() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_decision_policy() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_decorator_multi() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_descriptions() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_multi() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_operator() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_classification() (in module airflow.providers.common.ai.example_dags.example_llm_classification) example_llm_decorator() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_decorator_structured() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_fallback() (in module airflow.providers.common.ai.example_dags.example_llm_fallback) example_llm_fallback_explicit_chain() (in module airflow.providers.common.ai.example_dags.example_llm_fallback) example_llm_fallback_operator_argument() (in module airflow.providers.common.ai.example_dags.example_llm_fallback) example_llm_file_analysis_approval() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_basic() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_multimodal() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_prefix() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_structured() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_operator() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_agent_params() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_approval() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_structured() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_templated_usage_limits() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_usage_limits() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_schema_compare_approval() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_basic() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_basic_context() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_conditional() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_with_object_storage() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_sql_basic() (in module airflow.providers.common.ai.example_dags.example_llm_sql) example_llm_survey_agentic() (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) example_llm_survey_interactive() (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) example_mcp_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_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_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_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_task_with_toolsets() (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_hook) execute() (airflow.providers.common.ai.operators.agent.AgentOperator method) (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator method) (airflow.providers.common.ai.operators.llamaindex_embedding.LlamaIndexEmbeddingOperator method) (airflow.providers.common.ai.operators.llamaindex_retrieval.LlamaIndexRetrievalOperator method) (airflow.providers.common.ai.operators.llm.LLMOperator method) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator method) (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator method) (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator method) (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator method) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator method) execute_complete() (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin method) (airflow.providers.common.ai.operators.llm.LLMOperator method) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator method) (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator method) (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator method) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator method) 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) 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.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_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) 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_model_request() (in module airflow.providers.common.ai.durable.fingerprint) fingerprint_tool_call() (in module airflow.providers.common.ai.durable.fingerprint) finish_reason (airflow.providers.common.ai.batch.base.RawResultItem attribute) finish_timeout() (airflow.providers.common.ai.batch.polling.BatchPoller method) for_run() (airflow.providers.common.ai.toolsets.sandbox.SandboxToolset method) (airflow.providers.common.ai.toolsets.skills.AgentSkillsToolset method) format_size() (in module airflow.providers.common.ai.sandbox.output) 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_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_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_SCHEMA_TOOL_DESCRIPTION (in module airflow.providers.common.ai.utils.query_results)

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) 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_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_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) iter_results() (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter method) (airflow.providers.common.ai.batch.base.BatchAdapter method) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter method) iter_toolsets() (in module airflow.providers.common.ai.utils.toolsets) iteration (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.ConversationEntry attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) (airflow.providers.common.ai.utils.hitl_review.HumanActionData attribute)

J

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

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

K

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

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

L

label (airflow.providers.common.ai.example_dags.example_llm_batch.Sentiment attribute) LANGCHAIN_CONN_ID (in module airflow.providers.common.ai.example_dags.example_langchain_10k) LangChainHook (class in airflow.providers.common.ai.hooks.langchain) LIST_DIRECTORY (in module airflow.providers.common.ai.toolsets.sandbox) list_directory() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend 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_aip_progress_tracker) (in module airflow.providers.common.ai.example_dags.example_langchain_10k) (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) (in module airflow.providers.common.ai.example_dags.example_langchain_toolset_bridge) (in module airflow.providers.common.ai.example_dags.example_llamaindex_10k) (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_agent) (in module airflow.providers.common.ai.example_dags.example_strands_agent) 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_langchain_tool_agent) (in module airflow.providers.common.ai.example_dags.example_langchain_toolset_bridge) (in module airflow.providers.common.ai.example_dags.example_strands_agent) 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_model_response() (airflow.providers.common.ai.durable.base.DurableStorageProtocol method) (airflow.providers.common.ai.durable.storage.DurableStorage method) (airflow.providers.common.ai.durable.task_state_store.TaskStateStoreDurableStorage method) load_run_usage() (in module airflow.providers.common.ai.utils.usage_budget) load_tool_result() (airflow.providers.common.ai.durable.base.DurableStorageProtocol method) (airflow.providers.common.ai.durable.storage.DurableStorage method) (airflow.providers.common.ai.durable.task_state_store.TaskStateStoreDurableStorage method) locations (airflow.providers.common.ai.example_dags.example_llm.Entities attribute) log (airflow.providers.common.ai.mixins.cancellable_run.CancellableAgentRunMixin attribute) (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (in module airflow.providers.common.ai.batch.anthropic) (in module airflow.providers.common.ai.batch.openai) (in module airflow.providers.common.ai.batch.results) (in module airflow.providers.common.ai.durable.caching_model) (in module airflow.providers.common.ai.durable.caching_toolset) (in module airflow.providers.common.ai.durable.fingerprint) (in module airflow.providers.common.ai.durable.storage) (in module airflow.providers.common.ai.durable.task_state_store) (in module airflow.providers.common.ai.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.modal) (in module airflow.providers.common.ai.sandbox.opensandbox) (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.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) logger (airflow.providers.common.ai.toolsets.logging.LoggingToolset attribute) LoggingToolset (class in airflow.providers.common.ai.toolsets.logging) LogNotifier (class in airflow.providers.common.ai.example_dags.example_llm) lookup_order() (in module airflow.providers.common.ai.example_dags.example_agent_tool_approval) 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_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (in module tests.system.common.ai.example_sandbox_toolset_sbx) mask_secrets() (in module airflow.providers.common.ai.utils.masking) 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) 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) mismatches (airflow.providers.common.ai.operators.llm_schema_compare.SchemaCompareResult attribute) missing_indexes() (in module airflow.providers.common.ai.batch.results) modal (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) ModalSandboxBackend (class in airflow.providers.common.ai.sandbox.modal) model (airflow.providers.common.ai.batch.base.BatchRequest attribute) (airflow.providers.common.ai.batch.base.RawResultItem attribute) (airflow.providers.common.ai.utils.decision.ModelConfidence attribute) model_id (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) model_provider (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIAzureHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIBedrockHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIVertexHook attribute) ModelConfidence (class in airflow.providers.common.ai.utils.decision) module airflow.providers.common.ai airflow.providers.common.ai.batch airflow.providers.common.ai.batch.anthropic airflow.providers.common.ai.batch.base airflow.providers.common.ai.batch.dispatch airflow.providers.common.ai.batch.openai airflow.providers.common.ai.batch.output_schema airflow.providers.common.ai.batch.polling airflow.providers.common.ai.batch.results airflow.providers.common.ai.batch.state airflow.providers.common.ai.decorators airflow.providers.common.ai.decorators.agent airflow.providers.common.ai.decorators.llm airflow.providers.common.ai.decorators.llm_batch airflow.providers.common.ai.decorators.llm_branch airflow.providers.common.ai.decorators.llm_file_analysis airflow.providers.common.ai.decorators.llm_schema_compare airflow.providers.common.ai.decorators.llm_sql airflow.providers.common.ai.durable airflow.providers.common.ai.durable.base airflow.providers.common.ai.durable.caching_model airflow.providers.common.ai.durable.caching_toolset airflow.providers.common.ai.durable.fingerprint airflow.providers.common.ai.durable.replay_usage airflow.providers.common.ai.durable.step_counter airflow.providers.common.ai.durable.storage airflow.providers.common.ai.durable.task_state_store airflow.providers.common.ai.example_dags airflow.providers.common.ai.example_dags.example_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_skills airflow.providers.common.ai.example_dags.example_agent_tool_approval airflow.providers.common.ai.example_dags.example_aip_progress_tracker 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_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_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.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.observability airflow.providers.common.ai.operators airflow.providers.common.ai.operators.agent airflow.providers.common.ai.operators.document_loader airflow.providers.common.ai.operators.llamaindex_embedding airflow.providers.common.ai.operators.llamaindex_retrieval airflow.providers.common.ai.operators.llm airflow.providers.common.ai.operators.llm_batch airflow.providers.common.ai.operators.llm_branch airflow.providers.common.ai.operators.llm_file_analysis airflow.providers.common.ai.operators.llm_schema_compare airflow.providers.common.ai.operators.llm_sql airflow.providers.common.ai.plugins airflow.providers.common.ai.plugins.hitl_review airflow.providers.common.ai.policies airflow.providers.common.ai.policies.decision airflow.providers.common.ai.policies.retry airflow.providers.common.ai.sandbox airflow.providers.common.ai.sandbox.base airflow.providers.common.ai.sandbox.modal airflow.providers.common.ai.sandbox.opensandbox 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.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_modal tests.system.common.ai.example_sandbox_toolset_opensandbox tests.system.common.ai.example_sandbox_toolset_sbx

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

N

name (airflow.providers.common.ai.batch.anthropic.AnthropicBatchAdapter attribute) (airflow.providers.common.ai.batch.base.BatchAdapter attribute) (airflow.providers.common.ai.batch.openai.OpenAIBatchAdapter attribute) (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.DeliverableStatus attribute) (airflow.providers.common.ai.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.sandbox.base.SandboxBackend attribute) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend attribute) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend 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) network (airflow.providers.common.ai.sandbox.base.AttachedSandbox attribute) NETWORK_TAG (in module airflow.providers.common.ai.sandbox.base) next_step() (airflow.providers.common.ai.durable.step_counter.DurableStepCounter method) normalize_assigned_users() (in module airflow.providers.common.ai.mixins.approval) 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_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_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) operator_extra_links (airflow.providers.common.ai.operators.agent.AgentOperator attribute) out_of_range_result_count (airflow.providers.common.ai.batch.results.MergeDiagnostics attribute) output_schema_digest (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) output_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) 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) 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) 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.opensandbox.OpenSandboxBackend 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_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) 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) regenerate_with_feedback() (airflow.providers.common.ai.mixins.hitl_review.HITLReviewMixin method) (airflow.providers.common.ai.operators.agent.AgentOperator method) register_adapter() (in module airflow.providers.common.ai.batch.dispatch) rehydrate_pydantic_output() (in module airflow.providers.common.ai.utils.output_type) REJECT (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin attribute) reject_sequence_with_unsupported_feature() (in module airflow.providers.common.ai.utils.validation) REJECTED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) release() (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)

replay_usage (airflow.providers.common.ai.durable.caching_model.CachingModel attribute) (airflow.providers.common.ai.durable.caching_toolset.CachingToolset attribute) replayable (airflow.providers.common.ai.toolsets.managed_agent.BaseManagedAgentToolset attribute) (airflow.providers.common.ai.toolsets.managed_agent.ManagedAgentToolset attribute) replayed_model (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) replayed_tool (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) ReplayUsageLedger (class in airflow.providers.common.ai.durable.replay_usage) repo_url (airflow.providers.common.ai.skills.GitSkills attribute) REPORT_SYSTEM_PROMPT (in module airflow.providers.common.ai.example_dags.example_langchain_tool_agent) request() (airflow.providers.common.ai.durable.caching_model.CachingModel method) request_count (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) request_params (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) requests (airflow.providers.common.ai.operators.llm_batch.LLMBatchOperator attribute) require_approval (airflow.providers.common.ai.operators.llm.LLMOperator attribute) resolve_adapter_name() (in module airflow.providers.common.ai.batch.dispatch) resolve_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_ABOVE (in module airflow.providers.common.ai.example_dags.example_decision_model) review_reason() (in module airflow.providers.common.ai.utils.decision) ReviewReason (in module airflow.providers.common.ai.utils.decision) reviews (airflow.providers.common.ai.policies.decision.DecisionPolicy property) REVIEWS (in module airflow.providers.common.ai.example_dags.example_llm_batch) role (airflow.providers.common.ai.utils.hitl_review.ConversationEntry attribute) row_count (airflow.providers.common.ai.example_dags.example_agent.Analysis attribute) run() (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger method) run_agent_sync() (airflow.providers.common.ai.mixins.cancellable_run.CancellableAgentRunMixin method) run_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.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend 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_usage (airflow.providers.common.ai.durable.replay_usage.ReplayUsageLedger attribute)

S

S3Hook (in module airflow.providers.common.ai.example_dags.example_hook_toolset) 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.utils.usage_budget.TaskStateStoreUsageBudget method) save_model_response() (airflow.providers.common.ai.durable.base.DurableStorageProtocol method) (airflow.providers.common.ai.durable.storage.DurableStorage method) (airflow.providers.common.ai.durable.task_state_store.TaskStateStoreDurableStorage method) save_tool_result() (airflow.providers.common.ai.durable.base.DurableStorageProtocol method) (airflow.providers.common.ai.durable.storage.DurableStorage method) (airflow.providers.common.ai.durable.task_state_store.TaskStateStoreDurableStorage method) SbxSandboxBackend (class in airflow.providers.common.ai.sandbox.sbx) SCHEDULED_PROMPT (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) schema_context (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) schema_name (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute) schema_version (airflow.providers.common.ai.batch.state.BatchStateRecord attribute) SCHEMA_VERSION (in module airflow.providers.common.ai.batch.state) SchemaCompareResult (class in airflow.providers.common.ai.operators.llm_schema_compare) SchemaMismatch (class in airflow.providers.common.ai.operators.llm_schema_compare) search_github_prs() (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) SECTION (in module airflow.providers.common.ai.durable.storage) (in module airflow.providers.common.ai.observability) Sentiment (class in airflow.providers.common.ai.example_dags.example_llm_batch) serialize() (airflow.providers.common.ai.triggers.llm_batch.LLMBatchTrigger method) serialize_for_llm() (in module airflow.providers.common.ai.utils.tool_definition) serialize_output (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) 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) should_retry (airflow.providers.common.ai.policies.retry.ErrorClassification attribute) size_bytes (airflow.providers.common.ai.sandbox.base.SandboxFileTooLargeError attribute) SKILLS_DIR (in module airflow.providers.common.ai.example_dags.example_agent_skills) (in module airflow.providers.common.ai.example_dags.example_aip_progress_tracker) SkillSource (in module airflow.providers.common.ai.skills) skipped_model (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) skipped_tools (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) SMTP_CONN_ID (in module airflow.providers.common.ai.example_dags.example_llm_survey_analysis) source (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) source_bytes (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) source_conn_id (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) source_path (airflow.providers.common.ai.operators.document_loader.DocumentLoaderOperator attribute) source_type (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) spec_summary (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.AIPStatus attribute) split_model_id() (in module airflow.providers.common.ai.batch.dispatch) SQL_SYSTEM_PROMPT (in module airflow.providers.common.ai.example_dags.example_llm_survey_agentic) SQLSafetyError SQLToolset (class in airflow.providers.common.ai.toolsets.sql) (in module airflow.providers.common.ai.example_dags.example_agent) (in module airflow.providers.common.ai.example_dags.example_agent_capabilities) (in module airflow.providers.common.ai.example_dags.example_agent_durable) (in module airflow.providers.common.ai.example_dags.example_agent_skills) (in module airflow.providers.common.ai.example_dags.example_sandbox_toolset) (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) STATE_PATH (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_sbx) status (airflow.providers.common.ai.batch.base.BatchState attribute) (airflow.providers.common.ai.example_dags.example_aip_progress_tracker.DeliverableStatus attribute) (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) STATUS_CANCELLED (in module airflow.providers.common.ai.batch.results) STATUS_ERROR (in module airflow.providers.common.ai.batch.results) STATUS_EXPIRED (in module airflow.providers.common.ai.batch.results) STATUS_INVALID_OUTPUT (in module airflow.providers.common.ai.batch.results) STATUS_MISSING (in module airflow.providers.common.ai.batch.results) STATUS_SUCCESS (in module airflow.providers.common.ai.batch.results) stderr (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) stderr_truncated (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) stdout (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) stdout_truncated (airflow.providers.common.ai.sandbox.base.SandboxExecResult attribute) storage (airflow.providers.common.ai.durable.caching_model.CachingModel attribute) (airflow.providers.common.ai.durable.caching_toolset.CachingToolset attribute) stream_results_to_jsonl() (in module airflow.providers.common.ai.batch.results) 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) 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) 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_modal) (in module tests.system.common.ai.example_sandbox_toolset_opensandbox) (in module tests.system.common.ai.example_sandbox_toolset_sbx) tests.system.common.ai module tests.system.common.ai.example_sandbox_toolset_modal module tests.system.common.ai.example_sandbox_toolset_opensandbox 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_prefix (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) TOOL_RESULT_SENTINEL (in module airflow.providers.common.ai.durable.base) ToolApprovalAlreadyRequestedError ToolApprovalError ToolCallError ToolProvider (class in airflow.providers.common.ai.tools) ToolResult (class in airflow.providers.common.ai.tools) tools (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) total_steps (airflow.providers.common.ai.durable.step_counter.DurableStepCounter property) trace (airflow.providers.common.ai.managed_agents.base.ManagedAgentCapabilities attribute) trace_ref (airflow.providers.common.ai.managed_agents.base.ManagedAgentResponse attribute) 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.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) user_content (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute)

V

validate_approval_prompt() (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol method) (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin method) validate_decision_policy() (in module airflow.providers.common.ai.utils.decision) validate_extracted_output() (in module airflow.providers.common.ai.batch.output_schema) validate_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) version (airflow.providers.common.ai.managed_agents.base.ManagedAgentRef attribute)

W

workdir (airflow.providers.common.ai.sandbox.base.AttachedSandbox attribute) WORKDIR_TAG (in module airflow.providers.common.ai.sandbox.base) wrap_toolsets_for_logging() (in module airflow.providers.common.ai.utils.logging) wrapped (airflow.providers.common.ai.batch.output_schema.OutputSpec attribute) WRITE_FILE (in module airflow.providers.common.ai.toolsets.sandbox) write_file() (airflow.providers.common.ai.sandbox.base.SandboxBackend method) (airflow.providers.common.ai.sandbox.modal.ModalSandboxBackend method) (airflow.providers.common.ai.sandbox.opensandbox.OpenSandboxBackend 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?