• Home
• Index

Index

_

__aenter__() (airflow.providers.common.ai.toolsets.mcp.MCPToolset method)

__aexit__() (airflow.providers.common.ai.toolsets.mcp.MCPToolset method) __version__ (in module airflow.providers.common.ai)

A

action (airflow.providers.common.ai.utils.hitl_review.HumanActionData attribute) agent_params (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) agent_task() (in module airflow.providers.common.ai.decorators.agent) AgentOperator (class in airflow.providers.common.ai.operators.agent) AgentSessionData (class in airflow.providers.common.ai.utils.hitl_review) airflow.providers.common.ai module airflow.providers.common.ai.decorators module airflow.providers.common.ai.decorators.agent module airflow.providers.common.ai.decorators.llm module airflow.providers.common.ai.decorators.llm_branch module airflow.providers.common.ai.decorators.llm_file_analysis module airflow.providers.common.ai.decorators.llm_schema_compare module airflow.providers.common.ai.decorators.llm_sql module airflow.providers.common.ai.durable module airflow.providers.common.ai.durable.caching_model module airflow.providers.common.ai.durable.caching_toolset module airflow.providers.common.ai.durable.step_counter module airflow.providers.common.ai.durable.storage module airflow.providers.common.ai.example_dags module airflow.providers.common.ai.example_dags.example_agent module airflow.providers.common.ai.example_dags.example_agent_durable module airflow.providers.common.ai.example_dags.example_llm module airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline module airflow.providers.common.ai.example_dags.example_llm_branch module airflow.providers.common.ai.example_dags.example_llm_classification module airflow.providers.common.ai.example_dags.example_llm_file_analysis module airflow.providers.common.ai.example_dags.example_llm_schema_compare module airflow.providers.common.ai.example_dags.example_llm_sql module airflow.providers.common.ai.example_dags.example_mcp module airflow.providers.common.ai.example_dags.example_pydantic_ai_hook module airflow.providers.common.ai.exceptions module airflow.providers.common.ai.get_provider_info module airflow.providers.common.ai.hooks module

airflow.providers.common.ai.hooks.mcp module airflow.providers.common.ai.hooks.pydantic_ai module airflow.providers.common.ai.mixins module airflow.providers.common.ai.mixins.approval module airflow.providers.common.ai.mixins.hitl_review module airflow.providers.common.ai.operators module airflow.providers.common.ai.operators.agent module airflow.providers.common.ai.operators.llm module airflow.providers.common.ai.operators.llm_branch module airflow.providers.common.ai.operators.llm_file_analysis module airflow.providers.common.ai.operators.llm_schema_compare module airflow.providers.common.ai.operators.llm_sql module airflow.providers.common.ai.plugins module airflow.providers.common.ai.plugins.hitl_review module airflow.providers.common.ai.toolsets module airflow.providers.common.ai.toolsets.datafusion module airflow.providers.common.ai.toolsets.hook module airflow.providers.common.ai.toolsets.logging module airflow.providers.common.ai.toolsets.mcp module airflow.providers.common.ai.toolsets.sql module airflow.providers.common.ai.triggers module airflow.providers.common.ai.utils module airflow.providers.common.ai.utils.file_analysis module airflow.providers.common.ai.utils.hitl_review module airflow.providers.common.ai.utils.logging module airflow.providers.common.ai.utils.sql_validation module 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) 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) approve_session() (in module airflow.providers.common.ai.plugins.hitl_review) APPROVED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) attachment_count (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute)

B

build_file_analysis_request() (in module airflow.providers.common.ai.utils.file_analysis)

C

cached_model (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) cached_tool (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) CachingModel (class in airflow.providers.common.ai.durable.caching_model) CachingToolset (class in airflow.providers.common.ai.durable.caching_toolset) call_tool() (airflow.providers.common.ai.durable.caching_toolset.CachingToolset method) (airflow.providers.common.ai.toolsets.datafusion.DataFusionToolset method) (airflow.providers.common.ai.toolsets.hook.HookToolset method) (airflow.providers.common.ai.toolsets.logging.LoggingToolset method) (airflow.providers.common.ai.toolsets.mcp.MCPToolset method) (airflow.providers.common.ai.toolsets.sql.SQLToolset method) CHANGES_REQUESTED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) cleanup() (airflow.providers.common.ai.durable.storage.DurableStorage method) column (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) compatible (airflow.providers.common.ai.operators.llm_schema_compare.SchemaCompareResult attribute) conn_name_attr (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute)

conn_type (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIAzureHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIBedrockHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIVertexHook attribute) content (airflow.providers.common.ai.utils.hitl_review.ConversationEntry attribute) context_strategy (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) conversation (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) ConversationEntry (class in airflow.providers.common.ai.utils.hitl_review) counter (airflow.providers.common.ai.durable.caching_model.CachingModel attribute) (airflow.providers.common.ai.durable.caching_toolset.CachingToolset attribute) create_agent() (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook method) current_output (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute)

D

dag_id (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) data_sources (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) DataFusionToolset (class in airflow.providers.common.ai.toolsets.datafusion) datasource_config (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) db_conn_id (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) db_conn_ids (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) db_hook (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator property) DEFAULT_ALLOWED_TYPES (in module airflow.providers.common.ai.utils.sql_validation) default_conn_name (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_SYSTEM_PROMPT (in module airflow.providers.common.ai.operators.llm_schema_compare) 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) description (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) detect_file_format() (in module airflow.providers.common.ai.utils.file_analysis) dialect (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) durable (airflow.providers.common.ai.operators.agent.AgentOperator attribute) DurableStepCounter (class in airflow.providers.common.ai.durable.step_counter) DurableStorage (class in airflow.providers.common.ai.durable.storage)

E

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) 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_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_structured_output() (in module airflow.providers.common.ai.example_dags.example_agent) example_llm_analysis_pipeline() (in module airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline) example_llm_branch_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_decorator_multi() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_multi() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_branch_operator() (in module airflow.providers.common.ai.example_dags.example_llm_branch) example_llm_classification() (in module airflow.providers.common.ai.example_dags.example_llm_classification) example_llm_decorator() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_decorator_structured() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_file_analysis_basic() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_multimodal() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_prefix() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_file_analysis_structured() (in module airflow.providers.common.ai.example_dags.example_llm_file_analysis) example_llm_operator() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_agent_params() (in module airflow.providers.common.ai.example_dags.example_llm)

example_llm_operator_approval() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_operator_structured() (in module airflow.providers.common.ai.example_dags.example_llm) example_llm_schema_compare_basic() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_conditional() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_full_context() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_schema_compare_with_object_storage() (in module airflow.providers.common.ai.example_dags.example_llm_schema_compare) example_llm_sql_approval() (in module airflow.providers.common.ai.example_dags.example_llm_sql) example_llm_sql_basic() (in module airflow.providers.common.ai.example_dags.example_llm_sql) example_llm_sql_decorator() (in module airflow.providers.common.ai.example_dags.example_llm_sql) example_llm_sql_expand() (in module airflow.providers.common.ai.example_dags.example_llm_sql) example_llm_sql_schema_introspection() (in module airflow.providers.common.ai.example_dags.example_llm_sql) example_llm_sql_with_object_storage() (in module airflow.providers.common.ai.example_dags.example_llm_sql) example_mcp_multiple_servers() (in module airflow.providers.common.ai.example_dags.example_mcp) example_mcp_toolset() (in module airflow.providers.common.ai.example_dags.example_mcp) example_pydantic_ai_hook() (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_hook) example_pydantic_ai_structured_output() (in module airflow.providers.common.ai.example_dags.example_pydantic_ai_hook) 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.llm.LLMOperator method) (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator method) (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator method) (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator method) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator method) execute_complete() (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin method) (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator method) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator method)

F

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) file_conn_id (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute)

file_path (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) FileAnalysisRequest (class in airflow.providers.common.ai.utils.file_analysis) find_session() (in module airflow.providers.common.ai.plugins.hitl_review) from_xcom() (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse static method)

