Skip to content

Commit ad5fb0e

Browse files
committed
network protocol test, use ThreadPoolExecutor
1 parent e9718c9 commit ad5fb0e

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

chia/_tests/util/test_network_protocol_test.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,7 @@ def test_missing_messages() -> None:
189189
"RequestSignatures",
190190
"RespondPlots",
191191
"RespondSignatures",
192-
"V2QualityChains",
192+
"PartialProofsData",
193193
}
194194

195195
introducer_msgs = {"RequestPeersIntroducer", "RespondPeersIntroducer"}

chia/solver/solver.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
from __future__ import annotations
22

33
import asyncio
4-
import concurrent
54
import contextlib
65
import logging
76
from collections.abc import AsyncIterator
@@ -48,7 +47,7 @@ def __init__(self, root_path: Path, config: dict[str, Any], constants: Consensus
4847
self._shut_down = False
4948
num_threads = config["num_threads"]
5049
self.log.info(f"Initializing solver with {num_threads} threads")
51-
self.executor = concurrent.futures.ThreadPoolExecutor(max_workers=num_threads, thread_name_prefix="solver-")
50+
self.executor = ThreadPoolExecutor(max_workers=num_threads, thread_name_prefix="solver-")
5251
self._server = None
5352
self.constants = constants
5453
self.state_changed_callback: Optional[StateChangedProtocol] = None

0 commit comments

Comments
 (0)