Skip to content

Commit

Permalink
Fixed concurrency stall by limitting the number of concurrent processes.
Browse files Browse the repository at this point in the history
  • Loading branch information
gerritdrost committed May 26, 2020
1 parent f13f26d commit 57203d7
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions compose/project.py
Original file line number Diff line number Diff line change
Expand Up @@ -76,6 +76,7 @@ def __init__(self, name, services, client, networks=None, volumes=None, config_v
self.volumes = volumes or ProjectVolumes({})
self.networks = networks or ProjectNetworks({}, False)
self.config_version = config_version
self.default_limit = 16

def labels(self, one_off=OneOffFilter.exclude, legacy=False):
name = self.name
Expand Down Expand Up @@ -287,6 +288,7 @@ def get_deps(service):
operator.attrgetter('name'),
'Starting',
get_deps,
limit=self.default_limit,
fail_check=lambda obj: not obj.containers(),
)

Expand All @@ -307,6 +309,7 @@ def get_deps(container):
operator.attrgetter('name'),
'Stopping',
get_deps,
limit=self.default_limit,
)

def pause(self, service_names=None, **options):
Expand Down Expand Up @@ -358,6 +361,7 @@ def restart(self, service_names=None, **options):
self.build_container_operation_with_timeout_func('restart', options),
operator.attrgetter('name'),
'Restarting',
limit=self.default_limit,
)
return containers

Expand Down Expand Up @@ -574,6 +578,7 @@ def get_deps(service):
operator.attrgetter('name'),
None,
get_deps,
limit=self.default_limit,
)
if errors:
raise ProjectError(
Expand Down

0 comments on commit 57203d7

Please sign in to comment.