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 7b45c23 commit a08ad91Copy full SHA for a08ad91
compiler_opt/distributed/local/local_worker_manager.py
@@ -161,10 +161,10 @@ def _msg_pump(self):
161
with self._lock:
162
future = self._map[task_result.msgid]
163
del self._map[task_result.msgid]
164
- if task_result.success:
165
- future.set_result(task_result.value)
166
- else:
167
- future.set_exception(task_result.value)
+ if task_result.success:
+ future.set_result(task_result.value)
+ else:
+ future.set_exception(task_result.value)
168
169
# clear out pending futures and mark ourselves as "stopped" by null-ing
170
# the map
0 commit comments