Skip to content

Commit 4cbdce1

Browse files
committed
get simplified/full resource str in one go
1 parent 88b862f commit 4cbdce1

File tree

6 files changed

+41
-27
lines changed

6 files changed

+41
-27
lines changed

sky/backends/backend_utils.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3240,12 +3240,12 @@ def _update_records_with_handle_info(
32403240
"""Add resource str to record"""
32413241
for record in _get_records_with_handle(records):
32423242
handle = record['handle']
3243-
record[
3244-
'resources_str'] = resources_utils.get_readable_resources_repr(
3245-
handle, simplify=True)
3246-
record[
3247-
'resources_str_full'] = resources_utils.get_readable_resources_repr(
3248-
handle, simplify=False)
3243+
resource_str_simple, resource_str_full = (
3244+
resources_utils.get_readable_resources_repr(
3245+
handle, simplified_only=False))
3246+
assert resource_str_full is not None
3247+
record['resources_str'] = resource_str_simple
3248+
record['resources_str_full'] = resource_str_full
32493249
if not summary_response:
32503250
record['cluster_name_on_cloud'] = handle.cluster_name_on_cloud
32513251

sky/jobs/utils.py

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1522,12 +1522,11 @@ def get_managed_job_queue(
15221522
handle = cluster_name_to_handle.get(
15231523
cluster_name, None) if cluster_name is not None else None
15241524
if isinstance(handle, backends.CloudVmRayResourceHandle):
1525-
resources_str = resources_utils.get_readable_resources_repr(
1526-
handle, simplify=True)
1527-
resources_str_full = (
1528-
resources_utils.get_readable_resources_repr(handle,
1529-
simplify=False))
1530-
job['cluster_resources'] = resources_str
1525+
resources_str_simple, resources_str_full = (
1526+
resources_utils.get_readable_resources_repr(
1527+
handle, simplified_only=False))
1528+
assert resources_str_full is not None
1529+
job['cluster_resources'] = resources_str_simple
15311530
job['cluster_resources_full'] = resources_str_full
15321531
job['cloud'] = str(handle.launched_resources.cloud)
15331532
job['region'] = handle.launched_resources.region

sky/serve/replica_managers.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -495,8 +495,8 @@ def to_info_dict(self,
495495
info_dict['cloud'] = repr(handle.launched_resources.cloud)
496496
info_dict['region'] = handle.launched_resources.region
497497
info_dict['resources_str'] = (
498-
resources_utils.get_readable_resources_repr(handle,
499-
simplify=True))
498+
resources_utils.get_readable_resources_repr(
499+
handle, simplified_only=True)[0])
500500
return info_dict
501501

502502
def __repr__(self) -> str:

sky/serve/serve_utils.py

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1550,8 +1550,15 @@ def _format_replica_table(replica_records: List[Dict[str, Any]], show_all: bool,
15501550
'handle']
15511551
if replica_handle is not None:
15521552
infra = replica_handle.launched_resources.infra.formatted_str()
1553-
resources_str = resources_utils.get_readable_resources_repr(
1554-
replica_handle, simplify=not show_all)
1553+
simplified = not show_all
1554+
resources_str_simple, resources_str_full = (
1555+
resources_utils.get_readable_resources_repr(
1556+
replica_handle, simplified_only=simplified))
1557+
if simplified:
1558+
resources_str = resources_str_simple
1559+
else:
1560+
assert resources_str_full is not None
1561+
resources_str = resources_str_full
15551562

15561563
replica_values = [
15571564
service_name,

sky/utils/cli_utils/status_utils.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -282,8 +282,14 @@ def _get_resources(cluster_record: _ClusterRecord,
282282
if resources_str_full is not None:
283283
resources_str = resources_str_full
284284
if resources_str is None:
285-
resources_str = resources_utils.get_readable_resources_repr(
286-
handle, simplify=truncate)
285+
resources_str_simple, resources_str_full = (
286+
resources_utils.get_readable_resources_repr(
287+
handle, simplified_only=truncate))
288+
if truncate:
289+
resources_str = resources_str_simple
290+
else:
291+
assert resources_str_full is not None
292+
resources_str = resources_str_full
287293

288294
return resources_str
289295
return '-'

sky/utils/resources_utils.py

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -242,18 +242,20 @@ def format_resource(resource: 'resources_lib.Resources',
242242
return resources_str_simple, resources_str_full
243243

244244

245-
def get_readable_resources_repr(handle: 'backends.CloudVmRayResourceHandle',
246-
simplify: bool = False) -> str:
245+
def get_readable_resources_repr(
246+
handle: 'backends.CloudVmRayResourceHandle',
247+
simplified_only: bool = False) -> Tuple[str, Optional[str]]:
247248
resource_str_simple, resource_str_full = format_resource(
248-
handle.launched_resources, simplify)
249+
handle.launched_resources, simplified_only)
250+
if not simplified_only:
251+
assert resource_str_full is not None
249252
if (handle.launched_nodes is not None and
250253
handle.launched_resources is not None):
251-
if simplify:
252-
return f'{handle.launched_nodes}x{resource_str_simple}'
253-
else:
254-
assert resource_str_full is not None
255-
return f'{handle.launched_nodes}x{resource_str_full}'
256-
return _DEFAULT_MESSAGE_HANDLE_INITIALIZING
254+
return (f'{handle.launched_nodes}x{resource_str_simple}',
255+
None if simplified_only else
256+
f'{handle.launched_nodes}x{resource_str_full}')
257+
return (_DEFAULT_MESSAGE_HANDLE_INITIALIZING,
258+
_DEFAULT_MESSAGE_HANDLE_INITIALIZING)
257259

258260

259261
def make_ray_custom_resources_str(

0 commit comments

Comments
 (0)