LLMSQLQueryOperator

В Airflow появился новый декоратор task.llm_sql, который генерирует SQL из запроса на обычном языке.

Вы описываете, какие данные нужны, передаёте схему — и LLM генерирует SQL.

Главное — безопасность: Airflow разбирает SQL в AST и разрешает только

SELECT, UNION, INTERSECT и EXCEPT.

DELETE, DROP, UPDATE и INSERT
блокируются.

Также можно включить

require_approval=True

, чтобы человек проверил SQL перед продолжением DAG.

Сам

@task.llm_sql

запрос не выполняет — только генерирует и валидирует его.

@tldr_data