Merge "Get cancellation grace period correctly"

This commit is contained in:
Jenkins 2017-07-04 06:36:39 +00:00 committed by Gerrit Code Review
commit 824c3f0a24
2 changed files with 4 additions and 4 deletions

View File

@ -1151,9 +1151,6 @@ class Resource(status.ResourceStatus):
properties.update_translation(rules, client_resolve=client_resolve)
def cancel_grace_period(self):
if self.status != self.IN_PROGRESS:
return None
canceller = getattr(self,
'handle_%s_cancel' % self.action.lower(),
None)

View File

@ -472,7 +472,10 @@ class DependencyTaskGroup(object):
return grace_period
for k, r in six.iteritems(self._runners):
gp = get_grace_period(k)
if not r.started() or r.done():
gp = None
else:
gp = get_grace_period(k)
try:
r.cancel(grace_period=gp)
except Exception as ex: