Skip to content

Commit 48e7594

Browse files
authored
fix: call warm_up_process to prevent loguru blocking (#20)
1 parent 9788d66 commit 48e7594

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

ajet/backbone/main_verl.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
from torch.utils.data import Dataset as TorchDataset
2828

2929
# Create training and validation datasets.
30+
from ajet.backbone.warm_up import warm_up_process
3031
from ajet.task_reader import RouterTaskReader, task_to_standard_dataset
3132
from ajet.utils.process_dataset import create_rl_sampler
3233
from ajet.utils.core_env_vars import get_runtime_env
@@ -116,6 +117,7 @@ def run(self, config):
116117
from loguru import logger
117118
from omegaconf import OmegaConf
118119
from verl.utils.fs import copy_to_local
120+
warm_up_process(config)
119121

120122
logger.info(f"TaskRunner hostname: {socket.gethostname()}, PID: {os.getpid()}")
121123
pprint(OmegaConf.to_container(config, resolve=True))

0 commit comments

Comments
 (0)