[BugFix] Fix precommit breakage due to conflicting in-flight merges (#38759)
Signed-off-by: Nick Hill <nickhill123@gmail.com>
This commit is contained in:
@@ -420,7 +420,7 @@ class RayExecutorV2(MultiprocExecutor):
|
||||
for response_mq in self.response_mqs:
|
||||
response_mq.wait_until_ready()
|
||||
|
||||
self.futures_queue = deque[tuple[FutureWrapper, Any]]()
|
||||
self.futures_queue = deque[FutureWrapper]()
|
||||
self._post_init_executor()
|
||||
|
||||
self.start_worker_monitor()
|
||||
|
||||
Reference in New Issue
Block a user