[PD] Remove Unnecessary Exception Handling for FastQueue.get() (#6712)
This commit is contained in:
@@ -424,8 +424,6 @@ class MooncakeKVManager(BaseKVManager):
|
|||||||
if kv_chunk.room in self.transfer_infos:
|
if kv_chunk.room in self.transfer_infos:
|
||||||
self.transfer_infos.pop(kv_chunk.room)
|
self.transfer_infos.pop(kv_chunk.room)
|
||||||
|
|
||||||
except queue.Empty:
|
|
||||||
continue
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
# NOTE(shangming): Remove this when we make sure the transfer thread is bug-free
|
# NOTE(shangming): Remove this when we make sure the transfer thread is bug-free
|
||||||
raise RuntimeError(
|
raise RuntimeError(
|
||||||
|
|||||||
Reference in New Issue
Block a user