feat: prevent apply before session in active

2020-02-14 16:02:30 +01:00
parent 65525ca2e1
commit f1020fb072
1 changed files with 5 additions and 4 deletions
@@ -64,15 +64,16 @@ class ApplyTimer(Timer):
        super().__init__(timout)

    def execute(self):
-        if operators.client:
-            nodes = operators.client.list(filter=self._type)
+        client =  operators.client
+        if client and  client.state['STATE'] == STATE_ACTIVE:
+            nodes = client.list(filter=self._type)

            for node in nodes:
-                node_ref = operators.client.get(uuid=node)
+                node_ref = client.get(uuid=node)

                if node_ref.state == FETCHED:
                    try:
-                        operators.client.apply(node)
+                        client.apply(node)
                    except Exception as e:
                        logger.error(
                            "fail to apply {}: {}".format(node_ref.uuid, e))