Merge pull request #249 from nicoddemus/flakes
Fix E741 and E722 flake errors
This commit is contained in:
@@ -12,7 +12,7 @@ environment:
|
|||||||
- TOXENV: "readme"
|
- TOXENV: "readme"
|
||||||
|
|
||||||
install:
|
install:
|
||||||
- C:\Python35\python -m pip install tox setuptools_scm
|
- C:\Python35\python -m pip install -U tox setuptools_scm pip
|
||||||
|
|
||||||
build: false # Not a C# project, build stuff at the test step instead.
|
build: false # Not a C# project, build stuff at the test step instead.
|
||||||
|
|
||||||
|
|||||||
@@ -20,13 +20,13 @@ pytest_plugins = "pytester"
|
|||||||
@pytest.fixture(autouse=True)
|
@pytest.fixture(autouse=True)
|
||||||
def _divert_atexit(request, monkeypatch):
|
def _divert_atexit(request, monkeypatch):
|
||||||
import atexit
|
import atexit
|
||||||
l = []
|
finalizers = []
|
||||||
|
|
||||||
def finish():
|
def finish():
|
||||||
while l:
|
while finalizers:
|
||||||
l.pop()()
|
finalizers.pop()()
|
||||||
|
|
||||||
monkeypatch.setattr(atexit, "register", l.append)
|
monkeypatch.setattr(atexit, "register", finalizers.append)
|
||||||
request.addfinalizer(finish)
|
request.addfinalizer(finish)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -83,10 +83,10 @@ class TestStatRecorder:
|
|||||||
tmp = tmpdir
|
tmp = tmpdir
|
||||||
sd = StatRecorder([tmp])
|
sd = StatRecorder([tmp])
|
||||||
|
|
||||||
l = [True, False]
|
ret_values = [True, False]
|
||||||
monkeypatch.setattr(StatRecorder, 'check', lambda self: l.pop())
|
monkeypatch.setattr(StatRecorder, 'check', lambda self: ret_values.pop())
|
||||||
sd.waitonchange(checkinterval=0.2)
|
sd.waitonchange(checkinterval=0.2)
|
||||||
assert not l
|
assert not ret_values
|
||||||
|
|
||||||
|
|
||||||
class TestRemoteControl:
|
class TestRemoteControl:
|
||||||
|
|||||||
@@ -50,10 +50,10 @@ class TestNodeManagerPopen:
|
|||||||
assert gm.specs[0].chdir is None
|
assert gm.specs[0].chdir is None
|
||||||
|
|
||||||
def test_default_chdir(self, config):
|
def test_default_chdir(self, config):
|
||||||
l = ["ssh=noco", "socket=xyz"]
|
specs = ["ssh=noco", "socket=xyz"]
|
||||||
for spec in NodeManager(config, l).specs:
|
for spec in NodeManager(config, specs).specs:
|
||||||
assert spec.chdir == "pyexecnetcache"
|
assert spec.chdir == "pyexecnetcache"
|
||||||
for spec in NodeManager(config, l, defaultchdir="abc").specs:
|
for spec in NodeManager(config, specs, defaultchdir="abc").specs:
|
||||||
assert spec.chdir == "abc"
|
assert spec.chdir == "abc"
|
||||||
|
|
||||||
def test_popen_makegateway_events(self, config, hookrecorder,
|
def test_popen_makegateway_events(self, config, hookrecorder,
|
||||||
@@ -89,10 +89,10 @@ class TestNodeManagerPopen:
|
|||||||
pass
|
pass
|
||||||
|
|
||||||
gw.remote_exec = pseudoexec
|
gw.remote_exec = pseudoexec
|
||||||
l = []
|
notifications = []
|
||||||
for gw in hm.group:
|
for gw in hm.group:
|
||||||
hm.rsync(gw, source, notify=lambda *args: l.append(args))
|
hm.rsync(gw, source, notify=lambda *args: notifications.append(args))
|
||||||
assert not l
|
assert not notifications
|
||||||
hm.teardown_nodes()
|
hm.teardown_nodes()
|
||||||
assert not len(hm.group)
|
assert not len(hm.group)
|
||||||
assert "sys.path.insert" in gw.remote_exec.args[0]
|
assert "sys.path.insert" in gw.remote_exec.args[0]
|
||||||
@@ -102,11 +102,11 @@ class TestNodeManagerPopen:
|
|||||||
hm = NodeManager(config, ["popen//chdir=%s" % dest] * 1)
|
hm = NodeManager(config, ["popen//chdir=%s" % dest] * 1)
|
||||||
hm.setup_nodes(None)
|
hm.setup_nodes(None)
|
||||||
source.ensure("dir1", "dir2", "hello")
|
source.ensure("dir1", "dir2", "hello")
|
||||||
l = []
|
notifications = []
|
||||||
for gw in hm.group:
|
for gw in hm.group:
|
||||||
hm.rsync(gw, source, notify=lambda *args: l.append(args))
|
hm.rsync(gw, source, notify=lambda *args: notifications.append(args))
|
||||||
assert len(l) == 1
|
assert len(notifications) == 1
|
||||||
assert l[0] == ("rsyncrootready", hm.group['gw0'].spec, source)
|
assert notifications[0] == ("rsyncrootready", hm.group['gw0'].spec, source)
|
||||||
hm.teardown_nodes()
|
hm.teardown_nodes()
|
||||||
dest = dest.join(source.basename)
|
dest = dest.join(source.basename)
|
||||||
assert dest.join("dir1").check()
|
assert dest.join("dir1").check()
|
||||||
@@ -137,9 +137,9 @@ class TestHRSync:
|
|||||||
source.ensure(".somedotfile", "moreentries")
|
source.ensure(".somedotfile", "moreentries")
|
||||||
source.ensure("somedir", "editfile~")
|
source.ensure("somedir", "editfile~")
|
||||||
syncer = HostRSync(source, ignores=NodeManager.DEFAULT_IGNORES)
|
syncer = HostRSync(source, ignores=NodeManager.DEFAULT_IGNORES)
|
||||||
l = list(source.visit(rec=syncer.filter, fil=syncer.filter))
|
files = list(source.visit(rec=syncer.filter, fil=syncer.filter))
|
||||||
assert len(l) == 3
|
assert len(files) == 3
|
||||||
basenames = [x.basename for x in l]
|
basenames = [x.basename for x in files]
|
||||||
assert 'dir' in basenames
|
assert 'dir' in basenames
|
||||||
assert 'file.txt' in basenames
|
assert 'file.txt' in basenames
|
||||||
assert 'somedir' in basenames
|
assert 'somedir' in basenames
|
||||||
|
|||||||
@@ -186,7 +186,7 @@ class HostRSync(execnet.RSync):
|
|||||||
def make_reltoroot(roots, args):
|
def make_reltoroot(roots, args):
|
||||||
# XXX introduce/use public API for splitting py.test args
|
# XXX introduce/use public API for splitting py.test args
|
||||||
splitcode = "::"
|
splitcode = "::"
|
||||||
l = []
|
result = []
|
||||||
for arg in args:
|
for arg in args:
|
||||||
parts = arg.split(splitcode)
|
parts = arg.split(splitcode)
|
||||||
fspath = py.path.local(parts[0])
|
fspath = py.path.local(parts[0])
|
||||||
@@ -197,8 +197,8 @@ def make_reltoroot(roots, args):
|
|||||||
break
|
break
|
||||||
else:
|
else:
|
||||||
raise ValueError("arg %s not relative to an rsync root" % (arg,))
|
raise ValueError("arg %s not relative to an rsync root" % (arg,))
|
||||||
l.append(splitcode.join(parts))
|
result.append(splitcode.join(parts))
|
||||||
return l
|
return result
|
||||||
|
|
||||||
|
|
||||||
class SlaveController(object):
|
class SlaveController(object):
|
||||||
@@ -326,7 +326,7 @@ class SlaveController(object):
|
|||||||
except KeyboardInterrupt:
|
except KeyboardInterrupt:
|
||||||
# should not land in receiver-thread
|
# should not land in receiver-thread
|
||||||
raise
|
raise
|
||||||
except:
|
except: # noqa
|
||||||
excinfo = py.code.ExceptionInfo()
|
excinfo = py.code.ExceptionInfo()
|
||||||
py.builtin.print_("!" * 20, excinfo)
|
py.builtin.print_("!" * 20, excinfo)
|
||||||
self.config.notify_exception(excinfo)
|
self.config.notify_exception(excinfo)
|
||||||
|
|||||||
Reference in New Issue
Block a user