execute delete_trigger_file() after successfull call of create_replica()

2026-08-25 14:53:37 +00:00 · 2015-10-26 11:29:32 +01:00
parent acd21eae4c
commit ab64ae7fe7
1 changed files with 3 additions and 1 deletions
@@ -189,7 +189,9 @@ class Postgresql:
        r = parseurl(leader.conn_url)

        env = self.write_pgpass(r)
-        return self.create_replica(r, env) == 0
+        ret = self.create_replica(r, env) == 0
+        ret and self.delete_trigger_file()
+        return ret

    @staticmethod
    def build_connstring(conn):