summaryrefslogtreecommitdiff
path: root/bin/ansible-pull
diff options
context:
space:
mode:
authorMichael DeHaan <michael.dehaan@gmail.com>2014-03-16 15:41:17 -0500
committerMichael DeHaan <michael.dehaan@gmail.com>2014-03-16 15:41:17 -0500
commit71977bfe7113964c8f548e284e9c00a46f2bdef4 (patch)
tree2c3293ab388bd22715a61fcf16318a27a4855f52 /bin/ansible-pull
parent69d26d507b33c4bde396396d8d1c81968bd0d25b (diff)
parent1ef8f279b9d24a13b5b6788cca44af07580fb2cb (diff)
downloadansible-71977bfe7113964c8f548e284e9c00a46f2bdef4.tar.gz
Merge pull request #5720 from mschurenko/devel
added random sleep option to ansible-pull
Diffstat (limited to 'bin/ansible-pull')
-rwxr-xr-xbin/ansible-pull17
1 files changed, 16 insertions, 1 deletions
diff --git a/bin/ansible-pull b/bin/ansible-pull
index f9316e5561..dc829dc941 100755
--- a/bin/ansible-pull
+++ b/bin/ansible-pull
@@ -44,6 +44,8 @@ import subprocess
import sys
import datetime
import socket
+import random
+import time
from ansible import utils
from ansible.utils import cmd_functions
from ansible import errors
@@ -102,6 +104,8 @@ def main(args):
help='purge checkout after playbook run')
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')
+ 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,
action='store_true',
help='run the playbook even if the repository could '
@@ -164,7 +168,18 @@ def main(args):
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)
if rc != 0: