Skip to content

Commit 8f9996a

Browse files
committed
Use new rank_zero_debug
1 parent 9b2b1bb commit 8f9996a

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

pytorch_lightning/utilities/distributed.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -290,14 +290,16 @@ def register_ddp_comm_hook(
290290

291291
if ddp_comm_wrapper is not None:
292292
if not _TORCH_GREATER_EQUAL_1_9:
293-
rank_zero_warn("Not applying DDP comm wrapper. To use communication wrapper, please use pytorch>=1.9.0.")
293+
new_rank_zero_warn(
294+
"Not applying DDP comm wrapper. To use communication wrapper, please use pytorch>=1.9.0."
295+
)
294296
else:
295297
new_rank_zero_info(
296298
f"DDP comm wrapper is provided, apply {ddp_comm_wrapper.__qualname__}({ddp_comm_hook.__qualname__})."
297299
)
298300
ddp_comm_hook = ddp_comm_wrapper(ddp_comm_hook)
299301

300-
rank_zero_debug(f"Registering DDP comm hook: {ddp_comm_hook.__qualname__}.")
302+
new_rank_zero_debug(f"Registering DDP comm hook: {ddp_comm_hook.__qualname__}.")
301303
model.register_comm_hook(state=ddp_comm_state, hook=ddp_comm_hook)
302304

303305

0 commit comments

Comments
 (0)