Skip to content

Commit 630dbc7

Browse files
krfrickematthewdeng
authored andcommitted
[tune] Storage: πŸ™ 🧠 Tune tests and examples {using RLlib} migration (ray-project#38895)
Signed-off-by: Kai Fricke <kai@anyscale.com> Co-authored-by: matthewdeng <matt@anyscale.com>
1 parent 250373a commit 630dbc7

File tree

5 files changed

+225
-289
lines changed

5 files changed

+225
-289
lines changed

β€Ž.buildkite/pipeline.ml.yml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -341,7 +341,6 @@
341341
- TUNE_TESTING=1 ./ci/env/install-dependencies.sh
342342
- ./ci/env/env_info.sh
343343
- bazel test --config=ci $(./ci/run/bazel_export_options) --build_tests_only --test_tag_filters=-gpu_only,rllib
344-
--test_env=RAY_AIR_NEW_PERSISTENCE_MODE=0
345344
python/ray/tune/...
346345

347346
- label: ":octopus: ML library integrations tests and examples."

β€Žpython/ray/tune/analysis/experiment_analysis.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -680,7 +680,11 @@ def _retrieve_rows(
680680
assert not mode or metric
681681
rows = {}
682682
for path, df in self.trial_dataframes.items():
683-
if mode == "max":
683+
if df.empty:
684+
continue
685+
if metric not in df:
686+
idx = -1
687+
elif mode == "max":
684688
idx = df[metric].idxmax()
685689
elif mode == "min":
686690
idx = df[metric].idxmin()

β€Žpython/ray/tune/experiment/trial.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1082,7 +1082,7 @@ def should_checkpoint(self):
10821082

10831083
def has_checkpoint(self):
10841084
if _use_storage_context():
1085-
return self.checkpoint.path is not None
1085+
return self.checkpoint is not None
10861086
return self.checkpoint.dir_or_data is not None
10871087

10881088
def clear_checkpoint(self):

0 commit comments

Comments
Β (0)