verl/HybridFlow: A Flexible and Efficient RL Post-Training Framework
2866 matches across 17 categories. Click a row to expand file-level details.
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tests/test_protocol_v2_on_cpu.py | 67 | def test_tensor_dict_constructor(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 92 | def test_index_select_tensor_dict(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 152 | def test_tensordict_with_images(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 180 | def test_tensordict_with_packing(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 269 | def test_tensor_dict_make_iterator(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 509 | def test_torch_save_data_proto(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 654 | def test_dataproto_chunk_after_index(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 697 | def test_concat_nested_tensor(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 923 | def test_assign_non_tensor_stack_with_nested_lists(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 938 | def test_assign_non_tensor_stack_with_nested_dicts(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 953 | def test_assign_non_tensor_stack_with_complex_nested(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 972 | def test_assign_non_tensor_handles_wrappers(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 987 | def test_assign_non_tensor_stack_batch_size_check(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 995 | def test_assign_non_tensor_with_auto_detection(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 1018 | def test_get_tensordict_with_nested_lists(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 1033 | def test_get_tensordict_with_nested_dicts(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 1045 | def test_get_tensordict_with_complex_nested_structures(): |
| LOW | tests/test_protocol_v2_on_cpu.py | 1060 | def test_get_tensordict_agent_loop_scenario(): |
| LOW | tests/test_base_config_on_cpu.py | 33 | def test_getitem_nonexistent_attribute(base_config_mock): |
| LOW | tests/test_base_config_on_cpu.py | 39 | def test_getitem_invalid_key_type(base_config_mock): |
| LOW | tests/test_protocol_on_cpu.py | 141 | def test_tensor_dict_constructor(): |
| LOW | tests/test_protocol_on_cpu.py | 155 | def test_tensor_dict_make_iterator(): |
| LOW | tests/test_protocol_on_cpu.py | 219 | def test_concat_metrics_from_multiple_workers(): |
| LOW | tests/test_protocol_on_cpu.py | 249 | def test_concat_with_empty_and_non_list_meta_info(): |
| LOW | tests/test_protocol_on_cpu.py | 272 | def test_concat_first_worker_missing_metrics(): |
| LOW | tests/test_protocol_on_cpu.py | 295 | def test_concat_non_list_metrics(): |
| LOW | tests/test_protocol_on_cpu.py | 315 | def test_concat_merge_different_non_metric_keys(): |
| LOW | tests/test_protocol_on_cpu.py | 339 | def test_concat_conflicting_non_metric_keys(): |
| LOW | tests/test_protocol_on_cpu.py | 447 | def test_dataproto_fold_unfold(): |
| LOW | tests/test_protocol_on_cpu.py | 470 | def test_torch_save_data_proto(): |
| LOW | tests/test_protocol_on_cpu.py | 570 | def test_old_vs_new_from_single_dict(): |
| LOW | tests/test_protocol_on_cpu.py | 642 | def test_dataproto_unfold_column_chunks(): |
| LOW | tests/test_protocol_on_cpu.py | 708 | def test_dataproto_chunk_after_index(): |
| LOW | tests/test_protocol_on_cpu.py | 785 | def test_to_tensordict_with_nested_lists(): |
| LOW | tests/test_protocol_on_cpu.py | 810 | def test_to_tensordict_with_nested_dicts(): |
| LOW | tests/test_protocol_on_cpu.py | 834 | def test_to_tensordict_with_complex_nested_structures(): |
| LOW | tests/test_protocol_on_cpu.py | 862 | def test_to_tensordict_and_back_with_nested_data(): |
| LOW | tests/test_protocol_on_cpu.py | 926 | def test_to_tensordict_agent_loop_scenario(): |
| LOW | tests/test_protocol_on_cpu.py | 993 | def test_serialize_deserialize_single_tensor(): |
| LOW | tests/test_protocol_on_cpu.py | 1010 | def test_serialize_deserialize_tensordict_regular_tensors(): |
| LOW | tests/test_protocol_on_cpu.py | 1039 | def test_serialize_deserialize_tensordict_nested_tensors(): |
| LOW | tests/test_protocol_on_cpu.py | 1092 | def test_serialize_deserialize_tensordict_mixed_types(): |
| LOW | tests/test_protocol_on_cpu.py | 1177 | def test_serialize_deserialize_tensordict_with_device(): |
| LOW | tests/test_protocol_on_cpu.py | 1208 | def test_serialize_dataproto_with_empty_tensordict(): |
| LOW | …l/fully_async_policy/test_async_genrm_config_on_cpu.py | 76 | def _validate_async_rm_config(config): |
| LOW | …l/fully_async_policy/test_async_genrm_config_on_cpu.py | 92 | def test_rm_enabled_standalone_passes(self): |
| LOW | …l/fully_async_policy/test_async_genrm_config_on_cpu.py | 98 | def test_rm_enabled_colocate_fails(self): |
| LOW | tests/experimental/vla/test_sim_envs.py | 37 | def test_sim_env_creation_and_step(simulator_type): |
| LOW | …ts/experimental/reward_loop/test_reward_model_disrm.py | 107 | def test_reward_model_manager(): |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 71 | def mock_sync_reward_function( |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 83 | async def mock_async_reward_function( |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 106 | async def mock_failing_api_function( |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 114 | async def mock_dict_result_function( |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 169 | async def test_basic_reward_computation(self, tokenizer): |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 258 | async def test_concurrency_limiting(self, tokenizer): |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 351 | async def test_sync_reward_function(self, tokenizer): |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 366 | async def test_combined_rate_limits(self, tokenizer): |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 402 | async def test_correct_vs_incorrect_answers(self, tokenizer): |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 463 | async def test_class_initialization_once(self, tokenizer): |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 482 | async def mock_reward_with_extra_info( |
| 1078 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | pyproject.toml | 1 | # ------------------------------- |
| MEDIUM | pyproject.toml | 3 | # ------------------------------- |
| MEDIUM | pyproject.toml | 11 | # ------------------------------- |
| MEDIUM | pyproject.toml | 13 | # ------------------------------- |
| MEDIUM | pyproject.toml | 26 | # ------------------------------- |
| MEDIUM | pyproject.toml | 28 | # ------------------------------- |
| MEDIUM | pyproject.toml | 68 | # ------------------------------- |
| MEDIUM | pyproject.toml | 70 | # ------------------------------- |
| MEDIUM | pyproject.toml | 90 | # ------------------------------- |
| MEDIUM | pyproject.toml | 92 | # ------------------------------- |
| MEDIUM | tests/experimental/agent_loop/test_basic_agent_loop.py | 411 | # ────────────────────────────────────────────────────────────────────── |
| MEDIUM | tests/experimental/agent_loop/test_basic_agent_loop.py | 413 | # ────────────────────────────────────────────────────────────────────── |
| MEDIUM | tests/tools/test_function_tool_on_cpu.py | 52 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/tools/test_function_tool_on_cpu.py | 54 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/tools/test_function_tool_on_cpu.py | 331 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/tools/test_function_tool_on_cpu.py | 333 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/tools/test_function_tool_on_cpu.py | 491 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/tools/test_function_tool_on_cpu.py | 493 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/tools/test_function_tool_on_cpu.py | 586 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/tools/test_function_tool_on_cpu.py | 588 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/utils/test_bucketed_weight_transfer.py | 61 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/utils/test_bucketed_weight_transfer.py | 63 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/utils/test_bucketed_weight_transfer.py | 95 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/utils/test_bucketed_weight_transfer.py | 97 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/utils/test_bucketed_weight_transfer.py | 145 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/utils/test_bucketed_weight_transfer.py | 147 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/utils/test_bucketed_weight_transfer.py | 181 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/utils/test_bucketed_weight_transfer.py | 183 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 103 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 105 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 123 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 125 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 142 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 144 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 292 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 294 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 317 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 319 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 333 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 335 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 348 | # =========================================================== |
| MEDIUM | tests/utils/veomni/test_router_replay_on_cpu.py | 350 | # =========================================================== |
| MEDIUM | tests/models/test_fused_kernels_ulysses_sp_on_cpu.py | 50 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/models/test_fused_kernels_ulysses_sp_on_cpu.py | 52 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/models/test_fused_kernels_ulysses_sp_on_cpu.py | 94 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/models/test_fused_kernels_ulysses_sp_on_cpu.py | 98 | # --------------------------------------------------------------------------- |
| MEDIUM | …ts/workers/test_router_replay_engine_helpers_on_cpu.py | 113 | # =========================================================== |
| MEDIUM | …ts/workers/test_router_replay_engine_helpers_on_cpu.py | 115 | # =========================================================== |
| MEDIUM | tests/workers/test_engine_workers_lora_sync.py | 118 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/workers/test_engine_workers_lora_sync.py | 120 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/workers/test_engine_workers_lora_sync.py | 259 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/workers/test_engine_workers_lora_sync.py | 261 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/workers/test_engine_workers_lora_sync.py | 317 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/workers/test_engine_workers_lora_sync.py | 319 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/workers/test_engine_workers_lora_sync.py | 360 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/workers/test_engine_workers_lora_sync.py | 362 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/workers/test_engine_workers_lora_sync.py | 31 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/workers/test_engine_workers_lora_sync.py | 33 | # --------------------------------------------------------------------------- |
| MEDIUM | …orkers/rollout/rollout_sglang/test_lora_sleep_level.py | 29 | # --------------------------------------------------------------------------- |
| MEDIUM | …orkers/rollout/rollout_sglang/test_lora_sleep_level.py | 32 | # --------------------------------------------------------------------------- |
| 117 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | setup.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/test_protocol_v2_on_cpu.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/test_protocol_v2_on_cpu.py | 581 | # assert result_np_bool.keys() == data.keys() |
| LOW | tests/test_base_config_on_cpu.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/__init__.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/test_protocol_on_cpu.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/experimental/fully_async_policy/__init__.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | …l/fully_async_policy/test_async_genrm_config_on_cpu.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/experimental/vla/test_sim_envs.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | …ts/experimental/reward_loop/test_reward_model_disrm.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | …reward_loop/test_rate_limited_reward_manager_on_cpu.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | …ental/reward_loop/test_agent_reward_loop_standalone.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/experimental/reward_loop/test_math_verify.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | …imental/reward_loop/test_agent_reward_loop_colocate.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | …ts/experimental/reward_loop/test_reward_model_genrm.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | …rimental/reward_loop/test_async_token_bucket_on_cpu.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/experimental/reward_loop/reward_fn.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/experimental/agent_loop/test_multi_modal.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/experimental/agent_loop/test_call_tool_on_cpu.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/experimental/agent_loop/test_basic_agent_loop.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/experimental/agent_loop/agent_utils.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | …sts/experimental/agent_loop/test_standalone_rollout.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | …mental/agent_loop/test_audio_server_contract_on_cpu.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/experimental/agent_loop/function_tool_examples.py | 1 | # Copyright 2026 Bytedance Ltd. and/or its affiliates |
| LOW | …ent_loop/test_agent_loop_extra_fields_schema_on_cpu.py | 1 | # Copyright 2026 Bytedance Ltd. and/or its affiliates |
| LOW | …ts/experimental/agent_loop/test_gpt_oss_tool_parser.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/tools/test_mixed_tools_on_cpu.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/tools/__init__.py | 1 | # Copyright 2026 Bytedance Ltd. and/or its affiliates |
| LOW | tests/tools/test_function_tool_on_cpu.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/tools/_stub_search_tools.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/check_docstrings.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/check_device_api_usage.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/check_dataproto_usage.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/test_check_example_naming.py | 1 | # Copyright 2026 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/check_license.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/check_api_docs.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/check_pr_description.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/validate_imported_docs.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/check_example_naming.py | 1 | # Copyright 2026 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/test_import.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/check_docs_time_info.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/test_config_docs.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/type_coverage_check.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/validate_structure.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/special_sanity/check_pr_title.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_bucketed_weight_transfer.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_linear_cross_entropy.py | 1 | # |
| LOW | tests/utils/test_fsdp_wrap_policy_on_cpu.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_shared_memory.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_config_on_cpu.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_torch_profile.py | 1 | # Copyright 2026 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_rollout_trace_on_cpu.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_temp_env_on_cpu.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_timeout_decorator_cpu.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_nvtx_profile.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_nvtx_profile.py | 141 | # def test_annotate_discrete_mode(self): |
| LOW | tests/utils/test_tracking_on_cpu.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_mlflow_key_sanitization.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/test_check_profiler_output.py | 1 | # Copyright 2026 Bytedance Ltd. and/or its affiliates |
| LOW | tests/utils/_test_module.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates |
| 608 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tests/test_protocol_on_cpu.py | 1115 | except Exception: |
| LOW | tests/test_protocol_on_cpu.py | 1228 | except Exception as e: |
| LOW | tests/experimental/reward_loop/reward_fn.py | 50 | except Exception as e: |
| LOW | tests/experimental/reward_loop/reward_fn.py | 82 | except Exception: |
| LOW | tests/experimental/agent_loop/test_multi_modal.py | 122 | except Exception as e: |
| LOW | tests/experimental/agent_loop/test_basic_agent_loop.py | 154 | except Exception as e: |
| LOW | tests/experimental/agent_loop/test_basic_agent_loop.py | 186 | except Exception as e: |
| LOW | tests/experimental/agent_loop/function_tool_examples.py | 69 | except Exception as e: |
| LOW | tests/special_sanity/check_docstrings.py | 83 | except Exception as e: |
| MEDIUM | tests/special_sanity/check_docstrings.py | 84 | print(f"Error processing {filepath}: {e}") |
| LOW | tests/special_sanity/check_api_docs.py | 68 | except Exception as exc: |
| LOW | tests/special_sanity/check_pr_description.py | 54 | except Exception as e: |
| LOW | tests/special_sanity/check_pr_description.py | 63 | except Exception as e: |
| MEDIUM | tests/special_sanity/check_pr_description.py | 58 | def load_pr_body(event_path): |
| LOW | tests/special_sanity/validate_imported_docs.py | 88 | except Exception: # pragma: no cover – wide net for import quirks |
| MEDIUM | tests/special_sanity/check_docs_time_info.py | 54 | print(f"Error: Documentation directory '{DOCS_DIR}' does not exist.", file=sys.stderr) |
| LOW | tests/special_sanity/type_coverage_check.py | 50 | except Exception: |
| LOW | tests/utils/test_shared_memory.py | 218 | except Exception as e: |
| MEDIUM | tests/utils/test_shared_memory.py | 219 | print(f"Error in child process: {e}") |
| LOW | tests/utils/test_timeout_decorator_cpu.py | 77 | except Exception as e: |
| LOW | tests/utils/test_timeout_decorator_cpu.py | 170 | except Exception as e: |
| LOW | tests/utils/test_timeout_decorator_cpu.py | 182 | except Exception as e: |
| LOW | tests/utils/test_timeout_decorator_cpu.py | 211 | except Exception as e: |
| LOW | tests/utils/test_timeout_decorator_cpu.py | 223 | except Exception as e: |
| MEDIUM | tests/utils/test_timeout_decorator_cpu.py | 164 | def slow_task_in_thread(): |
| MEDIUM | tests/utils/test_timeout_decorator_cpu.py | 176 | def thread_target(): |
| MEDIUM | tests/utils/test_timeout_decorator_cpu.py | 205 | def slow_task_in_thread(): |
| MEDIUM | tests/utils/test_timeout_decorator_cpu.py | 217 | def thread_target(): |
| LOW | tests/utils/test_check_profiler_output.py | 147 | except Exception as e: |
| LOW | …kers/rollout/rollout_sglang/test_http_server_engine.py | 902 | except Exception: |
| LOW | tests/special_e2e/check_results.py | 30 | except Exception: |
| LOW | tests/trainer/ppo/test_rollout_corr.py | 428 | except Exception as e: |
| LOW | …rl/experimental/fully_async_policy/fully_async_main.py | 194 | except Exception as e: |
| LOW | …rl/experimental/fully_async_policy/fully_async_main.py | 202 | except Exception as e: |
| LOW | verl/experimental/fully_async_policy/detach_utils.py | 354 | except Exception as e: |
| LOW | verl/experimental/fully_async_policy/message_queue.py | 159 | except Exception: |
| LOW | …perimental/fully_async_policy/fully_async_rollouter.py | 341 | except Exception as e: |
| LOW | …perimental/fully_async_policy/fully_async_rollouter.py | 286 | except Exception as e: |
| LOW | …perimental/fully_async_policy/fully_async_rollouter.py | 989 | except Exception as e: |
| LOW | …perimental/fully_async_policy/fully_async_rollouter.py | 1035 | except Exception as e: |
| LOW | …experimental/fully_async_policy/fully_async_trainer.py | 266 | except Exception as e: |
| LOW | …l/fully_async_policy/unittest/simple_streaming_demo.py | 111 | except Exception as e: |
| LOW | verl/experimental/reward_loop/reward_loop.py | 181 | except Exception as e: |
| LOW | verl/experimental/reward_loop/reward_manager/limited.py | 460 | except Exception as e: |
| LOW | verl/experimental/reward_loop/router/naive_router.py | 40 | except Exception: |
| LOW | verl/experimental/reward_loop/router/naive_router.py | 43 | except Exception: |
| LOW | verl/experimental/reward_loop/router/naive_router.py | 165 | except Exception as e: |
| LOW | verl/experimental/agent_loop/tool_parser.py | 119 | except Exception as e: |
| LOW | verl/experimental/agent_loop/tool_parser.py | 176 | except Exception as e: |
| LOW | verl/experimental/agent_loop/tool_parser.py | 246 | except Exception: |
| LOW | verl/experimental/agent_loop/tool_parser.py | 258 | except Exception: |
| LOW | verl/experimental/agent_loop/tool_parser.py | 277 | except Exception: |
| LOW | verl/experimental/agent_loop/tool_parser.py | 284 | except Exception: |
| LOW | verl/experimental/agent_loop/tool_parser.py | 351 | except Exception as e: |
| LOW | verl/experimental/agent_loop/tool_parser.py | 425 | except Exception as e: |
| LOW | verl/experimental/agent_loop/tool_agent_loop.py | 453 | except Exception as e: |
| LOW | verl/experimental/one_step_off_policy/ray_trainer.py | 215 | except Exception as e: |
| MEDIUM | verl/experimental/one_step_off_policy/ray_trainer.py | 216 | print(f"Error in async_gen_next_batch: {e}") |
| LOW | verl/model_merger/base_model_merger.py | 248 | except Exception as e: |
| LOW | verl/model_merger/base_model_merger.py | 438 | except Exception as e: |
| 160 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tests/test_protocol_v2_on_cpu.py | 802 | |
| LOW | tests/test_protocol_on_cpu.py | 1092 | |
| LOW | tests/experimental/agent_loop/test_multi_modal.py | 76 | |
| LOW | …mental/agent_loop/test_audio_server_contract_on_cpu.py | 30 | |
| LOW | tests/special_sanity/check_pr_description.py | 40 | |
| LOW | tests/special_sanity/validate_imported_docs.py | 63 | |
| LOW | tests/special_sanity/test_config_docs.py | 19 | |
| LOW | tests/special_sanity/type_coverage_check.py | 34 | |
| LOW | tests/special_sanity/type_coverage_check.py | 87 | |
| LOW | tests/utils/test_linear_cross_entropy.py | 113 | |
| LOW | tests/utils/test_special_linear_cross_entropy_tp.py | 207 | |
| LOW | tests/utils/test_fsdp_lora_merge.py | 37 | |
| LOW | tests/utils/test_fsdp_lora_merge.py | 225 | |
| LOW | tests/utils/test_special_megatron_kl_loss_tp.py | 55 | |
| LOW | …sts/utils/dataset/test_multiturn_sft_dataset_on_cpu.py | 245 | |
| LOW | …eward_score/reward_score/test_sandbox_fusion_on_cpu.py | 127 | |
| LOW | tests/special_distributed/test_tensor_dict.py | 28 | |
| LOW | …ts/workers/rollout/rollout_trtllm/test_trtllm_abort.py | 32 | |
| LOW | tests/workers/rollout/rollout_vllm/test_vllm_abort.py | 29 | |
| LOW | verl/protocol.py | 546 | |
| LOW | verl/protocol.py | 917 | |
| LOW | …rl/experimental/fully_async_policy/fully_async_main.py | 176 | |
| LOW | verl/experimental/fully_async_policy/detach_utils.py | 253 | |
| LOW | …perimental/fully_async_policy/fully_async_rollouter.py | 848 | |
| LOW | …l/fully_async_policy/unittest/simple_streaming_demo.py | 85 | |
| LOW | …experimental/reward_loop/router/inner_sglang_router.py | 30 | |
| LOW | verl/experimental/agent_loop/tool_parser.py | 207 | |
| LOW | verl/experimental/agent_loop/tool_parser.py | 379 | |
| LOW | verl/experimental/agent_loop/tool_parser.py | 218 | |
| LOW | verl/experimental/agent_loop/tool_agent_loop.py | 125 | |
| LOW | verl/experimental/agent_loop/tool_agent_loop.py | 287 | |
| LOW | verl/experimental/separation/ray_trainer.py | 499 | |
| LOW | verl/model_merger/megatron_model_merger.py | 358 | |
| LOW | verl/model_merger/base_model_merger.py | 189 | |
| LOW | verl/model_merger/fsdp_model_merger.py | 143 | |
| LOW | verl/utils/torch_functional.py | 507 | |
| LOW | verl/utils/torch_functional.py | 1008 | |
| LOW | verl/utils/megatron_utils.py | 214 | |
| LOW | verl/utils/megatron_utils.py | 472 | |
| LOW | verl/utils/megatron_utils.py | 549 | |
| LOW | verl/utils/megatron_utils.py | 597 | |
| LOW | verl/utils/megatron_utils.py | 638 | |
| LOW | verl/utils/megatron_utils.py | 679 | |
| LOW | verl/utils/megatron_utils.py | 725 | |
| LOW | verl/utils/megatron_utils.py | 766 | |
| LOW | verl/utils/megatron_utils.py | 1051 | |
| LOW | verl/utils/megatron_utils.py | 1196 | |
| LOW | verl/utils/megatron_utils.py | 1341 | |
| LOW | verl/utils/megatron_utils.py | 1534 | |
| LOW | verl/utils/megatron_utils.py | 1590 | |
| LOW | verl/utils/megatron_utils.py | 1638 | |
| LOW | verl/utils/megatron_utils.py | 616 | |
| LOW | verl/utils/megatron_utils.py | 657 | |
| LOW | verl/utils/megatron_utils.py | 777 | |
| LOW | verl/utils/rollout_trace.py | 133 | |
| LOW | verl/utils/rollout_trace.py | 318 | |
| LOW | verl/utils/rollout_trace.py | 71 | |
| LOW | verl/utils/rollout_trace.py | 320 | |
| LOW | verl/utils/rollout_trace.py | 404 | |
| LOW | verl/utils/chat_template.py | 69 | |
| 178 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …mental/agent_loop/test_audio_server_contract_on_cpu.py | 15 | |
| LOW | …ent_loop/test_agent_loop_extra_fields_schema_on_cpu.py | 15 | |
| LOW | tests/tools/test_mixed_tools_on_cpu.py | 22 | |
| LOW | tests/tools/test_function_tool_on_cpu.py | 16 | |
| LOW | tests/tools/_stub_search_tools.py | 18 | |
| LOW | tests/special_sanity/test_check_example_naming.py | 17 | |
| LOW | tests/special_sanity/check_api_docs.py | 28 | |
| LOW | tests/special_sanity/validate_imported_docs.py | 22 | |
| LOW | tests/special_sanity/check_example_naming.py | 41 | |
| LOW | tests/special_sanity/validate_structure.py | 32 | |
| LOW | tests/workers/test_engine_workers_lora_sync.py | 26 | |
| LOW | tests/workers/rollout/test_pd_disaggregation.py | 16 | |
| LOW | …orkers/rollout/rollout_sglang/test_lora_sleep_level.py | 22 | |
| LOW | tests/special_e2e/envs/__init__.py | 15 | |
| LOW | tests/special_e2e/envs/digit_completion/__init__.py | 17 | |
| LOW | tests/special_e2e/envs/digit_completion/__init__.py | 17 | |
| LOW | verl/__init__.py | 21 | |
| LOW | verl/experimental/teacher_loop/__init__.py | 15 | |
| LOW | verl/experimental/reward_loop/__init__.py | 15 | |
| LOW | verl/experimental/reward_loop/__init__.py | 15 | |
| LOW | verl/experimental/reward_loop/__init__.py | 15 | |
| LOW | verl/experimental/reward_loop/__init__.py | 16 | |
| LOW | …rl/experimental/reward_loop/reward_manager/__init__.py | 15 | |
| LOW | …rl/experimental/reward_loop/reward_manager/__init__.py | 15 | |
| LOW | …rl/experimental/reward_loop/reward_manager/__init__.py | 16 | |
| LOW | …rl/experimental/reward_loop/reward_manager/__init__.py | 17 | |
| LOW | …rl/experimental/reward_loop/reward_manager/__init__.py | 18 | |
| LOW | …rl/experimental/reward_loop/reward_manager/__init__.py | 19 | |
| LOW | …rl/experimental/reward_loop/reward_manager/__init__.py | 20 | |
| LOW | verl/experimental/agent_loop/__init__.py | 15 | |
| LOW | verl/experimental/agent_loop/__init__.py | 15 | |
| LOW | verl/experimental/agent_loop/__init__.py | 15 | |
| LOW | verl/experimental/agent_loop/__init__.py | 15 | |
| LOW | verl/experimental/agent_loop/__init__.py | 15 | |
| LOW | verl/tools/tool_registry.py | 15 | |
| LOW | verl/tools/function_tool.py | 18 | |
| LOW | verl/model_merger/megatron_model_merger.py | 28 | |
| LOW | verl/utils/transformers_compat.py | 28 | |
| LOW | verl/utils/groupwise.py | 41 | |
| LOW | verl/utils/ulysses.py | 29 | |
| LOW | verl/utils/__init__.py | 16 | |
| LOW | verl/utils/__init__.py | 16 | |
| LOW | verl/utils/__init__.py | 17 | |
| LOW | verl/utils/__init__.py | 17 | |
| LOW | verl/utils/__init__.py | 18 | |
| LOW | verl/utils/__init__.py | 18 | |
| LOW | verl/utils/__init__.py | 18 | |
| LOW | verl/utils/__init__.py | 18 | |
| LOW | verl/utils/__init__.py | 18 | |
| LOW | verl/utils/activation_offload.py | 18 | |
| LOW | verl/utils/checkpoint/__init__.py | 15 | |
| LOW | verl/utils/checkpoint/__init__.py | 15 | |
| LOW | verl/utils/qat/__init__.py | 33 | |
| LOW | verl/utils/qat/__init__.py | 33 | |
| LOW | verl/utils/qat/__init__.py | 33 | |
| LOW | verl/utils/qat/__init__.py | 33 | |
| LOW | verl/utils/qat/__init__.py | 33 | |
| LOW | verl/utils/qat/__init__.py | 40 | |
| LOW | verl/utils/qat/__init__.py | 40 | |
| LOW | verl/utils/qat/__init__.py | 40 | |
| 143 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | docs/data/transfer_queue.md | 238 | Sample a batch of indices from the ready indices. Args: ready_indexes: List of global indices for which all |
| HIGH | verl/base_config.py | 56 | Implement the [] operator for the class. Allows accessing attributes like dictionary items. Args: k |
| HIGH | verl/protocol.py | 676 | Slice the DataProto and return a new DataProto object. This is an improved version of direct slicing wh |
| HIGH | verl/experimental/fully_async_policy/detach_utils.py | 87 | Assemble gen_batch_output from RolloutSample objects Assembles batches from RolloutSample objects, similar to t |
| HIGH | verl/experimental/reward_loop/reward_manager/limited.py | 91 | Acquire tokens from the bucket, waiting if necessary. This method will block (using asyncio.sleep) until suffic |
| HIGH | verl/experimental/agent_loop/utils.py | 20 | Resolve agent loop configuration file path. In multi-node Ray training, relative paths may not resolve correctly |
| HIGH | verl/tools/base_tool.py | 63 | Execute the tool. Args: instance_id: The instance id of the tool. parameters: The json |
| HIGH | verl/utils/seqlen_balancing.py | 214 | Calculates partitions of indices from seqlen_list such that the sum of sequence lengths in each partition is ba |
| HIGH | verl/utils/torch_functional.py | 106 | Compute log-probabilities using Flash Attention's optimized cross-entropy. Uses the Flash Attention library's Trito |
| HIGH | verl/utils/py_functional.py | 57 | Decorator to add a timeout to a function. Args: seconds: The timeout duration in seconds. use_ |
| HIGH | verl/utils/device.py | 280 | Check if the given software and CANN versions support IPC. Compares the software version and CANN toolkit version a |
| HIGH | verl/utils/model.py | 806 | Extract LoRA rank from adapter configuration file. Args: adapter_path: Path to LoRA adapter directory |
| HIGH | verl/utils/import_utils.py | 209 | Load a class from its fully qualified name. Args: fqn: Fully qualified class name (e.g., 'mypackage.module. |
| HIGH | verl/utils/tensordict_utils.py | 186 | Concatenate multiple nested tensors along the batch dimension. Takes a list of nested tensors with jagged layout an |
| HIGH | verl/utils/tensordict_utils.py | 222 | Handle concatenation of TensorDicts with empty batch size. For TensorDicts that contain only metadata (NonTensorDat |
| HIGH | verl/utils/tensordict_utils.py | 248 | Concatenate multiple TensorDicts along dimension zero. Combines a list of TensorDicts into a single TensorDict by c |
| HIGH | verl/utils/tensordict_utils.py | 303 | Split a TensorDict into equal-sized chunks with special nested tensor handling. Divides a TensorDict into the speci |
| HIGH | verl/utils/tensordict_utils.py | 459 | Select rows from a TensorDict using indices. Creates a new TensorDict containing only the rows specified by indices |
| HIGH | verl/utils/tensordict_utils.py | 514 | Merge two TensorDicts, adding keys from the second to the first. Performs an in-place union of two TensorDicts. Key |
| HIGH | verl/utils/tensordict_utils.py | 560 | Create an iterator that yields mini-batches from a TensorDict. Wraps a TensorDict in a DataLoader-style iterator th |
| HIGH | verl/utils/tensordict_utils.py | 699 | Extract a subset of keys from a TensorDict into a new TensorDict. Creates a new TensorDict containing only the spec |
| HIGH | verl/utils/tensordict_utils.py | 773 | Remove multiple keys from a TensorDict and return them as a new TensorDict. Removes the specified keys from the sou |
| HIGH | verl/utils/tensordict_utils.py | 814 | Pad a TensorDict's batch dimension to be divisible by a given divisor. If the TensorDict's length is not evenly div |
| HIGH | verl/utils/fsdp_utils.py | 439 | Get the full state dict from an FSDP model. Args: model (torch.nn.Module): The FSDP model to get state |
| HIGH | verl/utils/dataset/rl_dataset.py | 480 | split the dataset into num_splits sub-datasets Args: num_splits: specified number of splits |
| HIGH | verl/utils/kernel/fp8_kernel.py | 177 | High-performance FP8 blockwise quantization using Triton kernel. This is the recommended function to use for FP8 qu |
| HIGH | verl/utils/megatron/router_replay_utils.py | 347 | Reorder and merge per-VPP layer blocks into a contiguous layer dimension. Given a tensor shaped as [bs*vpp_siz |
| HIGH | verl/utils/reward_score/__init__.py | 29 | Compute the score for a given solution based on the data source. Args: data_source (str): The source datase |
| HIGH | verl/workers/config/optimizer.py | 219 | Build an optimizer based on the configuration. Dynamically imports and instantiates an optimizer class from the spe |
| HIGH | verl/workers/rollout/trtllm_rollout/trtllm_rollout.py | 178 | Make an async HTTP request with retry logic and consistent error handling. Args: endpoint (str): Th |
| HIGH | …l/workers/rollout/sglang_rollout/http_server_engine.py | 110 | Launch an SGLang HTTP server process and wait for it to be ready. This function starts a new process running an SGL |
| HIGH | …l/workers/rollout/sglang_rollout/http_server_engine.py | 296 | Make a HTTP request with retry logic and consistent error handling. Args: endpoint (str): The API e |
| HIGH | …l/workers/rollout/sglang_rollout/http_server_engine.py | 664 | Make an async HTTP request with retry logic and consistent error handling. Args: endpoint (str): Th |
| HIGH | verl/workers/engine/base.py | 325 | Function to create a new training engine instance based on the provided config. Args: key: |
| HIGH | verl/workers/engine/fsdp/utils.py | 62 | Determine the appropriate sharding strategy based on the number of dimensions of the device mesh. Args: |
| HIGH | verl/workers/engine/torchtitan/utils.py | 81 | Derive torchtitan model name and flavor from a HuggingFace config. The name is mapped from ``hf_config.model_type`` |
| HIGH | verl/trainer/ppo/reward.py | 51 | Load and return a custom reward function from external file. Dynamically imports a reward function from a specified |
| HIGH | verl/trainer/ppo/core_algos.py | 194 | Factory function to create appropriate KL controller based on configuration. Args: kl_ctrl: Configuration o |
| HIGH | verl/trainer/ppo/core_algos.py | 2210 | Compute importance weights for resampling based on scores. Args: scores (torch.Tensor): Tensor of s |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | docs/blog/v0.7.md | 0 | send the weights of the model. args: weights: a generator that yields the name of the weight tensor and the tensor itsel |
| HIGH | verl/checkpoint_engine/nccl_checkpoint_engine.py | 0 | send the weights of the model. args: weights: a generator that yields the name of the weight tensor and the tensor itsel |
| HIGH | verl/checkpoint_engine/nixl_checkpoint_engine.py | 0 | send the weights of the model. args: weights: a generator that yields the name of the weight tensor and the tensor itsel |
| HIGH | verl/checkpoint_engine/kimi_checkpoint_engine.py | 0 | send the weights of the model. args: weights: a generator that yields the name of the weight tensor and the tensor itsel |
| HIGH | verl/checkpoint_engine/hccl_checkpoint_engine.py | 0 | send the weights of the model. args: weights: a generator that yields the name of the weight tensor and the tensor itsel |
| HIGH | docs/blog/v0.7.md | 0 | receive the weights of the model. yields: a tuple of the name of the weight tensor and the tensor itself. |
| HIGH | verl/checkpoint_engine/nccl_checkpoint_engine.py | 0 | receive the weights of the model. yields: a tuple of the name of the weight tensor and the tensor itself. |
| HIGH | verl/checkpoint_engine/nixl_checkpoint_engine.py | 0 | receive the weights of the model. yields: a tuple of the name of the weight tensor and the tensor itself. |
| HIGH | verl/checkpoint_engine/kimi_checkpoint_engine.py | 0 | receive the weights of the model. yields: a tuple of the name of the weight tensor and the tensor itself. |
| HIGH | verl/checkpoint_engine/hccl_checkpoint_engine.py | 0 | receive the weights of the model. yields: a tuple of the name of the weight tensor and the tensor itself. |
| HIGH | …perimental/fully_async_policy/fully_async_rollouter.py | 0 | initialize distributed training workers using ray backend. creates: 1. ray resource pools from configuration 2. worker g |
| HIGH | …experimental/fully_async_policy/fully_async_trainer.py | 0 | initialize distributed training workers using ray backend. creates: 1. ray resource pools from configuration 2. worker g |
| HIGH | verl/experimental/separation/ray_trainer.py | 0 | initialize distributed training workers using ray backend. creates: 1. ray resource pools from configuration 2. worker g |
| HIGH | verl/trainer/main_ppo_sync.py | 0 | initialize distributed training workers using ray backend. creates: 1. ray resource pools from configuration 2. worker g |
| HIGH | verl/trainer/ppo/ray_trainer.py | 0 | initialize distributed training workers using ray backend. creates: 1. ray resource pools from configuration 2. worker g |
| HIGH | …experimental/fully_async_policy/fully_async_trainer.py | 0 | the training loop of ppo. the driver process only need to call the compute functions of the worker group through rpc to |
| HIGH | verl/experimental/one_step_off_policy/ray_trainer.py | 0 | the training loop of ppo. the driver process only need to call the compute functions of the worker group through rpc to |
| HIGH | verl/trainer/ppo/ray_trainer.py | 0 | the training loop of ppo. the driver process only need to call the compute functions of the worker group through rpc to |
| HIGH | verl/models/mcore/registry.py | 0 | get the forward function for given model architecture. |
| HIGH | verl/models/mcore/registry.py | 0 | get the forward function for given model architecture. |
| HIGH | verl/models/mcore/registry.py | 0 | get the forward function for given model architecture. |
| HIGH | verl/workers/reward_manager/prime.py | 0 | we will expand this function gradually based on the available datasets |
| HIGH | verl/workers/reward_manager/naive.py | 0 | we will expand this function gradually based on the available datasets |
| HIGH | verl/workers/reward_manager/dapo.py | 0 | we will expand this function gradually based on the available datasets |
| HIGH | …/workers/rollout/trtllm_rollout/trtllm_async_server.py | 0 | restore kv_cache gpu memory after a weight sync. counterpart to release_kv_cache(). |
| HIGH | …/workers/rollout/sglang_rollout/async_sglang_server.py | 0 | restore kv_cache gpu memory after a weight sync. counterpart to release_kv_cache(). |
| HIGH | verl/workers/rollout/vllm_rollout/vllm_async_server.py | 0 | restore kv_cache gpu memory after a weight sync. counterpart to release_kv_cache(). |
| HIGH | verl/workers/engine/base.py | 0 | whether the current rank is the first rank in model parallel group that contains model outputs |
| HIGH | verl/workers/engine/veomni/transformer_impl.py | 0 | whether the current rank is the first rank in model parallel group that contains model outputs |
| HIGH | verl/workers/engine/torchtitan/transformer_impl.py | 0 | whether the current rank is the first rank in model parallel group that contains model outputs |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | tests/test_protocol_v2_on_cpu.py | 434 | # Create a DataProto object with some batch and non-tensor data |
| MEDIUM | tests/test_protocol_v2_on_cpu.py | 629 | # Create a DataProto object with some batch and non-tensor data |
| MEDIUM | tests/test_protocol_on_cpu.py | 133 | # Create a circular reference and a non-circular one. |
| MEDIUM | tests/test_protocol_on_cpu.py | 371 | # Create a DataProto object with some batch and non-tensor data |
| MEDIUM | tests/test_protocol_on_cpu.py | 618 | # Create a DataProto object with some batch and non-tensor data |
| MEDIUM | tests/test_protocol_on_cpu.py | 1220 | # Create a DataProto with an empty TensorDict but with a batch size |
| MEDIUM | tests/experimental/agent_loop/test_multi_modal.py | 87 | # Create a simple colored image for testing |
| MEDIUM | tests/experimental/agent_loop/test_multi_modal.py | 329 | # Create a simple test image |
| MEDIUM | tests/experimental/agent_loop/test_basic_agent_loop.py | 396 | # Initialize the class to set up class-level attributes |
| MEDIUM | tests/utils/test_nvtx_profile.py | 57 | # Create a new ProfilerConfig instance |
| MEDIUM | tests/utils/test_model_on_cpu.py | 35 | # Create a fresh mock config object for each test case |
| MEDIUM | tests/utils/test_import_utils_on_cpu.py | 84 | # Create a temporary file with syntax errors |
| MEDIUM | tests/utils/test_special_linear_cross_entropy_tp.py | 273 | # Create a tensor to hold the gathered weights from all ranks |
| MEDIUM | tests/utils/test_special_linear_cross_entropy_tp.py | 277 | # Create a single contiguous tensor to hold all gathered weights |
| MEDIUM | …sts/utils/dataset/test_multiturn_sft_dataset_on_cpu.py | 49 | # Create a temporary parquet file with test data |
| MEDIUM | …eward_score/reward_score/test_sandbox_fusion_on_cpu.py | 338 | # Define a low global concurrency limit to test the semaphore's effect |
| MEDIUM | …eward_score/reward_score/test_sandbox_fusion_on_cpu.py | 340 | # Define the number of processes used in the test |
| MEDIUM | …eward_score/reward_score/test_sandbox_fusion_on_cpu.py | 342 | # Define the number of tasks processed by check_correctness in each process (i.e., internal |
| MEDIUM | …eward_score/reward_score/test_sandbox_fusion_on_cpu.py | 470 | # Create a multiprocessing.Semaphore instance, this is the global semaphore we are testing. |
| MEDIUM | …kers/rollout/rollout_sglang/test_http_server_engine.py | 17 | # This file is adapted from multiple sources: |
| MEDIUM | tests/single_controller/test_decorator_on_cpu.py | 38 | # Define a simple worker for testing |
| MEDIUM | tests/trainer/ppo/test_metric_utils_on_cpu.py | 297 | # Create a mock DataProto object |
| MEDIUM | tests/trainer/ppo/test_metric_utils_on_cpu.py | 358 | # Create a mock DataProto object |
| MEDIUM | tests/trainer/ppo/test_metric_utils_on_cpu.py | 409 | # Create a mock DataProto object |
| MEDIUM | verl/protocol.py | 703 | # Create a slice object |
| MEDIUM | …perimental/fully_async_policy/fully_async_rollouter.py | 1028 | # Create the main asynchronous task |
| MEDIUM | verl/experimental/one_step_off_policy/ray_trainer.py | 222 | # Create the initial batch from the data loader |
| MEDIUM | verl/utils/megatron_utils.py | 1391 | # Create a dummy total_loss_dict to collect MTP metrics |
| MEDIUM | verl/utils/tensordict_utils.py | 281 | # Create a list of tensordicts containing only non-nested tensors for concatenation |
| MEDIUM | verl/utils/tensordict_utils.py | 287 | # Create a new TensorDict with non-nested items without modifying the original |
| MEDIUM | verl/utils/tracking.py | 444 | # Create a new table with same columns and existing data |
| MEDIUM | verl/utils/vllm/vllm_fp8_utils.py | 313 | """This function is used to process the weights after loading for a Linear layer, it is used for vllm v0.10 |
| MEDIUM | verl/utils/vllm/vllm_fp8_utils.py | 368 | """This function is used to process the weights after loading for a Linear layer, it is used for vllm 0.11 |
| MEDIUM | verl/utils/vllm/vllm_fp8_utils.py | 430 | """This function is used to process the weights after loading for a Linear layer, it is used for vllm v0.14-v0.19. |
| MEDIUM | verl/utils/vllm/vllm_fp8_utils.py | 492 | """This function is used to process the weights after loading for a FusedMoE layer, it is used for vllm v0.10""" |
| MEDIUM | verl/utils/vllm/vllm_fp8_utils.py | 568 | """This function is used to process the weights after loading for a FusedMoE layer, it is used for vllm 0.11""" |
| MEDIUM | verl/utils/debug/performance.py | 16 | # This file is deprecated, for new features please develop in profiler/performance.py |
| MEDIUM | verl/workers/rollout/trtllm_rollout/trtllm_rollout.py | 153 | # Create a new session for each request to avoid resource competition |
| MEDIUM | …l/workers/rollout/sglang_rollout/http_server_engine.py | 17 | # This file is adapted from multiple sources: |
| MEDIUM | …l/workers/rollout/sglang_rollout/http_server_engine.py | 639 | # Create a new session for each request to avoid resource competition |
| MEDIUM | verl/trainer/main_ppo.py | 51 | # Define a function to run the PPO-like training process |
| MEDIUM | verl/trainer/main_ppo.py | 85 | # Create a remote instance of the TaskRunner class, and |
| MEDIUM | verl/trainer/main_ppo.py | 105 | # This file is used for performance analysis |
| MEDIUM | verl/trainer/ppo/reward.py | 140 | # Create a semaphore to control concurrent access to the sandbox |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tests/test_protocol_on_cpu.py | 1073 | # Check if it's a nested tensor |
| LOW | tests/experimental/agent_loop/test_multi_modal.py | 416 | # Check if this sample should have image pads (samples with index 1 and 2 in each repeat have images) |
| LOW | tests/special_sanity/test_config_docs.py | 35 | # Check if there's a comment above |
| LOW | tests/utils/test_special_linear_cross_entropy_tp.py | 494 | # Check if running with torchrun (distributed mode) |
| LOW | tests/models/test_tiled_mlp_accuracy.py | 95 | # Check if within tolerance (1e-2 for bf16) |
| LOW | verl/protocol.py | 379 | # Check if batch is empty to avoid torch.cat error in consolidate |
| LOW | …perimental/fully_async_policy/fully_async_rollouter.py | 833 | # Check if have reached the last step |
| LOW | …experimental/fully_async_policy/fully_async_trainer.py | 541 | # Check if validation is needed |
| LOW | …experimental/fully_async_policy/fully_async_trainer.py | 603 | # Check if the ESI (Elastic Server Instance)/training plan is close to expiration. |
| LOW | …experimental/fully_async_policy/fully_async_trainer.py | 608 | # Check if the conditions for saving a checkpoint are met. |
| LOW | verl/experimental/reward_loop/reward_manager/limited.py | 267 | # Check if already initialized before calling parent. |
| LOW | verl/experimental/separation/ray_trainer.py | 674 | # Check if the ESI (Elastic Server Instance)/training plan is close to expiration. |
| LOW | verl/experimental/separation/ray_trainer.py | 679 | # Check if the conditions for saving a checkpoint are met. |
| LOW | verl/utils/transferqueue_utils.py | 196 | # Check if collect_fn is a functools.partial and handle gracefully |
| LOW | verl/utils/fp8_utils.py | 56 | # Check if matches exclude patterns |
| LOW | verl/utils/fp8_utils.py | 76 | # Check if matches include patterns |
| LOW | verl/utils/fp8_utils.py | 106 | # Check if quantization is needed |
| LOW | verl/utils/rollout_skip.py | 184 | # Check if path is in Ray temporary directory |
| LOW | verl/utils/rollout_skip.py | 227 | # Check if train_step not start from 1 |
| LOW | verl/utils/fsdp_utils.py | 977 | # Check if module is a PEFT model |
| LOW | verl/utils/qat/vllm_patch.py | 130 | # Check if we have metadata for this layer |
| LOW | verl/utils/qat/vllm_patch.py | 138 | # Check if this param needs rebuild |
| LOW | verl/utils/qat/vllm_patch.py | 182 | # Check if can rebuild from metadata |
| LOW | verl/utils/dataset/multiturn_sft_dataset.py | 334 | # Check if all tensors in the list have the same shape |
| LOW | verl/utils/dataset/rl_dataset.py | 545 | # Check if a custom dataset class is specified in the data configuration |
| LOW | verl/utils/kernel/fp8_kernel.py | 22 | # Check if Triton is available |
| LOW | verl/models/mcore/mtp_patch.py | 210 | # Check if GPTModel has MTP and find the layers |
| LOW | verl/models/mcore/mtp_patch.py | 216 | # Check if any layer in the model is MultiTokenPredictionLayer |
| LOW | verl/models/mcore/mtp_patch.py | 243 | # Check if GPTModel has MTP and find the layers |
| LOW | verl/models/mcore/mtp_patch.py | 249 | # Check if any layer in the model is MultiTokenPredictionLayer |
| LOW | verl/models/mcore/mtp_patch.py | 277 | # Check if GPTModel has MTP and find the layers |
| LOW | verl/models/mcore/mtp_patch.py | 283 | # Check if any layer in the model is MultiTokenPredictionLayer |
| LOW | verl/models/mcore/mtp_patch.py | 313 | # Check if GPTModel has MTP and find the layers |
| LOW | verl/models/mcore/mtp_patch.py | 319 | # Check if any layer in the model is MultiTokenPredictionLayer |
| LOW | …third_party/torch/distributed/checkpoint/state_dict.py | 479 | # Verify if the model_state_dict and optim_state_dict are valid. This API |
| LOW | verl/workers/rollout/llm_server.py | 77 | # Check if server is still in the active pool |
| LOW | …kers/rollout/trtllm_rollout/trtllm_worker_extension.py | 153 | # Check if model supports partial loading and use appropriate strategy |
| LOW | verl/workers/rollout/vllm_rollout/utils.py | 276 | # Check if FP8 quantization is enabled and apply appropriate weight loading |
| LOW | verl/workers/engine/veomni/utils.py | 74 | # Check if this is a MultiOptimizer (for ep and non-ep parameters when ep+fsdp2 is enabled) |
| LOW | verl/workers/engine/veomni/utils.py | 94 | # Check if this is a MultiOptimizer (for ep and non-ep parameters when ep+fsdp2 is enabled) |
| LOW | verl/trainer/main_ppo.py | 61 | # Check if Ray is not initialized |
| LOW | verl/trainer/ppo/metric_utils.py | 366 | # Check if we have the necessary data (sum_pi_squared is required for W-score) |
| LOW | verl/trainer/ppo/ray_trainer.py | 264 | # Check if sum_pi_squared is available |
| LOW | verl/trainer/ppo/ray_trainer.py | 1651 | # Check if the ESI (Elastic Server Instance)/training plan is close to expiration. |
| LOW | verl/trainer/ppo/ray_trainer.py | 1656 | # Check if the conditions for saving a checkpoint are met. |
| LOW | examples/tutorial/skypilot/verl-ppo.yaml | 22 | # Check if the script exists and use absolute path |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tests/utils/test_activation_offload.py | 113 | # Step 1: Initial update and save checkpoint |
| LOW | tests/utils/test_activation_offload.py | 126 | # Step 2: Second update and forward pass |
| LOW | tests/utils/test_activation_offload.py | 138 | # Step 3: wrap module with activation offloading and load checkpoint |
| LOW | tests/utils/test_activation_offload.py | 142 | # Step 4: Repeat the second update with same input |
| LOW | tests/utils/test_activation_offload.py | 154 | # Step 4: Verify outputs match |
| LOW | tests/special_distributed/test_fsdp_ckpt.py | 107 | # Step 1: Initial update and save checkpoint |
| LOW | tests/special_distributed/test_fsdp_ckpt.py | 121 | # Step 2: Second update and forward pass |
| LOW | tests/special_distributed/test_fsdp_ckpt.py | 133 | # Step 3: Load checkpoint and repeat second update |
| LOW | tests/special_distributed/test_fsdp_ckpt.py | 152 | # Step 4: Verify outputs match |
| LOW | …experimental/fully_async_policy/fully_async_trainer.py | 237 | # Step 3: Sleep all hybrid replicas |
| LOW | verl/utils/megatron/router_replay_patch.py | 346 | # Step 1: Patch TransformerConfig to include the feature flag |
| LOW | verl/utils/megatron/router_replay_patch.py | 397 | # Step 2: Patch TopKRouter only once to ensure idempotency. |
| LOW | verl/utils/megatron/router_replay_patch.py | 403 | # Step 3: Define the new __init__ method |
| LOW | verl/utils/megatron/router_replay_patch.py | 410 | # Step 4: Patch MoEAlltoAllTokenDispatcher.preprocess to handle router replay |
| LOW | verl/utils/megatron/router_replay_patch.py | 440 | # Step 5: Apply the patches |
| LOW | verl/models/transformers/monkey_patch.py | 358 | # Step 1: patch model to support image-text mixed data |
| LOW | verl/models/transformers/monkey_patch.py | 387 | # Step 2: patch attention to support ulysses parallelism |
| LOW | verl/models/transformers/monkey_patch.py | 406 | # Step 3: patch input for multimodal sequence parallelism |
| LOW | verl/models/transformers/monkey_patch.py | 412 | # Step 1: patch model to support image-text mixed data |
| LOW | verl/models/transformers/monkey_patch.py | 445 | # Step 2: patch input for multimodal sequence parallelism |
| LOW | verl/models/transformers/monkey_patch.py | 451 | # Step 1: patch model to support image-text mixed data |
| LOW | verl/models/transformers/monkey_patch.py | 466 | # Step 2: patch attention to support ulysses parallelism |
| LOW | verl/models/transformers/monkey_patch.py | 473 | # Step 3: patch input for multimodal sequence parallelism |
| LOW | verl/models/transformers/monkey_patch.py | 493 | # Step 1: patch model to support image-text mixed data |
| LOW | verl/models/transformers/monkey_patch.py | 519 | # Step 2: patch vision model to fix fsdp2 cpu_offload bug. |
| LOW | verl/trainer/ppo/rollout_corr_helper.py | 841 | # Step 1: Compute log ratio (log(π_train / π_rollout)) |
| LOW | verl/trainer/ppo/rollout_corr_helper.py | 845 | # Step 2: Compute IS weights (if enabled) |
| LOW | verl/trainer/ppo/rollout_corr_helper.py | 857 | # Step 3: Compute rejection mask (if enabled) |
| LOW | verl/trainer/ppo/rollout_corr_helper.py | 873 | # Step 4: Compute off-policy metrics (KL, PPL, χ², etc.) |
| LOW | verl/trainer/ppo/rollout_corr_helper.py | 881 | # Step 6: Add "rollout_corr/" prefix to all metrics for logging consistency |
| LOW | verl/trainer/ppo/rollout_corr_helper.py | 889 | # Step 7: Wrap IS weights in DataProto for consistency with API |
| LOW | verl/trainer/ppo/core_algos.py | 924 | # Step 1: Compute w_per_timestep = 1 - 2π_t + Σπ²) |
| LOW | verl/trainer/ppo/core_algos.py | 928 | # Step 2: Apply rollout importance sampling correction (if enabled) |
| LOW | verl/trainer/ppo/core_algos.py | 933 | # Step 3: Compute cumulative path-variance proxy: W_t = Σ_{j=1}^t w_j |
| LOW | verl/trainer/ppo/core_algos.py | 1040 | # Step 1: Compute w_per_timestep = 1 - 2π_t + Σπ²) |
| LOW | verl/trainer/ppo/core_algos.py | 1044 | # Step 2: Apply rollout importance sampling correction (if enabled) |
| LOW | verl/trainer/ppo/core_algos.py | 1049 | # Step 3: Compute cumulative path-variance proxy: W_t = Σ_{j=1}^t w_j |
| LOW | verl/trainer/ppo/core_algos.py | 1053 | # Step 4: Concatenate returns and w_cumulative for each trajectory |
| Severity | File | Line | Snippet |
|---|---|---|---|
| CRITICAL | tests/trainer/ppo/test_core_algos_on_cpu.py | 42 | verl.trainer.ppo.core_algos.ADV_ESTIMATOR_REGISTRY.clear() |
| CRITICAL | tests/trainer/ppo/test_core_algos_on_cpu.py | 50 | verl.trainer.ppo.core_algos.ADV_ESTIMATOR_REGISTRY.clear() |
| CRITICAL | verl/trainer/ppo/ray_trainer.py | 1402 | if self.config.actor_rollout_ref.rollout.skip.get("enable", False): |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | tests/test_protocol_on_cpu.py | 98 | # 4D object array to ensure deep recursion is robust |
| MEDIUM | …fully_async_policy/config/fully_async_ppo_trainer.yaml | 66 | # And it can be used in conjunction with other rollout_correction algorithms. |
| MEDIUM | …nc_policy/config/fully_async_ppo_megatron_trainer.yaml | 65 | # And it can be used in conjunction with other rollout_correction algorithms. |
| MEDIUM | …f_policy/config/one_step_off_ppo_megatron_trainer.yaml | 28 | # And it can be used in conjunction with other rollout_correction algorithms. |
| MEDIUM | …e_step_off_policy/config/one_step_off_ppo_trainer.yaml | 28 | # And it can be used in conjunction with other rollout_correction algorithms. |
| MEDIUM | verl/utils/vllm/vllm_fp8_utils.py | 679 | # robust than version string comparison, especially for dev/pre-release versions. |
| MEDIUM | verl/utils/reward_score/math_dapo.py | 14 | # Adapted from https://github.com/EleutherAI/lm-evaluation-harness/blob/main/lm_eval/tasks/hendrycks_math/utils.py |
| MEDIUM | verl/utils/reward_score/math_reward.py | 14 | # Adapted from https://github.com/EleutherAI/lm-evaluation-harness/blob/main/lm_eval/tasks/hendrycks_math/utils.py |
| MEDIUM | verl/utils/reward_score/math_reward.py | 31 | # string normalization from https://github.com/EleutherAI/lm-evaluation-harness/blob/master/lm_eval/tasks/hendrycks_math |
| LOW | …third_party/torch/distributed/checkpoint/state_dict.py | 1180 | >>> # if we simply call ddp_model.state_dict() and fsdp_model.state_dict(), |
| MEDIUM | verl/single_controller/ray/base.py | 204 | # that can utilize different WorkerGroup for differnt models |
| MEDIUM | verl/trainer/main_ppo.py | 364 | # Use a sampler to facilitate checkpoint resumption. |
| MEDIUM | verl/trainer/ppo/rollout_corr_helper.py | 667 | """Compute comprehensive metrics for truncated importance sampling weights. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | verl/models/mcore/mtp_patch.py | 379 | # embedding computation - you can modify this part |
| MEDIUM | verl/trainer/config/rollout/rollout.yaml | 48 | # you can use smaller batch size to save memory used in cuda graph, eg: [1 ,2, 4, 8, 16, 32] |
| MEDIUM | examples/grpo_trainer/run_gpt_oss_20b_fsdp.sh | 63 | # or you can use lmsys/gpt-oss-20b-bf16 |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tests/utils/test_rollout_trace_on_cpu.py | 67 | async def my_method(self, a, b="default"): |
| LOW | tests/utils/test_rollout_trace_on_cpu.py | 90 | async def my_method(self, x): |
| LOW | tests/utils/_test_module.py | 30 | def test_function(): |
| LOW | verl/utils/activation_offload.py | 457 | def my_function(*inputs): |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | verl/trainer/ppo/rollout_corr_helper.py | 915 | - kl: Direct KL divergence estimator KL(π_rollout || π_training) |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tests/special_e2e/run_fully_async_policy_opd.sh | 24 | # Usage: |