|
@@ -111,7 +111,7 @@ class BasePool(object):
|
|
def maintain_pool(self, *args, **kwargs):
|
|
def maintain_pool(self, *args, **kwargs):
|
|
pass
|
|
pass
|
|
|
|
|
|
- def terminate_job(self, pid):
|
|
|
|
|
|
+ def terminate_job(self, pid, signal=None):
|
|
raise NotImplementedError(
|
|
raise NotImplementedError(
|
|
'{0} does not implement kill_job'.format(type(self)))
|
|
'{0} does not implement kill_job'.format(type(self)))
|
|
|
|
|