mv get_event_loop to ray_utils

Author: baymax591

recipe/one_step_off_policy/fsdp_workers.py

@@ -41,7 +41,7 @@
 from verl.utils.model import get_generation_config, update_model_config
 from verl.utils.profiler import DistProfiler, DistProfilerExtension, ProfilerConfig, log_gpu_memory_usage, simple_timer
 from verl.utils.profiler.performance import reduce_timing, topk_reduce_ratio_min_max
-from verl.utils.event_loop import get_event_loop
+from verl.utils.asyncio_utils import get_event_loop
 from verl.workers.config import HFModelConfig, RolloutConfig
 from verl.workers.fsdp_workers import ActorRolloutRefWorker as ARRWorker
 from verl.workers.fsdp_workers import CriticWorker

verl/utils/event_loop.py renamed to verl/utils/asyncio_utils.py

@@ -16,7 +16,7 @@
 import asyncio
 
 
-def get_evnet_loop():
+def get_event_loop():
     try:
         loop = asyncio.get_event_loop()
     except RuntimeError:

verl/workers/fsdp_workers.py

@@ -85,7 +85,7 @@
 from verl.utils.profiler import DistProfiler, DistProfilerExtension, ProfilerConfig, log_gpu_memory_usage, simple_timer
 from verl.utils.profiler.performance import reduce_timing, topk_reduce_ratio_min_max
 from verl.utils.py_functional import convert_to_regular_types
-from verl.utils.event_loop import get_event_loop
+from verl.utils.asyncio_utils import get_event_loop
 from verl.workers.config import FSDPCriticConfig, FSDPEngineConfig, HFModelConfig, RolloutConfig
 from verl.workers.rollout import get_rollout_class
 from verl.workers.sharding_manager.fsdp_ulysses import FSDPUlyssesShardingManager

verl/workers/megatron_workers.py

@@ -69,7 +69,7 @@
     simple_timer,
 )
 from verl.utils.profiler.performance import reduce_timing, topk_reduce_ratio_min_max
-from verl.utils.event_loop import get_event_loop
+from verl.utils.asyncio_utils import get_event_loop
 from verl.workers.actor.megatron_actor import MegatronPPOActor
 from verl.workers.config import HFModelConfig, McoreCriticConfig, RolloutConfig
 from verl.workers.critic.megatron_critic import MegatronPPOCritic