cmueller/ansible
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

added random sleep option to ansible-pull

Browse source
This commit is contained in:
Matt 2014-01-22 00:01:51 -08:00
parent 61d283e2ad
commit 1ef8f279b9
1 changed files with 16 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
bin/ansible-pull
View file

@ -44,6 +44,8 @@ import subprocess
import sys import sys
import datetime import datetime
import socket import socket
import random
import time
from ansible import utils from ansible import utils
from ansible.utils import cmd_functions from ansible.utils import cmd_functions
@ -101,6 +103,8 @@ def main(args):
help='purge checkout after playbook run') help='purge checkout after playbook run')
parser.add_option('-o', '--only-if-changed', dest='ifchanged', default=False, action='store_true', parser.add_option('-o', '--only-if-changed', dest='ifchanged', default=False, action='store_true',
help='only run the playbook if the repository has been updated') help='only run the playbook if the repository has been updated')
parser.add_option('-s', '--sleep', dest='sleep', default=None,
help='sleep for random interval (between 0 and n number of seconds) before starting. this is a useful way to disperse git requests')
parser.add_option('-f', '--force', dest='force', default=False, parser.add_option('-f', '--force', dest='force', default=False,
action='store_true', action='store_true',
help='run the playbook even if the repository could ' help='run the playbook even if the repository could '
@ -159,7 +163,18 @@ def main(args):
inv_opts, base_opts, options.module_name, repo_opts inv_opts, base_opts, options.module_name, repo_opts
) )
# RUN THE CHECKOUT COMMAND if options.sleep:
try:
secs = random.randint(0,int(options.sleep));
except ValueError:
parser.error("%s is not a number." % options.sleep)
return 1
print >>sys.stderr, "Sleeping for %d seconds..." % secs
time.sleep(secs);
# RUN THe CHECKOUT COMMAND
rc, out, err = cmd_functions.run_cmd(cmd, live=True) rc, out, err = cmd_functions.run_cmd(cmd, live=True)
if rc != 0: if rc != 0: