forked from LBRYCommunity/lbry-sdk
changed addTimeout to add_timeout for lint compliance
This commit is contained in:
parent
dca7977051
commit
e6c1dc251e
1 changed files with 5 additions and 5 deletions
|
@ -132,18 +132,18 @@ class AsyncioTestCase(unittest.TestCase):
|
||||||
|
|
||||||
with outcome.testPartExecutor(self):
|
with outcome.testPartExecutor(self):
|
||||||
self.setUp()
|
self.setUp()
|
||||||
self.addTimeout()
|
self.add_timeout()
|
||||||
self.loop.run_until_complete(self.asyncSetUp())
|
self.loop.run_until_complete(self.asyncSetUp())
|
||||||
if outcome.success:
|
if outcome.success:
|
||||||
outcome.expecting_failure = expecting_failure
|
outcome.expecting_failure = expecting_failure
|
||||||
with outcome.testPartExecutor(self, isTest=True):
|
with outcome.testPartExecutor(self, isTest=True):
|
||||||
maybe_coroutine = testMethod()
|
maybe_coroutine = testMethod()
|
||||||
if asyncio.iscoroutine(maybe_coroutine):
|
if asyncio.iscoroutine(maybe_coroutine):
|
||||||
self.addTimeout()
|
self.add_timeout()
|
||||||
self.loop.run_until_complete(maybe_coroutine)
|
self.loop.run_until_complete(maybe_coroutine)
|
||||||
outcome.expecting_failure = False
|
outcome.expecting_failure = False
|
||||||
with outcome.testPartExecutor(self):
|
with outcome.testPartExecutor(self):
|
||||||
self.addTimeout()
|
self.add_timeout()
|
||||||
self.loop.run_until_complete(self.asyncTearDown())
|
self.loop.run_until_complete(self.asyncTearDown())
|
||||||
self.tearDown()
|
self.tearDown()
|
||||||
|
|
||||||
|
@ -191,7 +191,7 @@ class AsyncioTestCase(unittest.TestCase):
|
||||||
with outcome.testPartExecutor(self):
|
with outcome.testPartExecutor(self):
|
||||||
maybe_coroutine = function(*args, **kwargs)
|
maybe_coroutine = function(*args, **kwargs)
|
||||||
if asyncio.iscoroutine(maybe_coroutine):
|
if asyncio.iscoroutine(maybe_coroutine):
|
||||||
self.addTimeout()
|
self.add_timeout()
|
||||||
self.loop.run_until_complete(maybe_coroutine)
|
self.loop.run_until_complete(maybe_coroutine)
|
||||||
|
|
||||||
def cancel(self):
|
def cancel(self):
|
||||||
|
@ -200,7 +200,7 @@ class AsyncioTestCase(unittest.TestCase):
|
||||||
task.print_stack()
|
task.print_stack()
|
||||||
task.cancel()
|
task.cancel()
|
||||||
|
|
||||||
def addTimeout(self):
|
def add_timeout(self):
|
||||||
if self.TIMEOUT:
|
if self.TIMEOUT:
|
||||||
self.loop.call_later(self.TIMEOUT, self.cancel)
|
self.loop.call_later(self.TIMEOUT, self.cancel)
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue