Skip to content

Commit 8724b5c

Browse files
[pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
1 parent fc7e83d commit 8724b5c

File tree

3 files changed

+11
-6
lines changed

3 files changed

+11
-6
lines changed

src/xdist/scheduler/loadscope.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,9 @@ def add_node(self, node: WorkerController) -> None:
162162
"""
163163
assert node not in self.assigned_work
164164
self.assigned_work[node] = {}
165-
self.assigned_work = dict(sorted(self.assigned_work.items(), key=lambda item: item[0].gateway.id))
165+
self.assigned_work = dict(
166+
sorted(self.assigned_work.items(), key=lambda item: item[0].gateway.id)
167+
)
166168

167169
def remove_node(self, node: WorkerController) -> str | None:
168170
"""Remove a node from the scheduler.

src/xdist/workermanage.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -101,8 +101,7 @@ def setup_nodes(
101101
self.trace("setting up nodes")
102102
with ThreadPoolExecutor(max_workers=len(self.specs)) as executor:
103103
futs = [
104-
executor.submit(self.setup_node, spec, putevent)
105-
for spec in self.specs
104+
executor.submit(self.setup_node, spec, putevent) for spec in self.specs
106105
]
107106
return [f.result() for f in futs]
108107

testing/test_workermanage.py

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -83,10 +83,14 @@ def test_popen_makegateway_events(
8383
assert len(call.specs) == 2
8484

8585
# check expected gateways
86-
gw_calls = [hookrecorder.popcall("pytest_xdist_newgateway"),
87-
hookrecorder.popcall("pytest_xdist_newgateway")]
86+
gw_calls = [
87+
hookrecorder.popcall("pytest_xdist_newgateway"),
88+
hookrecorder.popcall("pytest_xdist_newgateway"),
89+
]
8890
assert {c.gateway.id for c in gw_calls} == {"gw0", "gw1"}
89-
assert {c.gateway.spec for c in gw_calls} == {execnet.XSpec("execmodel=main_thread_only//popen")}
91+
assert {c.gateway.spec for c in gw_calls} == {
92+
execnet.XSpec("execmodel=main_thread_only//popen")
93+
}
9094
assert len(hm.group) == 2
9195
hm.teardown_nodes()
9296
assert not len(hm.group)

0 commit comments

Comments
 (0)