tyler.durden/compose
1
0
Fork 0
mirror of https://github.com/docker/compose.git synced 2025-07-26 15:14:04 +02:00
Code Issues Packages Projects Releases Wiki Activity

Hide parallel pull behind --parallel flag

Browse Source 
Signed-off-by: Evan Shaw <evan@vendhq.com>
This commit is contained in:
Evan Shaw 2017-02-13 16:22:55 +13:00
parent f85da99ef3
commit c6a271e57c
2 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
compose/cli/main.py
View File

@ -602,10 +602,12 @@ class TopLevelCommand(object):
Options: Options:
--ignore-pull-failures Pull what it can and ignores images with pull failures. --ignore-pull-failures Pull what it can and ignores images with pull failures.
--parallel Pull multiple images in parallel.
""" """
self.project.pull( self.project.pull(
service_names=options['SERVICE'], service_names=options['SERVICE'],
ignore_pull_failures=options.get('--ignore-pull-failures') ignore_pull_failures=options.get('--ignore-pull-failures'),
in_parallel=options.get('--parallel')
) )
def push(self, options): def push(self, options):

25
compose/project.py
View File

@ -454,17 +454,22 @@ class Project(object):
return plans return plans
def pull(self, service_names=None, ignore_pull_failures=False): def pull(self, service_names=None, ignore_pull_failures=False, in_parallel=False):
def pull_service(service):
service.pull(ignore_pull_failures, True)
services = self.get_services(service_names, include_deps=False) services = self.get_services(service_names, include_deps=False)
parallel.parallel_execute(
services, if in_parallel:
pull_service, def pull_service(service):
operator.attrgetter('name'), service.pull(ignore_pull_failures, True)
'Pulling',
limit=5) parallel.parallel_execute(
services,
pull_service,
operator.attrgetter('name'),
'Pulling',
limit=5)
else:
for service in services:
service.pull(ignore_pull_failures)
def push(self, service_names=None, ignore_push_failures=False): def push(self, service_names=None, ignore_push_failures=False):
for service in self.get_services(service_names, include_deps=False): for service in self.get_services(service_names, include_deps=False):