Kill running queries before migration (#3341)

* Kill running queries before migration * don't cancel self
AudiusProject · Jun 29, 2022 · 9016770 · 9016770
1 parent 6c47cdb
commit 9016770
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/discovery-provider/alembic/versions/38642fb2948d_add_pg_triggers.py b/discovery-provider/alembic/versions/38642fb2948d_add_pg_triggers.py
@@ -26,6 +26,11 @@ def upgrade():
     connection = op.get_bind()
     connection.execute(
         """
+        SELECT pg_cancel_backend(pid)
+        FROM pg_stat_activity 
+        WHERE state != 'idle' AND query NOT ILIKE '%pg_stat_activity%' and pid <> pg_backend_pid() 
+        ORDER BY query_start DESC;
+        
         begin;
             WITH new_plays AS (
                 SELECT