G

get_conn() (airflow.providers.common.ai.hooks.mcp.MCPHook method) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook method) get_link() (airflow.providers.common.ai.operators.agent.HITLReviewLink method) get_provider_info() (in module airflow.providers.common.ai.get_provider_info) get_tools() (airflow.providers.common.ai.toolsets.datafusion.DataFusionToolset method) (airflow.providers.common.ai.toolsets.hook.HookToolset method) (airflow.providers.common.ai.toolsets.mcp.MCPToolset method) (airflow.providers.common.ai.toolsets.sql.SQLToolset method)

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

H

health() (in module airflow.providers.common.ai.plugins.hitl_review) hitl_poll_interval (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) hitl_review_app (in module airflow.providers.common.ai.plugins.hitl_review) hitl_timeout (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) HITLMaxIterationsError HITLReviewLink (class in airflow.providers.common.ai.operators.agent) HITLReviewMixin (class in airflow.providers.common.ai.mixins.hitl_review) HITLReviewPlugin (class in airflow.providers.common.ai.plugins.hitl_review)

HITLReviewProtocol (class in airflow.providers.common.ai.mixins.hitl_review) HITLReviewResponse (class in airflow.providers.common.ai.utils.hitl_review) hook_name (airflow.providers.common.ai.hooks.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) HumanActionData (class in airflow.providers.common.ai.utils.hitl_review) HumanActionType (in module airflow.providers.common.ai.utils.hitl_review) HumanFeedbackRequest (class in airflow.providers.common.ai.utils.hitl_review)

I

id (airflow.providers.common.ai.toolsets.datafusion.DataFusionToolset property) (airflow.providers.common.ai.toolsets.hook.HookToolset property) (airflow.providers.common.ai.toolsets.mcp.MCPToolset property) (airflow.providers.common.ai.toolsets.sql.SQLToolset property)

inherits_from_skipmixin (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator attribute) 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)

L

llm_branch_task() (in module airflow.providers.common.ai.decorators.llm_branch) llm_conn_id (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) 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_schema_compare_task() (in module airflow.providers.common.ai.decorators.llm_schema_compare) llm_sql_task() (in module airflow.providers.common.ai.decorators.llm_sql) llm_task() (in module airflow.providers.common.ai.decorators.llm) LLMApprovalMixin (class in airflow.providers.common.ai.mixins.approval) LLMBranchOperator (class in airflow.providers.common.ai.operators.llm_branch) LLMFileAnalysisError LLMFileAnalysisLimitExceededError LLMFileAnalysisMultimodalRequiredError LLMFileAnalysisOperator (class in airflow.providers.common.ai.operators.llm_file_analysis) LLMFileAnalysisUnsupportedFormatError

