Skip to content

Commit

Permalink
squashed commits
Browse files Browse the repository at this point in the history
  • Loading branch information
michaelzhiluo committed Dec 3, 2021
1 parent a35a830 commit d24baa8
Show file tree
Hide file tree
Showing 62 changed files with 992 additions and 1,163 deletions.
11 changes: 9 additions & 2 deletions .github/workflows/pylint.yml
Original file line number Diff line number Diff line change
@@ -1,8 +1,15 @@
name: Pylint

on:
- pull_request

# Trigger the workflow on push or pull request,
# but only for the main branch
push:
branches:
- master
pull_request:
branches:
- master

jobs:
pylint:
runs-on: ubuntu-latest
Expand Down
2 changes: 1 addition & 1 deletion .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ plotting/*.pdf
plotting/*.png

prototype/**/*.yml
prototype/config/*.sh
prototype/config/**/*.sh
prototype/*.egg-info/
prototype/**/*.tmp

Expand Down
2 changes: 2 additions & 0 deletions .pylintrc
Original file line number Diff line number Diff line change
Expand Up @@ -85,6 +85,8 @@ disable=abstract-method,
intern-builtin,
invalid-str-codec,
locally-disabled,
logging-format-interpolation, # FIXME(sky): make pass.
logging-fstring-interpolation, # FIXME(sky): make pass.
long-builtin,
long-suffix,
map-builtin-not-iterating,
Expand Down
1 change: 1 addition & 0 deletions prototype/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
## Setup

```bash
pip install -r requirements.txt
pip install -e .

python examples/resnet_app.py
Expand Down
10 changes: 6 additions & 4 deletions prototype/cli/cli.py
Original file line number Diff line number Diff line change
Expand Up @@ -163,15 +163,17 @@ def run(entry_point, cluster, dryrun):
with sky.Dag() as dag:
task = sky.Task.from_yaml(entry_point)

# TODO: This is sketchy. What if we're reusing a cluster and the optimized plan is different?
dag = sky.optimize(dag, minimize=sky.Optimizer.COST)

handle = None
if cluster is not None:
new_task = dag.tasks[0]
handle = _reuse_or_provision_cluster(new_task, cluster)

sky.execute(dag, dryrun=dryrun, handle=handle, stream_logs=stream_logs)
# TODO: This is sketchy. What if we're reusing a cluster and the optimized plan is different?
sky.execute(dag,
dryrun=dryrun,
handle=handle,
stream_logs=stream_logs,
optimize_target=sky.OptimizeTarget.COST)


@cli.command()
Expand Down
82 changes: 0 additions & 82 deletions prototype/config/aws-distributed.yml.j2

This file was deleted.

58 changes: 0 additions & 58 deletions prototype/config/aws.yml.j2

This file was deleted.

69 changes: 0 additions & 69 deletions prototype/config/azure.yml.j2

This file was deleted.

71 changes: 0 additions & 71 deletions prototype/config/gcp.yml.j2

This file was deleted.

1 change: 0 additions & 1 deletion prototype/examples/containerized_app.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,5 +24,4 @@
t = sky.Task(run=run_command, setup=setup_cmd)
t.set_resources(sky.Resources(sky.AWS(), accelerators='V100'))

dag = sky.optimize(dag)
sky.execute(dag)
41 changes: 0 additions & 41 deletions prototype/examples/debug_distributed_app.py

This file was deleted.

0 comments on commit d24baa8

Please sign in to comment.