diff --git a/library/database/riak b/library/database/riak
index 3ead6c4baad..5fbe8d92de6 100644
--- a/library/database/riak
+++ b/library/database/riak
@@ -91,13 +91,6 @@ import json
 import time
 
 
-def is_number(s):
-    try:
-        float(s)
-        return True
-    except ValueError:
-        return False
-
 def ring_check():
     rc, out, err = module.run_command('riak-admin ringready 2> /dev/null')
     if rc == 0 and out.find('TRUE All nodes agree on the ring') != -1:
@@ -105,45 +98,6 @@ def ring_check():
     else:
         return False
 
-def status_to_json():
-    # remove all unnecessary symbols and whitespace
-    stats = ''
-    rc, out, err = module.run_command("riak-admin status 2> /dev/null")
-    if rc == 0:
-        raw_stats = out
-    else:
-        module.fail_json(msg="Could not properly gather stats")
-
-    for line in raw_stats.splitlines():
-        stats += line.strip() + '\n'
-
-    stats = stats.replace('<<', '').replace('>>', '')
-    stats = stats.replace('\\n', '').replace(',\n', ',')
-    stats = stats.replace(": '", ': ').replace("'\n", "\n")
-    stats = stats.replace(': "[', ': [').replace(']"\n', "]\n")
-
-    stats = stats.replace('"', "'")
-
-    matchObj = re.compile(r"^(.*) : (.*)", re.M | re.I)
-
-    json_stats = '{'
-
-    for match in matchObj.finditer(stats):
-        key, value = match.groups()
-
-        if (value[0] == "'"):
-            value = value[1:-1]
-
-        if not is_number(value):
-            value = '"' + value + '"'
-        json_stats += '"' + key + '":' + value + ','
-
-    json_stats = json_stats[0:-1]
-    json_stats += '}'
-
-    return json_stats
-
-
 def main():
 
     ansible_facts = {}
@@ -153,8 +107,8 @@ def main():
         config_dir=dict(default='/etc/riak'),
         http_conn=dict(required=False, default='127.0.0.1:8098'),
         target_node=dict(default='riak@127.0.0.1', required=False),
-        wait_for_handoffs=dict(default=False, type='bool'),
-        wait_for_ring=dict(default=False, type='bool'),
+        wait_for_handoffs=dict(default=None, type='bool'),
+        wait_for_ring=dict(default=None, type='bool'),
         wait_for_service=dict(
             required=False, default=None, choices=['kv'])
     )
@@ -187,24 +141,33 @@ def main():
     else:
         module.fail_json(msg='Could not determine Riak version')
 
-    try:
-        stats_raw = urllib2.urlopen(
-            'http://%s/stats' % (http_conn), None, 5).read()
-    except urllib2.HTTPError, e:
-        stats_raw = status_to_json()
-    except urllib2.URLError, e:
-        stats_raw = status_to_json()
-    except Exception, e:
-        stats_raw = status_to_json()
+# here we attempt to get stats from the http stats interface for 120 seconds.
+    timeout = time.time() + 120
+    while True:
+        if time.time () > timeout:
+            module.fail_json(msg='Timeout, could not fetch Riak stats.')
+        try:
+            stats_raw = urllib2.urlopen(
+                'http://%s/stats' % (http_conn), None, 5).read()
+            break
+        except urllib2.HTTPError, e:
+            time.sleep(5)
+        except urllib2.URLError, e:
+            time.sleep(5)
+        except Exception, e:
+            module.fail_json(msg='Could not fetch Riak stats: %s' % e)
 
-    stats = json.loads(stats_raw)
+# here we attempt to load those stats,
+    try:
+        stats = json.loads(stats_raw)
+    except:
+        module.fail_json(msg='Timeout, could not parse Riak stats.')
 
     node_name = stats['nodename']
     nodes = stats['ring_members']
     ring_size = stats['ring_creation_size']
 
 
-
     result = {'node_name': node_name,
               'nodes': nodes,
               'ring_size': ring_size,