You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by sm...@apache.org on 2015/05/26 07:17:50 UTC
ambari git commit: AMBARI-11382.
test_execute_retryable_command_succeed fails intermittently
Repository: ambari
Updated Branches:
refs/heads/trunk 08e920eaf -> d12a79c40
AMBARI-11382. test_execute_retryable_command_succeed fails intermittently
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/d12a79c4
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/d12a79c4
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/d12a79c4
Branch: refs/heads/trunk
Commit: d12a79c4021ef5fbc574e46fb0e4fe99abf05fc0
Parents: 08e920e
Author: Sumit Mohanty <sm...@hortonworks.com>
Authored: Mon May 25 22:17:23 2015 -0700
Committer: Sumit Mohanty <sm...@hortonworks.com>
Committed: Mon May 25 22:17:23 2015 -0700
----------------------------------------------------------------------
ambari-agent/src/main/python/ambari_agent/ActionQueue.py | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/d12a79c4/ambari-agent/src/main/python/ambari_agent/ActionQueue.py
----------------------------------------------------------------------
diff --git a/ambari-agent/src/main/python/ambari_agent/ActionQueue.py b/ambari-agent/src/main/python/ambari_agent/ActionQueue.py
index bdf8767..afb60d4 100644
--- a/ambari-agent/src/main/python/ambari_agent/ActionQueue.py
+++ b/ambari-agent/src/main/python/ambari_agent/ActionQueue.py
@@ -279,7 +279,10 @@ class ActionQueue(threading.Thread):
if isCommandBackground:
return
else:
- status = self.COMPLETED_STATUS if commandresult['exitcode'] == 0 else self.FAILED_STATUS
+ if commandresult['exitcode'] == 0:
+ status = self.COMPLETED_STATUS
+ else:
+ status = self.FAILED_STATUS
if status != self.COMPLETED_STATUS and retryAble == True and maxAttempts > numAttempts:
delay = self.get_retry_delay(delay)