LLMOperator (class in airflow.providers.common.ai.operators.llm) LLMSchemaCompareOperator (class in airflow.providers.common.ai.operators.llm_schema_compare) LLMSQLQueryOperator (class in airflow.providers.common.ai.operators.llm_sql) load_model_response() (airflow.providers.common.ai.durable.storage.DurableStorage method) load_tool_result() (airflow.providers.common.ai.durable.storage.DurableStorage method) log (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (in module airflow.providers.common.ai.durable.caching_model) (in module airflow.providers.common.ai.durable.caching_toolset) (in module airflow.providers.common.ai.durable.storage) (in module airflow.providers.common.ai.mixins.approval) (in module airflow.providers.common.ai.mixins.hitl_review) (in module airflow.providers.common.ai.plugins.hitl_review) (in module airflow.providers.common.ai.toolsets.datafusion) (in module airflow.providers.common.ai.utils.file_analysis) log_run_summary() (in module airflow.providers.common.ai.utils.logging) logger (airflow.providers.common.ai.toolsets.logging.LoggingToolset attribute) LoggingToolset (class in airflow.providers.common.ai.toolsets.logging)

M

MapIndexDep (in module airflow.providers.common.ai.plugins.hitl_review) max_file_size_bytes (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) max_files (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) max_hitl_iterations (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) max_iterations (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) MAX_ITERATIONS_EXCEEDED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) max_text_chars (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) max_total_size_bytes (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) mcp_conn_id (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) MCPHook (class in airflow.providers.common.ai.hooks.mcp) MCPToolset (class in airflow.providers.common.ai.toolsets.mcp) migration_query (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) mismatches (airflow.providers.common.ai.operators.llm_schema_compare.SchemaCompareResult attribute) model_id (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) module airflow.providers.common.ai airflow.providers.common.ai.decorators airflow.providers.common.ai.decorators.agent airflow.providers.common.ai.decorators.llm airflow.providers.common.ai.decorators.llm_branch airflow.providers.common.ai.decorators.llm_file_analysis airflow.providers.common.ai.decorators.llm_schema_compare airflow.providers.common.ai.decorators.llm_sql airflow.providers.common.ai.durable airflow.providers.common.ai.durable.caching_model airflow.providers.common.ai.durable.caching_toolset airflow.providers.common.ai.durable.step_counter airflow.providers.common.ai.durable.storage airflow.providers.common.ai.example_dags airflow.providers.common.ai.example_dags.example_agent airflow.providers.common.ai.example_dags.example_agent_durable airflow.providers.common.ai.example_dags.example_llm airflow.providers.common.ai.example_dags.example_llm_analysis_pipeline airflow.providers.common.ai.example_dags.example_llm_branch airflow.providers.common.ai.example_dags.example_llm_classification airflow.providers.common.ai.example_dags.example_llm_file_analysis airflow.providers.common.ai.example_dags.example_llm_schema_compare airflow.providers.common.ai.example_dags.example_llm_sql airflow.providers.common.ai.example_dags.example_mcp airflow.providers.common.ai.example_dags.example_pydantic_ai_hook airflow.providers.common.ai.exceptions airflow.providers.common.ai.get_provider_info airflow.providers.common.ai.hooks airflow.providers.common.ai.hooks.mcp airflow.providers.common.ai.hooks.pydantic_ai airflow.providers.common.ai.mixins airflow.providers.common.ai.mixins.approval airflow.providers.common.ai.mixins.hitl_review airflow.providers.common.ai.operators airflow.providers.common.ai.operators.agent airflow.providers.common.ai.operators.llm airflow.providers.common.ai.operators.llm_branch airflow.providers.common.ai.operators.llm_file_analysis airflow.providers.common.ai.operators.llm_schema_compare airflow.providers.common.ai.operators.llm_sql airflow.providers.common.ai.plugins airflow.providers.common.ai.plugins.hitl_review airflow.providers.common.ai.toolsets airflow.providers.common.ai.toolsets.datafusion airflow.providers.common.ai.toolsets.hook airflow.providers.common.ai.toolsets.logging airflow.providers.common.ai.toolsets.mcp airflow.providers.common.ai.toolsets.sql airflow.providers.common.ai.triggers airflow.providers.common.ai.utils 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.sql_validation tests.system.common.ai

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

N

name (airflow.providers.common.ai.operators.agent.HITLReviewLink attribute) (airflow.providers.common.ai.plugins.hitl_review.HITLReviewPlugin attribute)

next_step() (airflow.providers.common.ai.durable.step_counter.DurableStepCounter method)

O

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

output_type (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) OutputT (in module airflow.providers.common.ai.hooks.pydantic_ai)

P

PENDING_REVIEW (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) prompt (airflow.providers.common.ai.mixins.approval.DeferForApprovalProtocol attribute) (airflow.providers.common.ai.mixins.hitl_review.HITLReviewProtocol attribute) (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute)

PydanticAIAzureHook (class in airflow.providers.common.ai.hooks.pydantic_ai) PydanticAIBedrockHook (class in airflow.providers.common.ai.hooks.pydantic_ai) PydanticAIHook (class in airflow.providers.common.ai.hooks.pydantic_ai) PydanticAIVertexHook (class in airflow.providers.common.ai.hooks.pydantic_ai)

R

