[Core] Allow nonexistent cloud in candidate resources and speed up optimization #3567

Michaelvll · 2024-05-20T07:17:14Z

Allow nonexistent cloud

With at least one cloud enabled

Without kubernetes and IBM enabled:

resources:
  accelerators: A100:8
  ordered:
    - cloud: kubernetes
    - cloud: aws
      use_spot: true
    - cloud: ibm

Master:

Task from YAML spec: task.yaml
I 05-20 07:20:28 optimizer.py:983] Using user-specified accelerators list (will be tried in the listed order): Kubernetes({'A100': 8}), AWS([Spot], {'A100': 8}), IBM({'A100': 8})
INFO:googleapiclient.discovery_cache:file_cache is only supported with oauth2client<4.0.0
sky.exceptions.ResourcesUnavailableError: Task requires Kubernetes which is not enabled: Task(run=<empty>)
  resources: Kubernetes({'A100': 8}).
To enable access, run sky check , or change the cloud requirement

This PR:

Task from YAML spec: task.yaml
W 05-20 07:41:11 optimizer.py:1189] Task requires IBM, Kubernetes which are not enabled. To enable access, change the task cloud requirement or run: sky check IBM Kubernetes
I 05-20 07:41:12 optimizer.py:696] == Optimizer ==
I 05-20 07:41:12 optimizer.py:707] Target: minimizing cost
I 05-20 07:41:12 optimizer.py:719] Estimated cost: $5.9 / hour
I 05-20 07:41:12 optimizer.py:719] 
I 05-20 07:41:12 optimizer.py:844] Considered resources (1 node):
I 05-20 07:41:12 optimizer.py:914] -------------------------------------------------------------------------------------------------
I 05-20 07:41:12 optimizer.py:914]  CLOUD   INSTANCE             vCPUs   Mem(GB)   ACCELERATORS   REGION/ZONE   COST ($)   CHOSEN   
I 05-20 07:41:12 optimizer.py:914] -------------------------------------------------------------------------------------------------
I 05-20 07:41:12 optimizer.py:914]  AWS     p4d.24xlarge[Spot]   96      1152      A100:8         us-east-2b    5.89          ✔     
I 05-20 07:41:12 optimizer.py:914] -------------------------------------------------------------------------------------------------
I 05-20 07:41:12 optimizer.py:914] 
Launching a new cluster 'sky-1276-azureuser'. Proceed? [Y/n]:

For a dag:

resources:
  accelerators: A100:8
  ordered:
    - cloud: kubernetes
    - cloud: aws
      use_spot: true
    - cloud: ibm


run: hi

---
resources:
  accelerators: h100:8
  ordered:
    - cloud: kubernetes
    - cloud: aws
      use_spot: true
    - cloud: gcp


run: hi

