Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 4 additions & 3 deletions sky/utils/resource_checker.py
Original file line number Diff line number Diff line change
Expand Up @@ -276,9 +276,10 @@ def get_all_managed_jobs():
# pylint: disable=import-outside-toplevel
from sky.jobs.server import core as managed_jobs_core
try:
return managed_jobs_core.queue(refresh=False,
skip_finished=True,
all_users=True)
filtered_jobs, _, _, _ = managed_jobs_core.queue(refresh=False,
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hi @seongsukwon-moreh, could you please help add return type List[Dict[str, Any]] for the get_all_clusters and get_all_managed_jobs functions, so that any mismatch changes can be caught later?
Thanks!

skip_finished=True,
all_users=True)
return filtered_jobs
except exceptions.ClusterNotUpError:
logger.warning('All jobs should be finished.')
return []
Expand Down
Loading