Switch to imp.load_module

pull/42973/head
Toshio Kuratomi 6 years ago
parent 52449cc01a
commit dce0a8d052

@ -134,21 +134,24 @@ def _ansiballz_main():
sys.path = [p for p in sys.path if p != scriptdir] sys.path = [p for p in sys.path if p != scriptdir]
import base64 import base64
import imp
import shutil import shutil
import tempfile import tempfile
import zipimport
import zipfile import zipfile
if sys.version_info < (3,): if sys.version_info < (3,):
bytes = str bytes = str
MOD_DESC = ('.py', 'U', imp.PY_SOURCE)
PY3 = False PY3 = False
else: else:
unicode = str unicode = str
MOD_DESC = ('.py', 'r', imp.PY_SOURCE)
PY3 = True PY3 = True
ZIPDATA = """%(zipdata)s""" ZIPDATA = """%(zipdata)s"""
def invoke_module(modlib_path, json_params): # Note: temp_path isn't needed once we switch to zipimport
def invoke_module(modlib_path, temp_path, json_params):
# When installed via setuptools (including python setup.py install), # When installed via setuptools (including python setup.py install),
# ansible may be installed with an easy-install.pth file. That file # ansible may be installed with an easy-install.pth file. That file
# may load the system-wide install of ansible rather than the one in # may load the system-wide install of ansible rather than the one in
@ -164,6 +167,13 @@ def _ansiballz_main():
zinfo.filename = 'sitecustomize.py' zinfo.filename = 'sitecustomize.py'
zinfo.date_time = ( %(year)i, %(month)i, %(day)i, %(hour)i, %(minute)i, %(second)i) zinfo.date_time = ( %(year)i, %(month)i, %(day)i, %(hour)i, %(minute)i, %(second)i)
z.writestr(zinfo, sitecustomize) z.writestr(zinfo, sitecustomize)
# Note: Remove the following section when we switch to zipimport
# Write the module to disk for imp.load_module
module = os.path.join(temp_path, '__main__.py')
with open(module, 'wb') as f:
f.write(z.read('__main__.py'))
f.close()
# End pre-zipimport section
z.close() z.close()
# Put the zipped up module_utils we got from the controller first in the python path so that we # Put the zipped up module_utils we got from the controller first in the python path so that we
@ -175,8 +185,8 @@ def _ansiballz_main():
basic._ANSIBLE_ARGS = json_params basic._ANSIBLE_ARGS = json_params
%(coverage)s %(coverage)s
# Run the module! By importing it as '__main__', it thinks it is executing as a script # Run the module! By importing it as '__main__', it thinks it is executing as a script
importer = zipimport.zipimporter(modlib_path) with open(module, 'rb') as mod:
importer.load_module('__main__') imp.load_module('__main__', mod, module, MOD_DESC)
# Ansible modules must exit themselves # Ansible modules must exit themselves
print('{"msg": "New-style module did not handle its own exit", "failed": true}') print('{"msg": "New-style module did not handle its own exit", "failed": true}')
@ -296,7 +306,9 @@ def _ansiballz_main():
# There's a race condition with the controller removing the # There's a race condition with the controller removing the
# remote_tmpdir and this module executing under async. So we cannot # remote_tmpdir and this module executing under async. So we cannot
# store this in remote_tmpdir (use system tempdir instead) # store this in remote_tmpdir (use system tempdir instead)
temp_path = tempfile.mkdtemp(prefix='ansible_') # Only need to use [ansible_module]_payload_ in the temp_path until we move to zipimport
# (this helps ansible-test produce coverage stats)
temp_path = tempfile.mkdtemp(prefix='ansible_%(ansible_module)s_payload_')
zipped_mod = os.path.join(temp_path, 'ansible_%(ansible_module)s_payload.zip') zipped_mod = os.path.join(temp_path, 'ansible_%(ansible_module)s_payload.zip')
with open(zipped_mod, 'wb') as modlib: with open(zipped_mod, 'wb') as modlib:
@ -305,7 +317,8 @@ def _ansiballz_main():
if len(sys.argv) == 2: if len(sys.argv) == 2:
exitcode = debug(sys.argv[1], zipped_mod, ANSIBALLZ_PARAMS) exitcode = debug(sys.argv[1], zipped_mod, ANSIBALLZ_PARAMS)
else: else:
invoke_module(zipped_mod, ANSIBALLZ_PARAMS) # Note: temp_path isn't needed once we switch to zipimport
invoke_module(zipped_mod, temp_path, ANSIBALLZ_PARAMS)
finally: finally:
try: try:
shutil.rmtree(temp_path) shutil.rmtree(temp_path)

Loading…
Cancel
Save