Browse Source

Fix flake8 warnings

ppa-0.6.1
practicalswift 7 years ago
committed by Christian Decker
parent
commit
d2109bfe0c
  1. 2
      tests/benchmark.py
  2. 22
      tests/test_lightningd.py
  3. 4
      tests/utils.py

2
tests/benchmark.py

@ -36,7 +36,7 @@ def bitcoind():
try: try:
bitcoind.rpc.stop() bitcoind.rpc.stop()
except: except Exception:
bitcoind.proc.kill() bitcoind.proc.kill()
bitcoind.proc.wait() bitcoind.proc.wait()

22
tests/test_lightningd.py

@ -46,7 +46,7 @@ def setupBitcoind(directory):
try: try:
bitcoind.start() bitcoind.start()
except: except Exception:
teardown_bitcoind() teardown_bitcoind()
raise raise
@ -86,7 +86,7 @@ def teardown_bitcoind():
global bitcoind global bitcoind
try: try:
bitcoind.rpc.stop() bitcoind.rpc.stop()
except: except Exception:
bitcoind.proc.kill() bitcoind.proc.kill()
bitcoind.proc.wait() bitcoind.proc.wait()
@ -126,7 +126,7 @@ class NodeFactory(object):
daemon.env["LIGHTNINGD_DEV_NO_BACKTRACE"] = "1" daemon.env["LIGHTNINGD_DEV_NO_BACKTRACE"] = "1"
if fake_bitcoin_cli: if fake_bitcoin_cli:
cli=os.path.join(lightning_dir, "fake-bitcoin-cli") cli = os.path.join(lightning_dir, "fake-bitcoin-cli")
with open(cli, "w") as text_file: with open(cli, "w") as text_file:
print("""#! /bin/sh print("""#! /bin/sh
! [ -f bitcoin-cli-fail ] || exit `cat bitcoin-cli-fail` ! [ -f bitcoin-cli-fail ] || exit `cat bitcoin-cli-fail`
@ -154,7 +154,7 @@ class NodeFactory(object):
try: try:
node.daemon.start() node.daemon.start()
except: except Exception:
node.daemon.stop() node.daemon.stop()
raise raise
@ -173,12 +173,12 @@ class NodeFactory(object):
try: try:
# This also puts leaks in log. # This also puts leaks in log.
leaks = self.nodes[i].rpc.dev_memleak()['leaks'] leaks = self.nodes[i].rpc.dev_memleak()['leaks']
except: except Exception:
pass pass
try: try:
self.nodes[i].stop() self.nodes[i].stop()
except: except Exception:
if expected_successes[i]: if expected_successes[i]:
unexpected_fail = True unexpected_fail = True
@ -223,7 +223,7 @@ class BaseLightningDTests(unittest.TestCase):
crashlog = os.path.join(node.daemon.lightning_dir, 'crash.log') crashlog = os.path.join(node.daemon.lightning_dir, 'crash.log')
with open(crashlog, 'r') as f: with open(crashlog, 'r') as f:
return f.readlines(), crashlog return f.readlines(), crashlog
except: except Exception:
return None, None return None, None
def printCrashLog(self, node): def printCrashLog(self, node):
@ -363,7 +363,7 @@ class LightningDTests(BaseLightningDTests):
def fake_bitcoind_unfail(self, l1): def fake_bitcoind_unfail(self, l1):
os.remove(os.path.join(l1.daemon.lightning_dir, "bitcoin-cli-fail")) os.remove(os.path.join(l1.daemon.lightning_dir, "bitcoin-cli-fail"))
@unittest.skipIf(not DEVELOPER, "needs DEVELOPER=1") @unittest.skipIf(not DEVELOPER, "needs DEVELOPER=1")
def test_shutdown(self): def test_shutdown(self):
# Fail, in that it will exit before cleanup. # Fail, in that it will exit before cleanup.
@ -1127,12 +1127,12 @@ class LightningDTests(BaseLightningDTests):
# And they should retry! # And they should retry!
l1.daemon.wait_for_logs(['estimatesmartfee .* exited with status 1', l1.daemon.wait_for_logs(['estimatesmartfee .* exited with status 1',
'getblockhash .* exited with status 1']) 'getblockhash .* exited with status 1'])
# Restore, then it should recover and get blockheight. # Restore, then it should recover and get blockheight.
self.fake_bitcoind_unfail(l1) self.fake_bitcoind_unfail(l1)
bitcoind.generate_block(5) bitcoind.generate_block(5)
sync_blockheight([l1]) sync_blockheight([l1])
def test_closing_different_fees(self): def test_closing_different_fees(self):
l1 = self.node_factory.get_node() l1 = self.node_factory.get_node()
@ -3691,7 +3691,7 @@ class LightningDTests(BaseLightningDTests):
.format(l1.daemon.lightning_dir), .format(l1.daemon.lightning_dir),
'-J', '-o', '-J', '-o',
'sendpay']).decode('utf-8') 'sendpay']).decode('utf-8')
except: except Exception:
pass pass
@unittest.skipIf(not DEVELOPER, "needs DEVELOPER=1") @unittest.skipIf(not DEVELOPER, "needs DEVELOPER=1")

4
tests/utils.py

@ -301,7 +301,7 @@ class LightningNode(object):
def call_connect(): def call_connect():
try: try:
self.rpc.connect('127.0.0.1', remote_node.daemon.port, tx['hex'], async=False) self.rpc.connect('127.0.0.1', remote_node.daemon.port, tx['hex'], async=False)
except: except Exception:
pass pass
t = threading.Thread(target=call_connect) t = threading.Thread(target=call_connect)
t.daemon = True t.daemon = True
@ -384,7 +384,7 @@ class LightningNode(object):
try: try:
# May fail if the process already died # May fail if the process already died
self.rpc.stop() self.rpc.stop()
except: except Exception:
pass pass
rc = self.daemon.wait(timeout) rc = self.daemon.wait(timeout)

Loading…
Cancel
Save