From d38315a590b350f8108cf474c13e7451c2f32210 Mon Sep 17 00:00:00 2001 From: s5u13b Date: Tue, 7 Jan 2025 09:22:37 +0000 Subject: [PATCH] Fix _check_deployment_states_loop --- llumnix/manager.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/llumnix/manager.py b/llumnix/manager.py index f1ae0bf5..107946e4 100644 --- a/llumnix/manager.py +++ b/llumnix/manager.py @@ -597,11 +597,12 @@ async def done_scale_up(): async def _check_deployment_states_loop(self, interval: float) -> None: async def watch_deployment(instance_id: str): - logger.warning("[_check_deployment_states_loop] watch instance {} deployment".format(instance_id)) await asyncio.sleep(WATCH_DEPLOYMENT_INTERVAL) curr_pgs, curr_servers, curr_instances = self.get_curr_deployment() if instance_id in curr_pgs and (instance_id not in curr_servers or instance_id not in curr_instances): - logger.warning("[_check_deployment_states_loop] instance {} deployment states incorrect".format(instance_id)) + logger.warning("[_check_deployment_states_loop] instance {} deployment states incorrect, " + "states: (pg {}, server {}, instance {})" + .format(instance_id, instance_id in curr_pgs, instance_id in curr_servers, instance_id in curr_instances)) self.scale_down(instance_id) while True: