VACUUM of VACUUM ANALYZE aanroepen terwijl de connectie nog een open transactie heeft. Veel ORM-frameworks (SQLAlchemy, Django ORM, ActiveRecord) openen automatisch een transactie bij de eerste query; VACUUM mag daar niet in worden uitgevoerd.. CREATE DATABASE of DROP DATABASE binnen een BEGIN/COMMIT-blok in een migratiescript. Beide commando's zijn per definitie transactie-onveilig en vereisen AUTOCOMMIT op de verbinding.. ALTER SYSTEM of REINDEX DATABASE worden vanuit een Airflow-taak of dbt-hook aangeroepen terwijl de connection pool de connectie hergebruikt vanuit een eerder opengebleven transactie.. Connection poolers zoals PgBouncer in transaction-mode of session-mode kunnen een connectie teruggeven aan een worker terwijl een vorige transactie niet volledig is afgerond, waardoor de nieuwe DDL-aanroep in een 'vuile' transactiecontext belandt.. Pipeline-scripts die handmatig BEGIN uitvoeren voor data-laadstappen en daarna — zonder tussendoor te committen — een CLUSTER TABLE of VACUUM-aanroep doen als onderdeel van post-load optimalisatie.. dbt-modellen met een `pre-hook` of `post-hook` die een DDL-operatie uitvoert (bijv. ANALYZE of VACUUM) terwijl dbt de modelrun al in een transactie heeft gewikkeld via het standaard transaction wrapper-gedrag.. Azure Database for PostgreSQL Flexible Server met de pgbouncer-extensie in session-pooling mode: wanneer een applicatie een connectie hergebruikt zonder expliciete COMMIT, kan een DDL-commando op de hergebruikte connectie 25001 triggeren.

Stap 1: Controleer of er een actieve transactie op de connectie staat voordat je het DDL-commando uitvoert: `SELECT txid_current_if_assigned();` — geeft NULL terug als er geen transactie actief is. Als er een waarde uitkomt, commit of rollback eerst: `COMMIT;` of `ROLLBACK;`. Stap 2: Stel AUTOCOMMIT in op de connectie voordat je het DDL-commando uitvoert. In psql: `\set AUTOCOMMIT on`. In Python met psycopg2: `conn.autocommit = True` vóór `cursor.execute('VACUUM ...')`. Herstel daarna de instelling als je daarna transacties nodig hebt.. Stap 3: Gebruik voor VACUUM en ANALYZE een aparte, dedicated connectie buiten de connection pool. Open een nieuwe verbinding, voer het commando uit, sluit de verbinding. Dit voorkomt dat de DDL-stap per ongeluk meerijdt op een transactionele poolverbinding.. Stap 4: In dbt — verplaats VACUUM- of ANALYZE-aanroepen naar een `on-run-end` hook op projectniveau in plaats van een `post-hook` op modelniveau. Gebruik `adapter.dispatch` met een macro die de juiste AUTOCOMMIT-context instelt, of gebruik dbt's `{% do run_query(...) %}` met een aparte adapter-connection.. Stap 5: In Airflow — gebruik `PostgresHook` met `autocommit=True` voor DDL-taken: `hook = PostgresHook(postgres_conn_id='...'); hook.run('VACUUM myschema.mytable', autocommit=True)`. Combineer dit niet met `get_conn()` zonder expliciete commit.. Stap 6: Controleer de transactiestatus van alle actieve connecties op de server: `SELECT pid, state, query, xact_start FROM pg_stat_activity WHERE state != 'idle' AND xact_start IS NOT NULL ORDER BY xact_start;` — termineer vastgelopen connecties indien nodig met `SELECT pg_terminate_backend(pid);`. Stap 7: Bij gebruik van CREATE DATABASE — zorg dat de database-URL in je migratiescript direct verbindt met `postgres` of `template1` en dat AUTOCOMMIT actief is. SQLAlchemy-voorbeeld: `engine = create_engine(url, isolation_level='AUTOCOMMIT')`.

