From 06a7351f2686c82354b264cf587bb3ef5d1b6fbf Mon Sep 17 00:00:00 2001 From: "carey.xu" Date: Thu, 4 Feb 2016 10:31:32 +0800 Subject: bugfix: return success when ansible stuck JIRA: COMPASS-304 Change-Id: Iad3de6582c522b75856421078a704bdf2e17c572 Signed-off-by: carey.xu (cherry picked from commit c1503ab8f0d9772effb562947bc67b860588e0d4) --- deploy/client.py | 20 +++++++++----------- 1 file changed, 9 insertions(+), 11 deletions(-) (limited to 'deploy') diff --git a/deploy/client.py b/deploy/client.py index 0d51ce20..593f9033 100644 --- a/deploy/client.py +++ b/deploy/client.py @@ -852,23 +852,13 @@ class CompassClient(object): def get_installing_progress(self, cluster_id): def _get_installing_progress(): """get intalling progress.""" - action_timeout = time.time() + 60 * float(CONF.action_timeout) - deployment_timeout = time.time() + 60 * float( - CONF.deployment_timeout) - + deployment_timeout = time.time() + 60 * float(CONF.deployment_timeout) current_time = time.time while current_time() < deployment_timeout: status, cluster_state = self.get_cluster_state(cluster_id) if not self.is_ok(status): raise RuntimeError("can not get cluster state") - if cluster_state['state'] in ['UNINITIALIZED', 'INITIALIZED']: - if current_time() >= action_timeout: - raise RuntimeError("installation timeout") - else: - time.sleep(5) - continue - elif cluster_state['state'] == 'SUCCESSFUL': LOG.info( 'get cluster %s state status %s: %s, successful', @@ -880,6 +870,14 @@ class CompassClient(object): 'get cluster %s state status %s: %s, error', (cluster_id, status, cluster_state) ) + + LOG.info("current_time=%s, deployment_timeout=%s" \ + % (current_time(), deployment_timeout)) + time.sleep(5) + + if not current_time() < deployment_timeout: + raise RuntimeError("installation timeout") + try: _get_installing_progress() finally: -- cgit 1.2.3-korg