Airflow integration - Pre-built operators for Apache Airflow.
Provides LLMTransformOperator for easy integration into Airflow DAGs.
LLMTransformOperator(*args, **kwargs)
Placeholder when Airflow not installed.
Source code in ondine/integrations/airflow.py
| def __init__(self, *args, **kwargs):
raise ImportError(
"Apache Airflow is required to use LLMTransformOperator. "
"Install with: pip install apache-airflow"
)
|