ansible-collections/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2025-07-24 13:50:22 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 10

Merge pull request #5091 from EspadaV8/5089_assemble_fix

Browse source 
#5089 hack-fix assemble module
This commit is contained in:
jctanner 2013-12-04 10:13:16 -08:00
commit 7aa35d64c2
1 changed files with 7 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

11
lib/ansible/runner/action_plugins/assemble.py
View file

@ -22,6 +22,7 @@ import pipes
import shutil import shutil
import tempfile import tempfile
from ansible import utils from ansible import utils
from ansible.runner.return_data import ReturnData
class ActionModule(object): class ActionModule(object):
@ -70,6 +71,7 @@ class ActionModule(object):
remote_md5 = self.runner._remote_md5(conn, tmp, dest) remote_md5 = self.runner._remote_md5(conn, tmp, dest)
if pathmd5 != remote_md5: if pathmd5 != remote_md5:
resultant = file(path).read()
if self.runner.diff: if self.runner.diff:
dest_result = self.runner._execute_module(conn, tmp, 'slurp', "path=%s" % dest, inject=inject, persist_files=True) dest_result = self.runner._execute_module(conn, tmp, 'slurp', "path=%s" % dest, inject=inject, persist_files=True)
if 'content' in dest_result.result: if 'content' in dest_result.result:
@ -88,10 +90,11 @@ class ActionModule(object):
module_args = "%s src=%s dest=%s original_basename=%s" % (module_args, pipes.quote(xfered), pipes.quote(dest), pipes.quote(os.path.basename(src))) module_args = "%s src=%s dest=%s original_basename=%s" % (module_args, pipes.quote(xfered), pipes.quote(dest), pipes.quote(os.path.basename(src)))
if self.runner.noop_on_check(inject): if self.runner.noop_on_check(inject):
return ReturnData(conn=conn, comm_ok=True, result=dict(changed=True), diff=dict(before_header=dest, after_header=src, before=dest_contents, after=resultant)) return ReturnData(conn=conn, comm_ok=True, result=dict(changed=True), diff=dict(before_header=dest, after_header=src, after=resultant))
else: else:
res = self.runner._execute_module(conn, tmp, 'copy', module_args, inject=inject, complex_args=complex_args) res = self.runner._execute_module(conn, tmp, 'copy', module_args, inject=inject)
res.diff = dict(before=dest_contents, after=resultant) res.diff = dict(after=resultant)
return res return res
else: else:
return self.runner._execute_module(conn, tmp, 'file', module_args, inject=inject, complex_args=complex_args) module_args = "%s src=%s dest=%s original_basename=%s" % (module_args, pipes.quote(xfered), pipes.quote(dest), pipes.quote(os.path.basename(src)))
return self.runner._execute_module(conn, tmp, 'file', module_args, inject=inject)