Skip to content

Commit

Permalink
[air] pyarrow.fs persistence: Bump some logs to INFO level (ray-p…
Browse files Browse the repository at this point in the history
…roject#38586)

This can be temporary -- to make it more obvious that we're running with the new codepath when updating release tests and CI.
  • Loading branch information
justinvyu authored and vitsai committed Aug 19, 2023
1 parent ca02af7 commit 8fdbb91
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion python/ray/train/_internal/session.py
Original file line number Diff line number Diff line change
Expand Up @@ -171,7 +171,7 @@ def noop(x):

if _use_storage_context():
assert storage
logger.debug(f"StorageContext on SESSION {world_rank}:\n{storage}")
logger.info(f"StorageContext on SESSION (rank={world_rank}):\n{storage}")

# Change the working directory to the local trial directory.
# -> All workers on the same node share a working directory.
Expand Down
6 changes: 3 additions & 3 deletions python/ray/train/_internal/storage.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
from ray.train._checkpoint import Checkpoint


logger = logging.getLogger(__file__)
logger = logging.getLogger(__name__)


def _use_storage_context() -> bool:
Expand Down Expand Up @@ -544,7 +544,7 @@ def persist_current_checkpoint(self, checkpoint: "Checkpoint") -> "Checkpoint":
# TODO(justinvyu): Fix this cyclical import.
from ray.train._checkpoint import Checkpoint

logger.debug(
logger.info(
"Copying checkpoint files to storage path:\n"
"({source_fs}, {source}) -> ({dest_fs}, {destination})".format(
source=checkpoint.path,
Expand Down Expand Up @@ -572,7 +572,7 @@ def persist_current_checkpoint(self, checkpoint: "Checkpoint") -> "Checkpoint":
filesystem=self.storage_filesystem,
path=self.checkpoint_fs_path,
)
logger.debug(f"Checkpoint successfully created at: {persisted_checkpoint}")
logger.info(f"Checkpoint successfully created at: {persisted_checkpoint}")
return persisted_checkpoint

@property
Expand Down

0 comments on commit 8fdbb91

Please sign in to comment.