react_apps (airflow.providers.common.ai.plugins.hitl_review.HITLReviewPlugin attribute) regenerate_with_feedback() (airflow.providers.common.ai.mixins.hitl_review.HITLReviewMixin method) (airflow.providers.common.ai.operators.agent.AgentOperator method) REJECT (airflow.providers.common.ai.mixins.approval.LLMApprovalMixin attribute) reject_session() (in module airflow.providers.common.ai.plugins.hitl_review) REJECTED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) replayed_model (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute)

replayed_tool (airflow.providers.common.ai.durable.step_counter.DurableStepCounter attribute) request() (airflow.providers.common.ai.durable.caching_model.CachingModel method) require_approval (airflow.providers.common.ai.operators.llm.LLMOperator attribute) resolved_paths (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) role (airflow.providers.common.ai.utils.hitl_review.ConversationEntry attribute) run_hitl_review() (airflow.providers.common.ai.mixins.hitl_review.HITLReviewMixin method) run_id (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute)

S

sample_rows (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) save_model_response() (airflow.providers.common.ai.durable.storage.DurableStorage method) save_tool_result() (airflow.providers.common.ai.durable.storage.DurableStorage method) schema_context (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) SchemaCompareResult (class in airflow.providers.common.ai.operators.llm_schema_compare) SchemaMismatch (class in airflow.providers.common.ai.operators.llm_schema_compare) SECTION (in module airflow.providers.common.ai.durable.storage) SessionDep (in module airflow.providers.common.ai.plugins.hitl_review) SessionStatus (class in airflow.providers.common.ai.utils.hitl_review) severity (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) source (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) source_type (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute)

SQLSafetyError SQLToolset (class in airflow.providers.common.ai.toolsets.sql) status (airflow.providers.common.ai.utils.hitl_review.AgentSessionData attribute) (airflow.providers.common.ai.utils.hitl_review.HITLReviewResponse attribute) storage (airflow.providers.common.ai.durable.caching_model.CachingModel attribute) (airflow.providers.common.ai.durable.caching_toolset.CachingToolset attribute) submit_feedback() (in module airflow.providers.common.ai.plugins.hitl_review) suggested_action (airflow.providers.common.ai.operators.llm_schema_compare.SchemaMismatch attribute) summary (airflow.providers.common.ai.operators.llm_schema_compare.SchemaCompareResult attribute) SUPPORTED_FILE_FORMATS (in module airflow.providers.common.ai.utils.file_analysis) system_prompt (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute)

T

table_names (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute) 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) template_fields (airflow.providers.common.ai.operators.agent.AgentOperator attribute) (airflow.providers.common.ai.operators.llm.LLMOperator attribute) (airflow.providers.common.ai.operators.llm_branch.LLMBranchOperator attribute) (airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator attribute) (airflow.providers.common.ai.operators.llm_schema_compare.LLMSchemaCompareOperator attribute) (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute)

test_connection() (airflow.providers.common.ai.hooks.mcp.MCPHook method) (airflow.providers.common.ai.hooks.pydantic_ai.PydanticAIHook method) tests.system.common.ai module text_file_count (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) text_truncated (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) TIMEOUT_EXCEEDED (airflow.providers.common.ai.utils.hitl_review.SessionStatus attribute) timestamp (airflow.providers.common.ai.utils.hitl_review.ConversationEntry attribute) tool_prefix (airflow.providers.common.ai.hooks.mcp.MCPHook attribute) toolsets (airflow.providers.common.ai.operators.agent.AgentOperator attribute) total_size_bytes (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute) total_steps (airflow.providers.common.ai.durable.step_counter.DurableStepCounter property)

U

user_content (airflow.providers.common.ai.utils.file_analysis.FileAnalysisRequest attribute)

V

validate_sql (airflow.providers.common.ai.operators.llm_sql.LLMSQLQueryOperator attribute)

validate_sql() (in module airflow.providers.common.ai.utils.sql_validation)

W

wrap_toolsets_for_logging() (in module airflow.providers.common.ai.utils.logging)

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?