Add expert distribution APIs for engine (#6290)
This commit is contained in:
@@ -324,6 +324,24 @@ class Engine(EngineBase):
|
|||||||
loop = asyncio.get_event_loop()
|
loop = asyncio.get_event_loop()
|
||||||
loop.run_until_complete(self.tokenizer_manager.stop_profile())
|
loop.run_until_complete(self.tokenizer_manager.stop_profile())
|
||||||
|
|
||||||
|
def start_expert_distribution_record(self):
|
||||||
|
loop = asyncio.get_event_loop()
|
||||||
|
loop.run_until_complete(
|
||||||
|
self.tokenizer_manager.start_expert_distribution_record()
|
||||||
|
)
|
||||||
|
|
||||||
|
def stop_expert_distribution_record(self):
|
||||||
|
loop = asyncio.get_event_loop()
|
||||||
|
loop.run_until_complete(
|
||||||
|
self.tokenizer_manager.stop_expert_distribution_record()
|
||||||
|
)
|
||||||
|
|
||||||
|
def dump_expert_distribution_record(self):
|
||||||
|
loop = asyncio.get_event_loop()
|
||||||
|
loop.run_until_complete(
|
||||||
|
self.tokenizer_manager.dump_expert_distribution_record()
|
||||||
|
)
|
||||||
|
|
||||||
def get_server_info(self):
|
def get_server_info(self):
|
||||||
loop = asyncio.get_event_loop()
|
loop = asyncio.get_event_loop()
|
||||||
internal_states = loop.run_until_complete(
|
internal_states = loop.run_until_complete(
|
||||||
|
|||||||
Reference in New Issue
Block a user