Low severityconfiguration

PostgreSQL Error:
25001

Impact

Wanneer dit een schema-migratie blokkeert tijdens een deployment: de DDL-stap mislukt, maar de transactie van eerdere DML-stappen blijft open — downstream tabellen krijgen geen schema-update en queries hierop falen of retourneren verouderde data totdat de connectie handmatig gereset is.

Wanneer een VACUUM of DDL-stap mislukt met 25001, wordt de gehele taak in Airflow of ADF gemarkeerd als failed. Afhankelijk van de retry-policy wacht de pipeline op de volgende poging, maar zonder AUTOCOMMIT-fix zal elke retry dezelfde fout opleveren. Downstream tabellen die afhankelijk zijn van de gefaalde post-load stap (bijv. geoptimaliseerde indexen na CLUSTER) blijven in een inconsistente toestand totdat de pipeline met correcte instellingen opnieuw wordt gedraaid. SLA-impact is direct als de refresh-window kleiner is dan de retry-interval.

What does this error mean?

SQLSTATE 25001 wordt gegenereerd wanneer PostgreSQL een commando ontvangt dat niet binnen een actieve transactie mag worden uitgevoerd. Typische gevallen zijn VACUUM, CREATE DATABASE, CLUSTER en ALTER SYSTEM — commando's die exclusieve toegang tot de database of een tabel vereisen en daarom buiten een transactieblok moeten staan. In een data-pipeline manifesteert dit zich als een plotseling afbrekende migratiestap of een DDL-commando dat de ORM of connection pool automatisch in een BEGIN-blok heeft gewikkeld. De engineer ziet de pipeline hangen of crashen op de DDL-stap, terwijl eerdere DML-stappen in dezelfde connectie nog niet gecommit zijn.

Common causes

1VACUUM of VACUUM ANALYZE aanroepen terwijl de connectie nog een open transactie heeft. Veel ORM-frameworks (SQLAlchemy, Django ORM, ActiveRecord) openen automatisch een transactie bij de eerste query; VACUUM mag daar niet in worden uitgevoerd.
2CREATE DATABASE of DROP DATABASE binnen een BEGIN/COMMIT-blok in een migratiescript. Beide commando's zijn per definitie transactie-onveilig en vereisen AUTOCOMMIT op de verbinding.
3ALTER SYSTEM of REINDEX DATABASE worden vanuit een Airflow-taak of dbt-hook aangeroepen terwijl de connection pool de connectie hergebruikt vanuit een eerder opengebleven transactie.
4Connection poolers zoals PgBouncer in transaction-mode of session-mode kunnen een connectie teruggeven aan een worker terwijl een vorige transactie niet volledig is afgerond, waardoor de nieuwe DDL-aanroep in een 'vuile' transactiecontext belandt.
5Pipeline-scripts die handmatig BEGIN uitvoeren voor data-laadstappen en daarna — zonder tussendoor te committen — een CLUSTER TABLE of VACUUM-aanroep doen als onderdeel van post-load optimalisatie.
6dbt-modellen met een `pre-hook` of `post-hook` die een DDL-operatie uitvoert (bijv. ANALYZE of VACUUM) terwijl dbt de modelrun al in een transactie heeft gewikkeld via het standaard transaction wrapper-gedrag.
7Azure Database for PostgreSQL Flexible Server met de pgbouncer-extensie in session-pooling mode: wanneer een applicatie een connectie hergebruikt zonder expliciete COMMIT, kan een DDL-commando op de hergebruikte connectie 25001 triggeren.

How to fix it

