Drop dead hasattr guards (hisparse_coordinator, metrics_collector) (#25437)
This commit is contained in:
@@ -781,7 +781,7 @@ class Scheduler(
|
|||||||
f"{'available_cpu_mem' if self.device == 'cpu' else 'available_gpu_mem'}={avail_mem:.2f} GB"
|
f"{'available_cpu_mem' if self.device == 'cpu' else 'available_gpu_mem'}={avail_mem:.2f} GB"
|
||||||
)
|
)
|
||||||
|
|
||||||
if self.enable_metrics and hasattr(self, "metrics_collector"):
|
if self.enable_metrics:
|
||||||
self.metrics_collector.emit_constants(
|
self.metrics_collector.emit_constants(
|
||||||
max_total_num_tokens=self.max_total_num_tokens,
|
max_total_num_tokens=self.max_total_num_tokens,
|
||||||
max_running_requests_under_SLO=getattr(
|
max_running_requests_under_SLO=getattr(
|
||||||
|
|||||||
@@ -568,9 +568,6 @@ class ModelRunner(ModelRunnerKVCacheMixin):
|
|||||||
self._model_update_group = {}
|
self._model_update_group = {}
|
||||||
self._weights_send_group = {}
|
self._weights_send_group = {}
|
||||||
|
|
||||||
if not hasattr(self, "hisparse_coordinator"):
|
|
||||||
self.hisparse_coordinator = None
|
|
||||||
|
|
||||||
def _build_model_config(
|
def _build_model_config(
|
||||||
self, server_args, model_path=None, model_revision=None, is_draft_model=False
|
self, server_args, model_path=None, model_revision=None, is_draft_model=False
|
||||||
):
|
):
|
||||||
|
|||||||
Reference in New Issue
Block a user