From bc0757636d4243fb945d734678d01618ebdcd6d2 Mon Sep 17 00:00:00 2001 From: Kevin James Date: Wed, 24 Jan 2018 11:00:57 -0800 Subject: [PATCH] fix(taskqueue): handle BrokenProcessPool explicitly --- taskqueue/gcloud/aio/taskqueue/taskmanager.py | 2 +- taskqueue/setup.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/taskqueue/gcloud/aio/taskqueue/taskmanager.py b/taskqueue/gcloud/aio/taskqueue/taskmanager.py index 76148f61e..422c0be4c 100644 --- a/taskqueue/gcloud/aio/taskqueue/taskmanager.py +++ b/taskqueue/gcloud/aio/taskqueue/taskmanager.py @@ -166,7 +166,7 @@ async def process(self, task): # and at this point I'm sick of having to update the blacklist. If we # get an exception while creating a LeaseManager, that's enough for me # to be reasonably sure the pool is broken without needing proof. - except Exception as e: # pylint: disable=broad-except + except (concurrent.futures.process.BrokenProcessPool, Exception) as e: # pylint: disable=broad-except log.error('process pool broke, quitting TaskManager') log.exception(e) self.running = False diff --git a/taskqueue/setup.py b/taskqueue/setup.py index edc495702..0190bc763 100644 --- a/taskqueue/setup.py +++ b/taskqueue/setup.py @@ -13,7 +13,7 @@ setuptools.setup( name='gcloud-aio-taskqueue', - version='1.2.4', + version='1.2.5', description='Asyncio Python Client for Google Cloud Task Queue', long_description=README, namespace_packages=[