From ab64ae7fe7ac804582352bb3184dd7443a1f831c Mon Sep 17 00:00:00 2001 From: Alexander Kukushkin Date: Mon, 26 Oct 2015 11:29:32 +0100 Subject: [PATCH] execute delete_trigger_file() after successfull call of create_replica() --- patroni/postgresql.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/patroni/postgresql.py b/patroni/postgresql.py index 0b725d78..bb72cb05 100644 --- a/patroni/postgresql.py +++ b/patroni/postgresql.py @@ -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):