This is an automated email from the ASF dual-hosted git repository.
gopidesupavan pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 08655577b32 Document LLMFileAnalysisOperator's inherited LLM and HITL
parameters (#71856)
08655577b32 is described below
commit 08655577b32b29a38ca28b07fdf8007fe22c889b
Author: Jyun-An Chen <[email protected]>
AuthorDate: Sun Aug 23 18:58:29 2026 +0800
Document LLMFileAnalysisOperator's inherited LLM and HITL parameters
(#71856)
model_id, system_prompt, agent_params, and the require_approval /
approval_timeout / allow_modifications trio are fully supported here
but undocumented in the docstrings, unlike every sibling operator
(LLMSQLQueryOperator, LLMBranchOperator, LLMSchemaCompareOperator),
which document them and show a require_approval example.
---
.../common/ai/docs/operators/llm_file_analysis.rst | 12 ++++++++++++
.../common/ai/decorators/llm_file_analysis.py | 13 ++++++++++++-
.../ai/example_dags/example_llm_file_analysis.py | 22 ++++++++++++++++++++++
.../common/ai/operators/llm_file_analysis.py | 12 ++++++++++++
4 files changed, 58 insertions(+), 1 deletion(-)
diff --git a/providers/common/ai/docs/operators/llm_file_analysis.rst
b/providers/common/ai/docs/operators/llm_file_analysis.rst
index c60435aa906..bb019e2b6a0 100644
--- a/providers/common/ai/docs/operators/llm_file_analysis.rst
+++ b/providers/common/ai/docs/operators/llm_file_analysis.rst
@@ -111,6 +111,18 @@ returns the prompt string; file settings are passed to the
decorator:
:start-after: [START howto_decorator_llm_file_analysis]
:end-before: [END howto_decorator_llm_file_analysis]
+Human-in-the-Loop Approval
+---------------------------
+
+Set ``require_approval=True`` to pause the task after the analysis and wait
+for a human reviewer to approve the output before it is returned.
+When ``allow_modifications=True``, the reviewer can also edit the output:
+
+.. exampleinclude::
/../../ai/src/airflow/providers/common/ai/example_dags/example_llm_file_analysis.py
+ :language: python
+ :start-after: [START howto_operator_llm_file_analysis_approval]
+ :end-before: [END howto_operator_llm_file_analysis_approval]
+
Parameters
----------
diff --git
a/providers/common/ai/src/airflow/providers/common/ai/decorators/llm_file_analysis.py
b/providers/common/ai/src/airflow/providers/common/ai/decorators/llm_file_analysis.py
index 1ad569d8105..e6ad0fcf2bd 100644
---
a/providers/common/ai/src/airflow/providers/common/ai/decorators/llm_file_analysis.py
+++
b/providers/common/ai/src/airflow/providers/common/ai/decorators/llm_file_analysis.py
@@ -36,7 +36,18 @@ if TYPE_CHECKING:
class _LLMFileAnalysisDecoratedOperator(DecoratedOperator,
LLMFileAnalysisOperator):
- """Wrap a callable that returns the prompt string for file analysis."""
+ """
+ Wraps a callable that returns a prompt for LLM-backed file analysis.
+
+ The user function is called at execution time to produce the prompt string.
+ All other parameters (``llm_conn_id``, ``file_path``, ``multi_modal``,
etc.)
+ are passed through to
+
:class:`~airflow.providers.common.ai.operators.llm_file_analysis.LLMFileAnalysisOperator`.
+
+ :param python_callable: A reference to a callable that returns the prompt
string.
+ :param op_args: Positional arguments for the callable.
+ :param op_kwargs: Keyword arguments for the callable.
+ """
template_fields: Sequence[str] = (
*DecoratedOperator.template_fields,
diff --git
a/providers/common/ai/src/airflow/providers/common/ai/example_dags/example_llm_file_analysis.py
b/providers/common/ai/src/airflow/providers/common/ai/example_dags/example_llm_file_analysis.py
index d1983d14846..27a368479e7 100644
---
a/providers/common/ai/src/airflow/providers/common/ai/example_dags/example_llm_file_analysis.py
+++
b/providers/common/ai/src/airflow/providers/common/ai/example_dags/example_llm_file_analysis.py
@@ -119,6 +119,28 @@ def example_llm_file_analysis_structured():
example_llm_file_analysis_structured()
+# [START howto_operator_llm_file_analysis_approval]
+@dag(tags=["example"])
+def example_llm_file_analysis_approval():
+ from datetime import timedelta
+
+ LLMFileAnalysisOperator(
+ task_id="analyze_contract_with_approval",
+ prompt="Summarize the key obligations and flag any unusual termination
clauses.",
+ llm_conn_id="pydanticai_default",
+ file_path="s3://legal/contracts/vendor-agreement.pdf",
+ file_conn_id="aws_default",
+ require_approval=True,
+ approval_timeout=timedelta(hours=1),
+ allow_modifications=True,
+ )
+
+
+# [END howto_operator_llm_file_analysis_approval]
+
+example_llm_file_analysis_approval()
+
+
# [START howto_decorator_llm_file_analysis]
@dag(tags=["example"])
def example_llm_file_analysis_decorator():
diff --git
a/providers/common/ai/src/airflow/providers/common/ai/operators/llm_file_analysis.py
b/providers/common/ai/src/airflow/providers/common/ai/operators/llm_file_analysis.py
index 8e919acf13b..7b757ba22ca 100644
---
a/providers/common/ai/src/airflow/providers/common/ai/operators/llm_file_analysis.py
+++
b/providers/common/ai/src/airflow/providers/common/ai/operators/llm_file_analysis.py
@@ -44,6 +44,12 @@ class LLMFileAnalysisOperator(LLMOperator):
:param prompt: The analysis prompt for the LLM.
:param llm_conn_id: Connection ID for the LLM provider.
+ :param model_id: Model identifier (e.g. ``"openai:gpt-5"``).
+ Overrides the model stored in the connection's extra field.
+ :param system_prompt: Additional instructions appended to the built-in
+ file-analysis system prompt.
+ :param agent_params: Additional keyword arguments passed to the pydantic-ai
+ ``Agent`` constructor (e.g. ``retries``, ``model_settings``,
``tools``).
:param file_path: File or prefix to analyze.
:param file_conn_id: Optional connection ID for the storage backend.
Overrides a connection embedded in ``file_path``.
@@ -62,6 +68,12 @@ class LLMFileAnalysisOperator(LLMOperator):
while ``max_file_size_bytes`` and ``max_total_size_bytes`` limit bytes
read from storage and ``max_text_chars`` limits the final prompt text
budget. Default ``10``.
+
+ Human-in-the-Loop approval parameters are inherited from
+ :class:`~airflow.providers.common.ai.operators.llm.LLMOperator`
+ (``require_approval``, ``approval_timeout``, ``allow_modifications``).
+ The task pauses after the file analysis and only returns the result once a
+ reviewer approves.
"""
template_fields: Sequence[str] = (
