ansible-collections/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2025-04-26 20:31:27 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

Style/docs cleanup, and also improve an error message.

Browse source
This commit is contained in:
Michael DeHaan 2013-08-10 18:58:45 -04:00
parent aeb8649da5
commit f8c97d6e79
3 changed files with 54 additions and 59 deletions
Download patch file Download diff file Expand all files Collapse all files

28
lib/ansible/runner/action_plugins/synchronize.py
View file

@ -26,12 +26,7 @@ class ActionModule(object):
def __init__(self, runner):
self.runner = runner
def _process_origin(
self,
host,
path,
user,
):
def _process_origin(self, host, path, user):
if not host in ['127.0.0.1', 'localhost']:
return '%s@%s:%s' % (user, host, path)
@ -43,16 +38,9 @@ class ActionModule(object):
if inject.get('delegate_to') is None:
inject['delegate_to'] = '127.0.0.1'
def run(
self,
conn,
tmp,
module_name,
module_args,
inject,
complex_args=None,
**kwargs
):
def run(self, conn, tmp, module_name, module_args,
inject, complex_args=None, **kwargs):
''' generates params and passes them on to the rsync module '''
# load up options
@ -77,9 +65,7 @@ class ActionModule(object):
if not dest_host is src_host:
user = inject.get('ansible_ssh_user',
self.runner.remote_user)
private_key = \
inject.get('ansible_ssh_private_key_file',
self.runner.private_key_file)
private_key = inject.get('ansible_ssh_private_key_file', self.runner.private_key_file)
if not private_key is None:
options['private_key'] = private_key
src = self._process_origin(src_host, src, user)
@ -87,10 +73,8 @@ class ActionModule(object):
options['src'] = src
options['dest'] = dest
try:
if 'mode' in options:
del options['mode']
except KeyError:
pass
# run the synchronize module