Ошибка с вложенной транзакцией

2025-12-10 23:40:27 +03:00
parent a8ac8f62dc
commit d936f204bd
1 changed files with 1 additions and 0 deletions
@@ -61,6 +61,7 @@ with DAG(
        task_id="generate_bookings_day",
        postgres_conn_id=BOOKINGS_CONN_ID,
        sql="src/bookings_generate_day_if_missing.sql",
+        autocommit=True,
    )

    # 2. Загружаем инкремент из stg.bookings_ext в stg.bookings