ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

Merge pull request #6460 from jsmartin/riak-bugfix

Browse source 
Fixes various typos, fetch_url now working, changed command composure for wait_for_service
This commit is contained in:
James Cammarata 2014-03-12 21:56:39 -05:00
commit bd16cce3e9
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
library/database/riak
View file

@ -124,9 +124,8 @@ def main():
wait_for_handoffs=dict(default=False, type='int'), wait_for_handoffs=dict(default=False, type='int'),
wait_for_ring=dict(default=False, type='int'), wait_for_ring=dict(default=False, type='int'),
wait_for_service=dict( wait_for_service=dict(
required=False, default=None, choices=['kv']) required=False, default=None, choices=['kv']),
), validate_certs = dict(default='yes', type='bool'))
validate_certs = dict(default='yes', type='bool'),
) )
@ -137,6 +136,7 @@ def main():
wait_for_handoffs = module.params.get('wait_for_handoffs') wait_for_handoffs = module.params.get('wait_for_handoffs')
wait_for_ring = module.params.get('wait_for_ring') wait_for_ring = module.params.get('wait_for_ring')
wait_for_service = module.params.get('wait_for_service') wait_for_service = module.params.get('wait_for_service')
validate_certs = module.params.get('validate_certs')
#make sure riak commands are on the path #make sure riak commands are on the path
@ -231,7 +231,7 @@ def main():
module.fail_json(msg='Timeout waiting for handoffs.') module.fail_json(msg='Timeout waiting for handoffs.')
if wait_for_service: if wait_for_service:
cmd = '%s wait_for_service riak_%s %s' % ( riak_admin_bin, wait_for_service, node_name) cmd = [riak_admin_bin, 'wait_for_service', 'riak_%s' % wait_for_service, node_name ]
rc, out, err = module.run_command(cmd) rc, out, err = module.run_command(cmd)
result['service'] = out result['service'] = out
@ -250,5 +250,6 @@ def main():
# import module snippets # import module snippets
from ansible.module_utils.basic import * from ansible.module_utils.basic import *
from ansible.module_utils.urls import *
main() main()