fix: update teardown to drop 'pgbelt' replication setl

Autodesk · Feb 2, 2024 · ff62d57 · ff62d57
1 parent 65f21c6
commit ff62d57
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pgbelt/util/pglogical.py b/pgbelt/util/pglogical.py
@@ -206,8 +206,8 @@ async def teardown_replication_set(pool: Pool, logger: Logger) -> None:
     async with pool.acquire() as conn:
         async with conn.transaction():
             try:
-                await conn.execute("SELECT pglogical.drop_replication_set('default');")
-                logger.debug("Replication set 'default' dropped")
+                await conn.execute("SELECT pglogical.drop_replication_set('pgbelt');")
+                logger.debug("Replication set 'pgbelt' dropped")
             except (
                 InvalidSchemaNameError,
                 UndefinedFunctionError,