1Stap 1: Controleer of er een actieve transactie op de connectie staat voordat je het DDL-commando uitvoert: `SELECT txid_current_if_assigned();` — geeft NULL terug als er geen transactie actief is. Als er een waarde uitkomt, commit of rollback eerst: `COMMIT;` of `ROLLBACK;`
2Stap 2: Stel AUTOCOMMIT in op de connectie voordat je het DDL-commando uitvoert. In psql: `\set AUTOCOMMIT on`. In Python met psycopg2: `conn.autocommit = True` vóór `cursor.execute('VACUUM ...')`. Herstel daarna de instelling als je daarna transacties nodig hebt.
3Stap 3: Gebruik voor VACUUM en ANALYZE een aparte, dedicated connectie buiten de connection pool. Open een nieuwe verbinding, voer het commando uit, sluit de verbinding. Dit voorkomt dat de DDL-stap per ongeluk meerijdt op een transactionele poolverbinding.
4Stap 4: In dbt — verplaats VACUUM- of ANALYZE-aanroepen naar een `on-run-end` hook op projectniveau in plaats van een `post-hook` op modelniveau. Gebruik `adapter.dispatch` met een macro die de juiste AUTOCOMMIT-context instelt, of gebruik dbt's `{% do run_query(...) %}` met een aparte adapter-connection.
5Stap 5: In Airflow — gebruik `PostgresHook` met `autocommit=True` voor DDL-taken: `hook = PostgresHook(postgres_conn_id='...'); hook.run('VACUUM myschema.mytable', autocommit=True)`. Combineer dit niet met `get_conn()` zonder expliciete commit.
6Stap 6: Controleer de transactiestatus van alle actieve connecties op de server: `SELECT pid, state, query, xact_start FROM pg_stat_activity WHERE state != 'idle' AND xact_start IS NOT NULL ORDER BY xact_start;` — termineer vastgelopen connecties indien nodig met `SELECT pg_terminate_backend(pid);`
7Stap 7: Bij gebruik van CREATE DATABASE — zorg dat de database-URL in je migratiescript direct verbindt met `postgres` of `template1` en dat AUTOCOMMIT actief is. SQLAlchemy-voorbeeld: `engine = create_engine(url, isolation_level='AUTOCOMMIT')`.

Example log output

ERROR:  25001: ERROR:  cannot execute VACUUM inside a transaction block
STATEMENT:  VACUUM ANALYZE myschema.fact_orders
CONTEXT:  PL/pgSQL function maintenance_job() line 12 at SQL statement

Frequently asked questions

Hoe fix ik 25001 'cannot execute VACUUM inside a transaction block'?

Voer VACUUM uit op een connectie met AUTOCOMMIT ingeschakeld. In psycopg2: `conn.autocommit = True` vóór de VACUUM-aanroep. In SQLAlchemy: gebruik `with engine.connect().execution_options(isolation_level='AUTOCOMMIT') as conn: conn.execute(text('VACUUM ...'))`. Zorg dat de VACUUM-aanroep niet in een BEGIN-blok staat.

Hoe voorkom ik 25001 in dbt pipelines?

Verplaats VACUUM- en ANALYZE-commando's uit model-level `post-hook` naar `on-run-end` hooks in `dbt_project.yml`. Gebruik daar een macro die een aparte verbinding opent met AUTOCOMMIT. Alternatief: gebruik dbt's `run-operation` als losse stap buiten de model-run, zodat dbt er geen transactie-wrapper omheen zet.

Waarom geeft mijn Airflow-taak steeds 25001 bij elke retry?

Airflow hergebruikt bij standaard instellingen dezelfde connectie per taak-run. Als de initiële connectie geen AUTOCOMMIT heeft en de retry dat ook niet instelt, blijft elke poging dezelfde fout geven. Fix: gebruik `PostgresHook.run(..., autocommit=True)` of maak de DDL-operatie een aparte Airflow-taak die een verse connectie opent.

Kan ik 25001 negeren en de pipeline gewoon opnieuw draaien?

Nee — zonder de onderliggende oorzaak te fixen zal elke retry dezelfde fout opleveren zolang de connectie in transactie-mode staat. Bovendien kan een openstaande transactie locks houden op de betrokken tabel, waardoor andere queries op die tabel wachten of time-outen. Sluit eerst de hangen connecties via `pg_terminate_backend`, fix dan de AUTOCOMMIT-instelling.

Source · www.postgresql.org/docs/current/errcodes-appendix.html