We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 47bcf75 commit 106c8a6Copy full SHA for 106c8a6
mypy/build_worker/worker.py
@@ -30,6 +30,7 @@
30
31
from mypy import util
32
from mypy.build import (
33
+ ACK_MESSAGE,
34
GRAPH_MESSAGE,
35
SCC,
36
SCC_REQUEST_MESSAGE,
@@ -201,7 +202,8 @@ def serve(server: IPCServer, ctx: ServerContext) -> None:
201
202
meta_files.append(meta_file)
203
send(server, SccResponseMessage(scc_id=scc_id, is_interface=True, result=mod_results))
204
# Only proceed with the implementations if there are no blockers so far.
- AckMessage.read(receive(server))
205
+ if should_shutdown(receive(server), ACK_MESSAGE):
206
+ break
207
try:
208
result = process_stale_scc_implementation(graph, stale, manager, meta_files)
209
# Both phases write cache, so we should commit here as well.
0 commit comments