vikramkoka opened a new pull request, #67615:
URL: https://github.com/apache/airflow/pull/67615
Two example Dags demonstrating multi-company financial research
with LlamaIndex RAG and Dynamic Task Mapping:
- Indexing DAG (weekly): builds per-company vector indexes via
LlamaIndexEmbeddingOperator.partial().expand_kwargs()
- Analysis DAG (manual): HITLEntryOperator -> @task.llm with structured
output (DecomposedQuestion) ->
LlamaIndexRetrievalOperator.partial().expand_kwargs()
fanned out per sub-question -> LLMOperator with UsageLimits +
AnalysisReport
schema -> ApprovalOperator
Showcases DTM where N is decided by the LLM at runtime, HITL bookends,
structured output via Pydantic models, and token budget caps. Includes
five fictional companies with inline 10-K text for self-contained
execution.
<!-- SPDX-License-Identifier: Apache-2.0
https://www.apache.org/licenses/LICENSE-2.0 -->
---
##### Was generative AI tooling used to co-author this PR?
- [ x] Yes (please specify the tool below)
Generated-by: [Claude] following [the
guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions)
---
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