Task from YAML spec: task.yaml
Managed job 'sky-1be1-azureuser' will be launched on (estimated):
W 05-20 07:47:36 optimizer.py:1189] Task 'sky-1be1-azureuser-0' requires IBM, Kubernetes which are not enabled. To enable access, change the task cloud requirement or run: sky check IBM Kubernetes
W 05-20 07:47:36 optimizer.py:1189] Task 'sky-1be1-azureuser-1' requires Kubernetes which is not enabled. To enable access, change the task cloud requirement or run: sky check Kubernetes
I 05-20 07:47:36 optimizer.py:978] 1st task is using user-specified accelerators list (will be tried in the listed order): Kubernetes({'A100': 8}), AWS([Spot], {'A100': 8}), IBM({'A100': 8})
I 05-20 07:47:36 optimizer.py:978] 2nd task is using user-specified accelerators list (will be tried in the listed order): Kubernetes({'H100': 8}), AWS([Spot], {'H100': 8}), GCP({'H100': 8})
I 05-20 07:47:38 optimizer.py:696] == Optimizer ==
I 05-20 07:47:38 optimizer.py:707] Target: minimizing cost
I 05-20 07:47:38 optimizer.py:722] Estimated total runtime: 2.0 hours
I 05-20 07:47:38 optimizer.py:722] Estimated total cost: $37.3
I 05-20 07:47:38 optimizer.py:722] 
I 05-20 07:47:38 optimizer.py:820] Best plan: 
I 05-20 07:47:38 optimizer.py:825] -------------------------------------------------------------------------------------------------------------
I 05-20 07:47:38 optimizer.py:825]  TASK                   #NODES   CLOUD   INSTANCE             vCPUs   Mem(GB)   ACCELERATORS   REGION/ZONE   
I 05-20 07:47:38 optimizer.py:825] -------------------------------------------------------------------------------------------------------------
I 05-20 07:47:38 optimizer.py:825]  sky-1be1-azureuser-0   1        AWS     p4d.24xlarge[Spot]   96      1152      A100:8         us-east-2b    
I 05-20 07:47:38 optimizer.py:825]  sky-1be1-azureuser-1   1        AWS     p5.48xlarge[Spot]    192     2048      H100:8         us-east-2b    
I 05-20 07:47:38 optimizer.py:825] -------------------------------------------------------------------------------------------------------------
I 05-20 07:47:38 optimizer.py:825] 
I 05-20 07:47:38 optimizer.py:844] Considered resources for task 'sky-1be1-azureuser-0' (1 node):
I 05-20 07:47:38 optimizer.py:914] -------------------------------------------------------------------------------------------------
I 05-20 07:47:38 optimizer.py:914]  CLOUD   INSTANCE             vCPUs   Mem(GB)   ACCELERATORS   REGION/ZONE   COST ($)   CHOSEN   
I 05-20 07:47:38 optimizer.py:914] -------------------------------------------------------------------------------------------------
I 05-20 07:47:38 optimizer.py:914]  AWS     p4d.24xlarge[Spot]   96      1152      A100:8         us-east-2b    5.89          ✔     
I 05-20 07:47:38 optimizer.py:914] -------------------------------------------------------------------------------------------------
I 05-20 07:47:38 optimizer.py:914] 
I 05-20 07:47:38 optimizer.py:844] Considered resources for task 'sky-1be1-azureuser-1' (1 node):
I 05-20 07:47:38 optimizer.py:914] --------------------------------------------------------------------------------------------------
I 05-20 07:47:38 optimizer.py:914]  CLOUD   INSTANCE            vCPUs   Mem(GB)   ACCELERATORS   REGION/ZONE     COST ($)   CHOSEN   
I 05-20 07:47:38 optimizer.py:914] --------------------------------------------------------------------------------------------------
I 05-20 07:47:38 optimizer.py:914]  GCP     a3-highgpu-8g       208     1872      H100:8         us-central1-a   87.83               
I 05-20 07:47:38 optimizer.py:914]  AWS     p5.48xlarge[Spot]   192     2048      H100:8         us-east-2b      31.44         ✔     
I 05-20 07:47:38 optimizer.py:914] --------------------------------------------------------------------------------------------------
I 05-20 07:47:38 optimizer.py:914] 
Launching a managed job 'sky-1be1-azureuser'. Proceed? [Y/n]:

With no cloud enabled

resources:
  accelerators: A100:8
  ordered:
    - cloud: kubernetes
    - cloud: IBM

Task from YAML spec: task.yaml
sky.exceptions.ResourcesUnavailableError: Task requires IBM, Kubernetes which are not enabled. To enable access, change the task cloud requirement or run: sky check IBM Kubernetes

For a dag:

resources:
  accelerators: A100:8
  ordered:
    - cloud: kubernetes
    - cloud: ibm


run: hi

---
resources:
  accelerators: h100:8
  ordered:
    - cloud: kubernetes
    - cloud: aws
      use_spot: true
    - cloud: gcp


run: hi

$ sky jobs launch task.yaml
Task from YAML spec: task.yaml
Managed job 'sky-7f4b-azureuser' will be launched on (estimated):
sky.exceptions.ResourcesUnavailableError: Task 'sky-7f4b-azureuser-0' requires IBM, Kubernetes which are not enabled. To enable access, change the task cloud requirement or run: sky check IBM Kubernetes

Speed up optimization

resources:
  accelerators: A100:8
  ordered:
    - cloud: kubernetes
    - cloud: aws
      use_spot: true

time sky launch task.yaml
master: 12.4s
this PR: 1.99s

Tested (run the relevant ones):

Code formatting: bash format.sh
Any manual or new tests for this PR (please specify below)
- scripts above with ordered and any_of
All smoke tests: pytest tests/test_smoke.py
Relevant individual smoke tests: pytest tests/test_smoke.py::test_fill_in_the_name
Backward compatibility tests: conda deactivate; bash -i tests/backward_compatibility_tests.sh

cblmemo

Thanks @Michaelvll for the fix! It looks mostly good to me. Left several nits and a discussion on multiple sky.check in a dag pipeline ; )

sky/optimizer.py

cblmemo · 2024-05-20T08:56:17Z

sky/optimizer.py

+        is_or_are = 'is' if len(rechecked_but_disabled_clouds) == 1 else 'are'
+        task_name = f' {task.name!r}' if task.name is not None else ''
+        msg = (
+            f'Task{task_name} requires '


Suggested change

f'Task{task_name} requires '

f'Task{task_name} requires one of '

It is not actually one of but requested all of them : )

sky/optimizer.py

Co-authored-by: Tian Xia <[email protected]>

