Command airflow db clean is getting stuck while removing data from dag_version table

[prayaagmahajan]

Hi, I am trying to run

airflow db clean --clean-before-timestamp 2026-01-19T11:51:59 --skip-archive --yes --tables asset_event,callback_request,celery_taskmeta,celery_tasksetmeta,dag,dag_run,deadline,import_error,job,log,sla_miss,task_instance,task_instance_history,task_reschedule,trigger,xcom

but this command is getting stuck at

Checking table dag_version Found 10349 rows meeting deletion criteria. Performing Delete... Moving data to table _airflow_deleted__dag_version__20260120123746

with error sqlalchemy.exc.InvalidRequestError: This session is in 'prepared' state; no further SQL can be emitted within this transaction.

Seeking help with this issue.

[potiuk]

Looks like a bug - which is likely fixed in newer versions of Airflow (you have not specified yours - but you can look at changelogs) - recommendation: upgrade to latest Airflow 3 version.

[prayaagmahajan]

Hi @potiuk, I am using 3.1.3 version of airflow, Is it possible it is been fixed in the latest stable version of airflow?