mirror of
https://github.com/projectatomic/atomic.git
synced 2026-02-05 18:45:01 +01:00
cc0919c408
The following integration tests have been added: * ScanList * ImagePull * ImageUpdate * ImageUpate when at latest * ImagePull when already at latest * Run * ContainersDelete * ContainersDelete when container doesnt exist Closes: #904 Approved by: rhatdan
59 lines
2.3 KiB
Python
59 lines
2.3 KiB
Python
try:
|
|
from . import Atomic
|
|
except ImportError:
|
|
from atomic import Atomic # pylint: disable=relative-import
|
|
from .util import get_atomic_config, write_out
|
|
from Atomic.backendutils import BackendUtils
|
|
|
|
ATOMIC_CONFIG = get_atomic_config()
|
|
|
|
|
|
_storage = ATOMIC_CONFIG.get('default_storage', "docker")
|
|
|
|
def cli(subparser):
|
|
# atomic pull
|
|
pullp = subparser.add_parser("pull", help=_("pull latest image from a repository"),
|
|
epilog="pull the latest specified image from a repository.")
|
|
pullp.set_defaults(_class=Pull, func='pull_image')
|
|
pullp.add_argument("--storage", dest="storage", default=None,
|
|
help=_("Specify the storage. Default is currently '%s'. You can"
|
|
" change the default by editing /etc/atomic.conf and changing"
|
|
" the 'default_storage' field." % _storage))
|
|
pullp.add_argument("-t", "--type", dest="reg_type", default=None,
|
|
help=_("Pull from an alternative registry type."))
|
|
pullp.add_argument("image", help=_("image id"))
|
|
|
|
|
|
class Pull(Atomic):
|
|
def __init__(self, policy_filename=None):
|
|
"""
|
|
:param policy_filename: override policy filename
|
|
"""
|
|
super(Pull, self).__init__()
|
|
self.policy_filename=policy_filename
|
|
self.be_utils = BackendUtils()
|
|
|
|
def pull_image(self):
|
|
storage_set = False if self.args.storage is None else True
|
|
storage = _storage if not storage_set else self.args.storage
|
|
if self.args.debug:
|
|
write_out(str(self.args))
|
|
|
|
be_utils = BackendUtils()
|
|
be = be_utils.get_backend_from_string(storage)
|
|
self.args.policy_filename = self.policy_filename
|
|
try:
|
|
if be.backend == 'docker':
|
|
remote_image_obj = be.make_remote_image(self.args.image)
|
|
if remote_image_obj.is_system_type and not storage_set:
|
|
be = be_utils.get_backend_from_string('ostree')
|
|
be_utils.message_backend_change('docker', 'ostree')
|
|
else:
|
|
remote_image_obj = None
|
|
be.pull_image(self.args.image, remote_image_obj, debug=self.args.debug, assumeyes=self.args.assumeyes)
|
|
except ValueError as e:
|
|
raise ValueError("Failed: {}".format(e))
|
|
return 0
|
|
|
|
|