…om:skypilot-org/skypilot into allow-unexist-cloud-in-candidate-resources

Michaelvll · 2024-05-20T18:02:03Z

Thanks for the review @cblmemo! PTAL @romilbhardwaj @cblmemo.

romilbhardwaj

Thanks @Michaelvll! Works nicely!

romilbhardwaj · 2024-05-20T19:13:37Z

sky/optimizer.py

@@ -120,6 +120,8 @@ def optimize(dag: 'dag_lib.Dag',
                for a task.
            exceptions.NoCloudAccessError: if no public clouds are enabled.
        """
+        _check_specified_clouds(dag)


nit - Can we add a quick comment why we call this method and the fact that it will run sky check on the clouds specified in resources?

Or alternatively, docstr for _check_specified_clouds would be useful

Added a docstr for the function. Thanks!

romilbhardwaj · 2024-05-20T19:17:41Z

sky/optimizer.py

+        enabled_clouds = sky_check.get_cached_enabled_clouds_or_refresh(
+            raise_if_no_cloud_access=True)


Can defer to another PR - maybe we can update sky_check.check in the future to return a list of enabled and disabled clouds

Good point! Filed an issue for this #3570. Would prefer to leave it to the future, as the semantic for the return value should be discussed when clouds argument is passed.

…unexist-cloud-in-candidate-resources

Michaelvll added 2 commits May 20, 2024 07:15

first version

2186408

refactor

e84ec49

Michaelvll marked this pull request as draft May 20, 2024 07:28

fix

9647487

Michaelvll marked this pull request as ready for review May 20, 2024 07:53

Michaelvll requested review from MaoZiming, concretevitamin, cblmemo and romilbhardwaj and removed request for concretevitamin May 20, 2024 07:53

revert is_same_cloud

a4aa491

cblmemo reviewed May 20, 2024

View reviewed changes

Michaelvll and others added 4 commits May 20, 2024 09:47

Update sky/optimizer.py

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.

GPG key ID: B5690EEEBB952194

Verified
Learn about vigilant mode

b690988

Co-authored-by: Tian Xia <[email protected]>

address comments

b3ed3b2

Merge branch 'allow-unexist-cloud-in-candidate-resources' of github.c…

d8c6c30

…om:skypilot-org/skypilot into allow-unexist-cloud-in-candidate-resources

check once for a dag

5c428c2

romilbhardwaj approved these changes May 20, 2024

View reviewed changes

Michaelvll added 3 commits May 20, 2024 19:34

Merge branch 'master' of github.com:skypilot-org/skypilot into allow-…

d2e5e79

…unexist-cloud-in-candidate-resources

fix doc str

c351f8f

format

97572c5

Michaelvll merged commit d259ddc into master May 20, 2024
20 checks passed

Michaelvll deleted the allow-unexist-cloud-in-candidate-resources branch May 20, 2024 21:02

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[Core] Allow nonexistent cloud in candidate resources and speed up optimization #3567

[Core] Allow nonexistent cloud in candidate resources and speed up optimization #3567

Michaelvll commented May 20, 2024 •

edited

Loading

cblmemo left a comment

cblmemo May 20, 2024

Michaelvll May 20, 2024

Michaelvll commented May 20, 2024

romilbhardwaj left a comment

romilbhardwaj May 20, 2024

romilbhardwaj May 20, 2024

Michaelvll May 20, 2024

romilbhardwaj May 20, 2024

Michaelvll May 20, 2024

	f'Task{task_name} requires '
	f'Task{task_name} requires one of '

		enabled_clouds = sky_check.get_cached_enabled_clouds_or_refresh(
		raise_if_no_cloud_access=True)

[Core] Allow nonexistent cloud in candidate resources and speed up optimization #3567

[Core] Allow nonexistent cloud in candidate resources and speed up optimization #3567

Conversation

Michaelvll commented May 20, 2024 • edited Loading

Allow nonexistent cloud

With at least one cloud enabled

With no cloud enabled

Speed up optimization

cblmemo left a comment

Choose a reason for hiding this comment

cblmemo May 20, 2024

Choose a reason for hiding this comment

Michaelvll May 20, 2024

Choose a reason for hiding this comment

Michaelvll commented May 20, 2024

romilbhardwaj left a comment

Choose a reason for hiding this comment

romilbhardwaj May 20, 2024

Choose a reason for hiding this comment

romilbhardwaj May 20, 2024

Choose a reason for hiding this comment

Michaelvll May 20, 2024

Choose a reason for hiding this comment

romilbhardwaj May 20, 2024

Choose a reason for hiding this comment

Michaelvll May 20, 2024

Choose a reason for hiding this comment

Michaelvll commented May 20, 2024 •

edited

Loading