Skip to content

Instantly share code, notes, and snippets.

@lxneng
Created August 12, 2016 02:57
Show Gist options
  • Save lxneng/63937454a0ef69618614b9f784280d9e to your computer and use it in GitHub Desktop.
Save lxneng/63937454a0ef69618614b9f784280d9e to your computer and use it in GitHub Desktop.
cleanup dag info by sql in postgres db
\set dag_id '''dag002''';
delete from xcom where dag_id = :dag_id;
delete from task_instance where dag_id = :dag_id;
delete from sla_miss where dag_id = :dag_id;
delete from log where dag_id = :dag_id;
delete from job where dag_id = :dag_id;
delete from dag_run where dag_id = :dag_id;
delete from dag where dag_id = :dag_id;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment