An Efficient and User-Friendly Scaling Library for Reinforcement Learning with Large Language Models
This report summarizes scanner evidence for alibaba/ROLL, a Python project with 3,419 GitHub stars. SynthScan examined 192,168 lines of code across 965 source files, recording 2365 pattern matches distributed across 23 syntactic categories. The legacy adjusted pattern signal is 18.8 (Elevated pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 1407 finding(s).
Are imports declared and package/API names verified? 501 finding(s).
Are wrappers, guards, and repeated structures necessary? 1320 finding(s).
Which changes need focused human review? 2365 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 2365 distinct pattern matches across 23 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | mcore_adapter/src/mcore_adapter/initialize.py | 16 | def is_distribute_initialized(): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/training_args.py | 448 | def allow_variable_seq_lengths(self): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/utils.py | 81 | def is_mcore_version_greater_than(content: str): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/utils.py | 105 | def is_transformers_version_greater_than(content: str): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/patcher.py | 31 | def patch_torch_find_nd_overlapping_shards(): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/patcher.py | 37 | def _find_nd_overlapping_shards(shards: list[ShardMetadata], sharded_dims: list[int]) -> Optional[tuple[int, int]]: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/patcher.py | 85 | def patch_torch_validate_global_plan(): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/patcher.py | 181 | def patch_megatron_preload_tensors_non_blocking(non_blocking: bool = False): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/patcher.py | 214 | def patched_get_save_function_and_args(self): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/checkpointing.py | 19 | def get_checkpoint_tracker_filename(checkpoints_path): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/checkpointing.py | 279 | def load_state_dict_from_checkpoint(checkpoint_dir, models = None): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/checkpointing.py | 287 | def save_config_and_state_dict(save_directory, config, state_dict, ckpt_format: str = "legacy"): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/checkpointing.py | 313 | def generate_model_state_dict(model, ckpt_format: str = "legacy"): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/rocm.py | 53 | def update_env_vars_for_visible_devices(cls, env_vars: dict, gpu_ranks: list) -> None: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/rocm.py | 93 | def get_vllm_run_time_env_vars(cls, gpu_rank: str) -> dict: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/cpu.py | 37 | def get_vllm_run_time_env_vars(cls, gpu_rank: str) -> dict: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/npu.py | 67 | def get_vllm_run_time_env_vars(cls, gpu_rank: str) -> dict: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/platform.py | 126 | def update_env_vars_for_visible_devices(cls, env_vars: dict, gpu_ranks: list) -> None: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/platform.py | 162 | def get_vllm_run_time_env_vars(cls, gpu_rank: str) -> dict: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/cuda.py | 68 | def get_vllm_run_time_env_vars(cls, gpu_rank: str) -> dict: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/unknown.py | 68 | def get_vllm_run_time_env_vars(cls, gpu_rank: str) -> dict: | CODE |
| LOW⚡ | …src/mcore_adapter/parallel_functions/vocab_parallel.py | 27 | def vocab_range_from_per_partition_vocab_size( | CODE |
| LOW⚡ | …src/mcore_adapter/parallel_functions/vocab_parallel.py | 35 | def vocab_range_from_global_vocab_size(global_vocab_size: int, rank: int, world_size: int) -> Sequence[int]: | CODE |
| LOW⚡ | …src/mcore_adapter/parallel_functions/vocab_parallel.py | 42 | def calculate_predicted_logits( | CODE |
| LOW | …src/mcore_adapter/parallel_functions/vocab_parallel.py | 188 | def vocab_parallel_target_rank(vocab_parallel_logits: "torch.Tensor", target: "torch.Tensor") -> "torch.Tensor": | CODE |
| LOW | …dapter/parallel_functions/encoder_sequence_parallel.py | 12 | def _gather_and_reorder_along_first_dim( | CODE |
| LOW | …dapter/parallel_functions/encoder_sequence_parallel.py | 129 | def encoder_sequence_parallel_gather(input_, split_plan, input_size_list): | CODE |
| LOW | …dapter/parallel_functions/encoder_sequence_parallel.py | 133 | def encoder_small_batch_size_gather(input_): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_utils.py | 125 | def _mca_lora_logits_postprocess(logits: "torch.Tensor"): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_utils.py | 136 | def mca_lora_logits_postprocess_hook(module, input, output): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_utils.py | 149 | def check_and_get_attention_backend_by_env(attention_backend: AttnBackend): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_utils.py | 171 | def get_thd_data_on_this_cp_rank( | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_utils.py | 197 | def configure_resized_vocab_size( | CODE |
| LOW⚡ | …ter/src/mcore_adapter/models/sequence_packing_mixin.py | 86 | def build_attention_mask_from_packed_seq_params( | CODE |
| LOW | …ter/src/mcore_adapter/models/sequence_packing_mixin.py | 208 | def build_multimodal_embeddings( | CODE |
| LOW | …ter/src/mcore_adapter/models/sequence_packing_mixin.py | 286 | def construct_multimodal_inputs( | CODE |
| LOW | …ter/src/mcore_adapter/models/sequence_packing_mixin.py | 472 | def _compute_full_sequence_embedding( | CODE |
| LOW | …ter/src/mcore_adapter/models/sequence_packing_mixin.py | 518 | def _pack_deepstack_visual_embeds( | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/value_head.py | 125 | def make_value_head_converter(dist_converter: DistConverter) -> DistConverter: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 125 | def load_state_dict_per_parameter( | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 278 | def get_batch_on_this_cp_rank(self, *args, **kwargs): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 377 | def get_batch_on_this_cp_rank(self, batch: Dict[str, "torch.Tensor"], dim3_keys: List[str] = ["attention_mask"]): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 414 | def enable_input_require_grads(self): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 420 | def make_inputs_require_grads(module, input, output): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 466 | def _get_transformer_layer_spec(self, config: Optional["McaModelConfig"] = None): | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 503 | def compute_language_model_loss(self, labels: torch.Tensor, logits: torch.Tensor) -> torch.Tensor: | CODE |
| LOW | …mcore_adapter/models/qwen3_next/modeling_qwen3_next.py | 12 | def _get_transformer_layer_spec(self, config: Optional[Qwen3NextConfig] = None): | CODE |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 558 | def _split_sharded_state_dict(self, sharded_state_dict: dict) -> list[dict]: | CODE |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 592 | def _stream_dist_weights_from_shards(self, sharded_state_dict: dict): | CODE |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 772 | def convert_checkpoint_to_mca( | CODE |
| LOW | …r/src/mcore_adapter/models/converter/dist_converter.py | 332 | def _get_num_layers_per_virtual_rank(self): | CODE |
| LOW | …r/src/mcore_adapter/models/converter/dist_converter.py | 609 | def handle_grouped_duplicated(self, name: str, weights: Union["Tensor", list["Tensor"]]) -> dict[str, "Tensor"]: | CODE |
| LOW | …r/src/mcore_adapter/models/converter/dist_converter.py | 626 | def _convert_te_grouped_column(self, name: str, weights: "Tensor"): | CODE |
| LOW | …r/src/mcore_adapter/models/converter/dist_converter.py | 636 | def _revert_te_grouped_column(self, name: str, weights: list["Tensor"], moe_index_preprocessed: bool = False): | CODE |
| LOW | …r/src/mcore_adapter/models/converter/dist_converter.py | 876 | def is_tensor_parallel_dup_weight(self, name: str) -> bool: | CODE |
| LOW | …r/src/mcore_adapter/models/converter/dist_converter.py | 880 | def is_expert_parallel_weight(self, name: str) -> bool: | CODE |
| LOW | …adapter/src/mcore_adapter/models/converter/template.py | 474 | def convert_hf_to_mca_config_kws(self, hf_config: "PretrainedConfig", **kw_args): | CODE |
| LOW | …er/src/mcore_adapter/models/converter/convert_utils.py | 149 | def remove_mca_mtp_weight_prefix(weight_name: str): | CODE |
| LOW | …er/src/mcore_adapter/models/converter/convert_utils.py | 309 | def _noisy_mean_initialization(embed_weight: "torch.Tensor", num_new_tokens: int) -> None: | CODE |
| LOW | …/src/mcore_adapter/models/converter/model_converter.py | 93 | def load_mca_state_dict_from_hf(self, model_path: str, vp_stage: int): | CODE |
| 738 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | mcore_adapter/src/mcore_adapter/initialize.py | 9 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/__init__.py | 2 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/__init__.py | 3 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/__init__.py | 3 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/checkpointing.py | 8 | CODE | |
| LOW | …apter/src/mcore_adapter/parallel_functions/__init__.py | 1 | CODE | |
| LOW | …apter/src/mcore_adapter/parallel_functions/__init__.py | 2 | CODE | |
| LOW | …apter/src/mcore_adapter/parallel_functions/__init__.py | 2 | CODE | |
| LOW | …apter/src/mcore_adapter/parallel_functions/__init__.py | 3 | CODE | |
| LOW | …src/mcore_adapter/parallel_functions/fused_logprobs.py | 16 | CODE | |
| LOW | …src/mcore_adapter/parallel_functions/fused_logprobs.py | 18 | CODE | |
| LOW | …src/mcore_adapter/parallel_functions/fused_logprobs.py | 18 | CODE | |
| LOW | …src/mcore_adapter/parallel_functions/fused_logprobs.py | 18 | CODE | |
| LOW | …src/mcore_adapter/parallel_functions/fused_logprobs.py | 18 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/model_utils.py | 16 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/model_utils.py | 175 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/model_config.py | 20 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/model_config.py | 27 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 1 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 22 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 22 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 23 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 24 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 24 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 47 | CODE | |
| LOW | …dapter/src/mcore_adapter/models/qwen3_next/__init__.py | 25 | CODE | |
| LOW | …dapter/src/mcore_adapter/models/qwen3_next/__init__.py | 26 | CODE | |
| LOW | …e_adapter/src/mcore_adapter/models/mixtral/__init__.py | 3 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 31 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 44 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 46 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 47 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 48 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/dist_converter.py | 26 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/dist_converter.py | 28 | CODE | |
| LOW | …adapter/src/mcore_adapter/models/converter/template.py | 26 | CODE | |
| LOW | …adapter/src/mcore_adapter/models/converter/template.py | 27 | CODE | |
| LOW | …/src/mcore_adapter/models/converter/model_converter.py | 4 | CODE | |
| LOW | …/src/mcore_adapter/models/converter/model_converter.py | 42 | CODE | |
| LOW | …/src/mcore_adapter/models/converter/model_converter.py | 44 | CODE | |
| 418 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | …ter/src/mcore_adapter/models/sequence_packing_mixin.py | 77 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ter/src/mcore_adapter/models/sequence_packing_mixin.py | 79 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …ter/src/mcore_adapter/models/sequence_packing_mixin.py | 308 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …ter/src/mcore_adapter/models/sequence_packing_mixin.py | 310 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …/pipeline/agentic/proxy/router/ingress_proxy_router.py | 86 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …/pipeline/agentic/proxy/router/ingress_proxy_router.py | 88 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …/pipeline/agentic/proxy/router/ingress_proxy_router.py | 198 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …/pipeline/agentic/proxy/router/ingress_proxy_router.py | 200 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 1186 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 1188 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 75 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 77 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 134 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 136 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 173 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 175 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 366 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 368 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 150 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 152 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 224 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 226 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | roll/pipeline/diffusion/utils.py | 303 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | roll/pipeline/diffusion/utils.py | 305 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | roll/pipeline/diffusion/models/base.py | 44 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | roll/pipeline/diffusion/models/base.py | 46 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | roll/pipeline/diffusion/models/base.py | 63 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | roll/pipeline/diffusion/models/base.py | 65 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | roll/pipeline/diffusion/models/base.py | 93 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | roll/pipeline/diffusion/models/base.py | 95 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …line/diffusion/models/qwen_image/qwen_image_adapter.py | 158 | # ========================================================================= | COMMENT |
| MEDIUM | …line/diffusion/models/qwen_image/qwen_image_adapter.py | 160 | # ========================================================================= | COMMENT |
| MEDIUM | …line/diffusion/models/qwen_image/qwen_image_adapter.py | 223 | # ========================================================================= | COMMENT |
| MEDIUM | …line/diffusion/models/qwen_image/qwen_image_adapter.py | 225 | # ========================================================================= | COMMENT |
| MEDIUM | …line/diffusion/models/qwen_image/qwen_image_adapter.py | 365 | # ========================================================================= | COMMENT |
| MEDIUM | …line/diffusion/models/qwen_image/qwen_image_adapter.py | 367 | # ========================================================================= | COMMENT |
| MEDIUM | …line/diffusion/models/qwen_image/qwen_image_adapter.py | 473 | # ========================================================================= | COMMENT |
| MEDIUM | …line/diffusion/models/qwen_image/qwen_image_adapter.py | 475 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …sion/models/qwen_image/vllm_omni_qwen_image_adapter.py | 127 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …sion/models/qwen_image/vllm_omni_qwen_image_adapter.py | 129 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …sion/models/qwen_image/vllm_omni_qwen_image_adapter.py | 148 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …sion/models/qwen_image/vllm_omni_qwen_image_adapter.py | 150 | # ========================================================================= | COMMENT |
| MEDIUM | …sion/models/qwen_image/vllm_omni_qwen_image_adapter.py | 187 | # ========================================================================= | COMMENT |
| MEDIUM | …sion/models/qwen_image/vllm_omni_qwen_image_adapter.py | 189 | # ========================================================================= | COMMENT |
| MEDIUM | …sion/models/qwen_image/vllm_omni_qwen_image_adapter.py | 233 | # ========================================================================= | COMMENT |
| MEDIUM | …sion/models/qwen_image/vllm_omni_qwen_image_adapter.py | 235 | # ========================================================================= | COMMENT |
| MEDIUM | roll/distributed/scheduler/remote_protocol.py | 278 | # ============================================================================ | COMMENT |
| MEDIUM | roll/distributed/scheduler/remote_protocol.py | 283 | # ============================================================================ | COMMENT |
| MEDIUM | roll/utils/fsdp_utils.py | 535 | # ============================================================================ | COMMENT |
| MEDIUM | roll/utils/fsdp_utils.py | 542 | # ============================================================================ | COMMENT |
| MEDIUM | roll/models/model_providers.py | 251 | # --------------------------------------------------------------------- | STRING |
| MEDIUM | roll/third_party/fsdp2/tiled_mlp.py | 166 | # ============================================================================ | COMMENT |
| MEDIUM | roll/third_party/fsdp2/tiled_mlp.py | 168 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | roll/third_party/vllm/gdn_patcher.py | 210 | # ================================================================ | COMMENT |
| MEDIUM⚡ | roll/third_party/vllm/gdn_patcher.py | 213 | # ================================================================ | COMMENT |
| MEDIUM⚡ | roll/third_party/vllm/gdn_patcher.py | 219 | # ================================================================ | COMMENT |
| MEDIUM | roll/third_party/megatron/mtp_patcher.py | 49 | # ============================================================================ | COMMENT |
| MEDIUM | roll/third_party/megatron/mtp_patcher.py | 51 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | roll/third_party/megatron/mtp_patcher.py | 226 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | roll/third_party/megatron/mtp_patcher.py | 228 | # ============================================================================ | COMMENT |
| 38 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | README.md | 49 | | **[01/01/2026]** 🎉 Our [Let It Flow: Agentic Crafting on Rock and Roll](https://arxiv.org/abs/2512.24873) report relea | CODE |
| MEDIUM⚡ | README.md | 160 | - [Freshness-Aware-PER](https://arxiv.org/abs/2604.16918): A freshness-aware prioritized experience replay framework for | CODE |
| MEDIUM⚡ | README.md | 165 | - [STAgent](https://arxiv.org/abs/2512.24957): An agentic LLM specialized for spatio-temporal understanding and complex | CODE |
| MEDIUM⚡ | README.md | 168 | - [EARL](https://arxiv.org/abs/2510.05943): Efficient Agentic RL Systems for LLMs, introducing a dynamic parallelism sel | CODE |
| MEDIUM | roll/pipeline/agentic/agentic_config.py | 187 | # agentic related | COMMENT |
| MEDIUM | roll/distributed/scheduler/router.py | 235 | # In agentic pipeline (pure DP): rank == dp_rank, so directly access rank2devices | COMMENT |
| MEDIUM⚡ | tests/pipeline/agentic_pipeline_config.yaml | 17 | # project: roll-agentic | COMMENT |
| MEDIUM⚡ | tests/pipeline/agentic_pipeline_config.yaml | 21 | # - agentic | COMMENT |
| MEDIUM⚡ | tests/pipeline/agentic_pipeline_config.yaml | 28 | # project: roll-agentic | COMMENT |
| MEDIUM⚡ | tests/pipeline/agentic_pipeline_config.yaml | 30 | # experiment_name: roll-agentic-examples | COMMENT |
| MEDIUM⚡ | tests/pipeline/agentic_pipeline_config.yaml | 33 | # - agentic | COMMENT |
| MEDIUM⚡ | …2.5-7B-agentic_megatron/agentic_val_webshop_gigpo.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM⚡ | …2.5-7B-agentic_megatron/agentic_val_webshop_gigpo.yaml | 24 | # - agentic | COMMENT |
| MEDIUM⚡ | …2.5-7B-agentic_megatron/agentic_val_webshop_gigpo.yaml | 32 | # project: roll-agentic | COMMENT |
| MEDIUM⚡ | …2.5-7B-agentic_megatron/agentic_val_webshop_gigpo.yaml | 37 | # - agentic | COMMENT |
| MEDIUM | …en2.5-7B-agentic_megatron/agentic_val_webshop_amd.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …en2.5-7B-agentic_megatron/agentic_val_webshop_amd.yaml | 24 | # - agentic | COMMENT |
| MEDIUM⚡ | …s/qwen2.5-7B-agentic_megatron/agentic_val_webshop.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM⚡ | …s/qwen2.5-7B-agentic_megatron/agentic_val_webshop.yaml | 24 | # - agentic | COMMENT |
| MEDIUM⚡ | …s/qwen2.5-7B-agentic_megatron/agentic_val_webshop.yaml | 32 | # project: roll-agentic | COMMENT |
| MEDIUM⚡ | …s/qwen2.5-7B-agentic_megatron/agentic_val_webshop.yaml | 37 | # - agentic | COMMENT |
| MEDIUM | …en3-30BA3B-agentic_fsdp2/agentic_val_sokoban_30a3.yaml | 25 | # project: roll-agentic | COMMENT |
| MEDIUM | …en3-30BA3B-agentic_fsdp2/agentic_val_sokoban_30a3.yaml | 29 | # - agentic | COMMENT |
| MEDIUM | …/agentic_qwen2.5_0.5B_frozen_lake_partial_rollout.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …/agentic_qwen2.5_0.5B_frozen_lake_partial_rollout.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | examples/qwen2.5-vl-3B-agentic/agentic_val_sokoban.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | examples/qwen2.5-vl-3B-agentic/agentic_val_sokoban.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …es/qwen2.5-0.5B-agentic/agentic_val_sokoban_gigpo.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …es/qwen2.5-0.5B-agentic/agentic_val_sokoban_gigpo.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …B-agentic/agent_val_frozen_lake-pg_var_is_correct.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …B-agentic/agent_val_frozen_lake-pg_var_is_correct.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …0.5B-agentic/agentic_val_sokoban_dynamic_batching.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …0.5B-agentic/agentic_val_sokoban_dynamic_batching.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …/qwen2.5-0.5B-agentic/agent_val_frozen_lake_gigpo.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …/qwen2.5-0.5B-agentic/agent_val_frozen_lake_gigpo.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …n2.5-0.5B-agentic/agent_val_frozen_lake_async_amd.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …n2.5-0.5B-agentic/agent_val_frozen_lake_async_amd.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …/qwen2.5-0.5B-agentic/agentic_val_sokoban_sandbox.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …/qwen2.5-0.5B-agentic/agentic_val_sokoban_sandbox.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …qwen2.5-0.5B-agentic/agent_val_frozen_lake-pg_var.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …qwen2.5-0.5B-agentic/agent_val_frozen_lake-pg_var.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …ples/qwen2.5-0.5B-agentic/agentic_val_sokoban_sao.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …ples/qwen2.5-0.5B-agentic/agentic_val_sokoban_sao.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …les/qwen2.5-0.5B-agentic/agentic_val_sokoban_lora.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …les/qwen2.5-0.5B-agentic/agentic_val_sokoban_lora.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …s/qwen2.5-0.5B-agentic/agentic_val_sokoban_native.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …s/qwen2.5-0.5B-agentic/agentic_val_sokoban_native.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …ples/qwen2.5-0.5B-agentic/agentic_rollout_sokoban.yaml | 16 | # project: roll-agentic | COMMENT |
| MEDIUM | …ples/qwen2.5-0.5B-agentic/agentic_rollout_sokoban.yaml | 20 | # - agentic | COMMENT |
| MEDIUM | examples/qwen2.5-0.5B-agentic/agentic_val_sokoban.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | examples/qwen2.5-0.5B-agentic/agentic_val_sokoban.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …es/qwen2.5-0.5B-agentic/agent_val_frozen_lake_amd.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …es/qwen2.5-0.5B-agentic/agent_val_frozen_lake_amd.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …/qwen2.5-0.5B-agentic/agentic_val_sokoban_sao_as1.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …/qwen2.5-0.5B-agentic/agentic_val_sokoban_sao_as1.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …amples/qwen2.5-0.5B-agentic/agent_val_frozen_lake.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …amples/qwen2.5-0.5B-agentic/agent_val_frozen_lake.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …/qwen2.5-0.5B-agentic/agent_val_frozen_lake_async.yaml | 20 | # project: roll-agentic | COMMENT |
| MEDIUM | …/qwen2.5-0.5B-agentic/agent_val_frozen_lake_async.yaml | 24 | # - agentic | COMMENT |
| MEDIUM | …2.5-0.5B-agentic/agentic_val_sokoban_agent_runner.yaml | 20 | # project: roll-agentic | COMMENT |
| 37 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | mcore_adapter/src/mcore_adapter/training_args.py | 293 | except Exception as e: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/utils.py | 76 | except Exception: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 177 | except Exception as e: | CODE |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 161 | except Exception as e: | CODE |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 834 | except Exception as e: | CODE |
| LOW | roll/pipeline/base_pipeline.py | 234 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/rlvr_pipeline.py | 490 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/utils.py | 116 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/actor_worker.py | 187 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/rewards/video_r1_reward_worker.py | 44 | except Exception as e: | CODE |
| MEDIUM | roll/pipeline/rlvr/rewards/video_r1_reward_worker.py | 45 | print(f"Error converting '{num_str}' to float: {e}") | CODE |
| MEDIUM | roll/pipeline/rlvr/rewards/video_r1_reward_worker.py | 40 | def normalize_number(num_str): | CODE |
| LOW⚡ | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 1160 | except Exception: | CODE |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 1279 | except Exception: | CODE |
| LOW | …vr/rewards/multiple_choice_boxed_rule_reward_worker.py | 143 | except Exception as e: | CODE |
| LOW | …l/pipeline/rlvr/rewards/remote_reward_system_worker.py | 165 | except Exception as e: | CODE |
| LOW | …l/pipeline/rlvr/rewards/remote_reward_system_worker.py | 211 | except Exception as e: | CODE |
| LOW | …l/pipeline/rlvr/rewards/remote_reward_system_worker.py | 258 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/rewards/ifeval_rule_reward_worker.py | 629 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/rewards/math_rule_reward_worker.py | 179 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/rewards/math_rule_reward_worker.py | 197 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/rewards/math_rule_reward_worker.py | 292 | except Exception as e: | CODE |
| MEDIUM | roll/pipeline/rlvr/rewards/math_rule_reward_worker.py | 126 | def _hf_verify_math_sample(response, answer, result, prompt): | CODE |
| LOW | …peline/rlvr/rewards/crossthinkqa_rule_reward_worker.py | 230 | except Exception as e: | CODE |
| LOW | …ipeline/rlvr/rewards/general_val_rule_reward_worker.py | 164 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/rewards/llm_judge_reward_worker.py | 99 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/rewards/llm_judge_reward_worker.py | 148 | except Exception as e: | CODE |
| LOW | roll/pipeline/rlvr/rewards/llm_judge_reward_worker.py | 162 | except Exception as e: | CODE |
| MEDIUM | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 621 | print(f"Error executing test case: {e}") | CODE |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 200 | except Exception as e: | CODE |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 249 | except Exception as e: | CODE |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 288 | except Exception as e: | CODE |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 354 | except Exception as e: # Added specific exception type | CODE |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 525 | except Exception as e: | CODE |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 586 | except Exception as e: | CODE |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 620 | except Exception as e: | CODE |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 704 | except Exception as e: | CODE |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 770 | except Exception as e: | CODE |
| LOW | roll/pipeline/distill/distill_vlm_pipeline.py | 66 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/utils.py | 56 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/utils.py | 278 | except Exception as e: | CODE |
| MEDIUM | roll/pipeline/agentic/utils.py | 280 | print(f"Error saving gif: {e}") | CODE |
| LOW | roll/pipeline/agentic/environment_worker.py | 125 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/tools/action_parser.py | 62 | except Exception: | CODE |
| LOW | roll/pipeline/agentic/tools/action_parser.py | 75 | except Exception: | CODE |
| LOW | roll/pipeline/agentic/tools/action_parser.py | 102 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/tools/action_parser.py | 131 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/tools/action_parser.py | 149 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/tools/mcp_tool.py | 128 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/tools/mcp_tool.py | 148 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/proxy/proxy_server.py | 82 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/proxy/proxy_server.py | 131 | except Exception as e: | CODE |
| LOW | …/pipeline/agentic/proxy/router/ingress_proxy_router.py | 398 | except Exception as e: | CODE |
| MEDIUM | …/pipeline/agentic/proxy/router/ingress_proxy_router.py | 399 | print(f"Error: {e}") | CODE |
| MEDIUM⚡ | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 1182 | print(f"Error: {e}") | CODE |
| MEDIUM | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 1131 | print(f"Error occurred while listing rules: {error.message if hasattr(error, 'message') else str(error)}") | CODE |
| LOW⚡ | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 709 | except Exception as e: | CODE |
| LOW⚡ | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 1181 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 440 | except Exception as e: | CODE |
| LOW | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 498 | except Exception as e: | CODE |
| 169 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | mcore_adapter/src/mcore_adapter/platforms/__init__.py | 31 | except ImportError: | CODE |
| HIGH | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 846 | except: | CODE |
| HIGH | roll/pipeline/rlvr/rewards/math_rule_reward_worker.py | 197 | except Exception as e: | CODE |
| HIGH | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 75 | except ValueError: | CODE |
| HIGH | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 53 | except ValueError: | CODE |
| HIGH | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 59 | except ValueError: | CODE |
| HIGH | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 66 | except ValueError: | CODE |
| HIGH | roll/pipeline/agentic/agent_runner/rock/pull_runner.py | 235 | except (asyncio.CancelledError, Exception): | CODE |
| HIGH | roll/pipeline/agentic/agent_runner/rock/push_runner.py | 67 | except (asyncio.CancelledError, Exception): | CODE |
| HIGH | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 131 | except Exception: | CODE |
| HIGH | roll/distributed/scheduler/initialize.py | 57 | except (socket.timeout, socket.error, OSError) as e: | CODE |
| HIGH | roll/distributed/scheduler/decorator.py | 297 | except Exception as oe: | CODE |
| HIGH | roll/distributed/scheduler/decorator.py | 354 | except Exception as oe: | CODE |
| HIGH | roll/distributed/scheduler/protocol.py | 81 | except: | CODE |
| HIGH | roll/distributed/scheduler/log_monitor.py | 78 | except Exception as e: | CODE |
| HIGH | roll/distributed/store/host_mem_pool.py | 51 | except RuntimeError: | CODE |
| HIGH | roll/distributed/strategy/vllm_strategy.py | 110 | except Exception: | CODE |
| HIGH | roll/datasets/collator.py | 259 | except (IndexError, TypeError): | CODE |
| HIGH | roll/utils/context_managers.py | 199 | except FileNotFoundError: | CODE |
| HIGH | roll/utils/context_managers.py | 211 | except FileNotFoundError: | CODE |
| HIGH | roll/utils/metrics/metrics_manager.py | 137 | except: | CODE |
| HIGH | roll/utils/metrics/metrics_manager.py | 153 | except: | CODE |
| HIGH | roll/utils/metrics/metrics_manager.py | 169 | except: | CODE |
| HIGH | roll/utils/local_code/testing_util.py | 602 | except SystemExit: | CODE |
| HIGH | roll/utils/local_code/testing_util.py | 147 | except Exception: # noqa | CODE |
| HIGH | roll/utils/local_code/testing_util.py | 468 | except Exception: | CODE |
| HIGH | roll/utils/local_code/testing_util.py | 484 | except Exception: | CODE |
| HIGH | roll/utils/context_parallel/monkey_patch.py | 48 | except Exception: | CODE |
| HIGH | roll/utils/context_parallel/hf_flash_attention_patch.py | 393 | except Exception: | CODE |
| HIGH | roll/utils/context_parallel/hf_flash_attention_patch.py | 401 | except Exception: | CODE |
| HIGH | roll/models/model_providers.py | 78 | except Exception: | CODE |
| HIGH | roll/third_party/vllm/sp_moe_patcher.py | 109 | except Exception: # noqa: BLE001 | CODE |
| HIGH | roll/third_party/vllm/sp_moe_patcher.py | 117 | except Exception: # noqa: BLE001 | CODE |
| HIGH | …ted/strategy/log_probs/test_fsdp_vlm_log_probs_perf.py | 157 | except: | CODE |
| HIGH | …ted/strategy/log_probs/test_fsdp_vlm_log_probs_perf.py | 188 | except: | CODE |
| HIGH | …ts/distributed/strategy/log_probs/apply_model_patch.py | 625 | except Exception: | CODE |
| HIGH | …ts/distributed/strategy/log_probs/apply_model_patch.py | 730 | except Exception: | CODE |
| HIGH | …buted/strategy/log_probs/test_fsdp_vlm_layer_states.py | 61 | except Exception: | CODE |
| HIGH | …t_parallel/test_fsdp2_cp_qwen3_hf_rmpad_equivalence.py | 36 | except Exception: | CODE |
| HIGH | …t_parallel/test_fsdp2_cp_qwen3_hf_rmpad_equivalence.py | 484 | except Exception: | CODE |
| HIGH | …t_parallel/test_fsdp2_cp_qwen3_hf_rmpad_equivalence.py | 457 | except Exception: | CODE |
| HIGH | …context_parallel/test_fsdp2_cp_qwen3_hf_equivalence.py | 144 | except Exception: | CODE |
| HIGH | …ontext_parallel/test_fsdp2_cp_vlm_rmpad_equivalence.py | 305 | except Exception: | CODE |
| HIGH | …ontext_parallel/test_fsdp2_cp_vlm_rmpad_equivalence.py | 428 | except Exception: | CODE |
| HIGH | tests/utils/test_chunked_logprobs_entropy.py | 248 | except RuntimeError: | CODE |
| HIGH | tests/utils/test_chunked_logprobs_entropy.py | 257 | except RuntimeError: | CODE |
| HIGH | …ts/diffusion/flow_grpo/test_flowgrpo_train_pipeline.py | 205 | except FileNotFoundError: | CODE |
| HIGH | tests/diffusion/flow_grpo/test_lora_sleep_wake.py | 432 | except Exception: | CODE |
| HIGH | tests/diffusion/flow_grpo/test_vllm_omni_async_smoke.py | 352 | except Exception: | CODE |
| HIGH | tests/diffusion/flow_grpo/test_vllm_omni_async_smoke.py | 357 | except Exception: | CODE |
| HIGH | tests/third_party/deepspeed/common.py | 167 | except FixtureLookupError: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | mcore_adapter/src/mcore_adapter/patcher.py | 85 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/patcher.py | 91 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/model_config.py | 54 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 64 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/models/model_factory.py | 98 | CODE | |
| LOW | …dapter/src/mcore_adapter/models/qwen3_next/__init__.py | 98 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 98 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/post_converter.py | 327 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/dist_converter.py | 557 | CODE | |
| LOW | …r/src/mcore_adapter/models/converter/dist_converter.py | 591 | CODE | |
| LOW | …adapter/src/mcore_adapter/models/converter/template.py | 97 | CODE | |
| LOW | …adapter/src/mcore_adapter/models/converter/template.py | 571 | CODE | |
| LOW | …/src/mcore_adapter/models/converter/model_converter.py | 174 | CODE | |
| LOW | …/src/mcore_adapter/models/converter/model_converter.py | 213 | CODE | |
| LOW | …mcore_adapter/models/qwen2_5_vl/modeling_qwen2_5_vl.py | 178 | CODE | |
| LOW | …apter/src/mcore_adapter/models/qwen3_5_moe/__init__.py | 83 | CODE | |
| LOW | …src/mcore_adapter/models/qwen2_vl/modeling_qwen2_vl.py | 177 | CODE | |
| LOW | …e_adapter/src/mcore_adapter/models/qwen3_5/__init__.py | 186 | CODE | |
| LOW | …src/mcore_adapter/models/qwen3_vl/transformer_block.py | 38 | CODE | |
| LOW | …src/mcore_adapter/models/qwen3_vl/transformer_block.py | 175 | CODE | |
| LOW | …dapter/src/mcore_adapter/models/qwen3_vl/rope_utils.py | 186 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/adapters/utils.py | 20 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/adapters/lora_layer.py | 531 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/adapters/lora_layer.py | 145 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/adapters/lora_layer.py | 209 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/adapters/lora_layer.py | 264 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/adapters/lora_layer.py | 354 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/trainer/trainer.py | 410 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/trainer/trainer.py | 628 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/trainer/trainer.py | 809 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/trainer/trainer.py | 950 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/trainer/dpo_trainer.py | 263 | CODE | |
| LOW | roll/pipeline/base_worker.py | 75 | CODE | |
| LOW | roll/pipeline/base_pipeline.py | 190 | CODE | |
| LOW | roll/pipeline/base_pipeline.py | 237 | CODE | |
| LOW | roll/pipeline/rlvr/rlvr_pipeline.py | 503 | CODE | |
| LOW | roll/pipeline/rlvr/actor_pg_worker.py | 26 | CODE | |
| LOW | roll/pipeline/rlvr/actor_pg_worker.py | 444 | CODE | |
| LOW | roll/pipeline/rlvr/rlvr_vlm_rollout_pipeline.py | 368 | CODE | |
| LOW | roll/pipeline/rlvr/rlvr_config.py | 157 | CODE | |
| LOW | roll/pipeline/rlvr/rlvr_vlm_pipeline.py | 426 | CODE | |
| LOW | roll/pipeline/rlvr/actor_worker.py | 169 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/video_r1_reward_worker.py | 32 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 1031 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 1112 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 214 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 301 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 673 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 753 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 1199 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 1643 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/gsm8k_math_reward_worker.py | 52 | CODE | |
| LOW | …l/pipeline/rlvr/rewards/remote_reward_system_worker.py | 185 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/ifeval_rule_reward_worker.py | 44 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/math_rule_reward_worker.py | 40 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/math_rule_reward_worker.py | 184 | CODE | |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 37 | CODE | |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 479 | CODE | |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 536 | CODE | |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 656 | CODE | |
| 166 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | mcore_adapter/src/mcore_adapter/platforms/platform.py | 163 | Generate the runtime environment variables required for vLLM execution on the specified GPU rank. | STRING |
| HIGH | …src/mcore_adapter/parallel_functions/fused_logprobs.py | 261 | Fused log_probs forward pass with in-place output tensors. Args: x: Input logits tensor of shape (M, N | STRING |
| HIGH | …src/mcore_adapter/parallel_functions/fused_logprobs.py | 578 | Entropy backward pass using fused kernel. This function computes the gradient of entropy with respect to the i | STRING |
| HIGH | …l/pipeline/rlvr/rewards/remote_reward_system_worker.py | 410 | Normalize various input data formats into a uniform reward reference format. Args: data (D | STRING |
| HIGH | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 44 | Select an ALB load balancer ID from a comma-separated list based on hash of job_name and listen_port. This fun | STRING |
| HIGH | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 98 | Discover all ALBs in the current region and set them to environment variable ALB_LOAD_BALANCER_IDS. This funct | STRING |
| HIGH | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 400 | Poll listener status until it reaches target state. Args: client: ALB client instance listener | STRING |
| HIGH | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 459 | Poll server group status until it reaches target state. Args: client: ALB client instance serv | STRING |
| HIGH | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 803 | Save server group ID or listener ID to a file in ALB_RESOURCE_CLEAN_DIR. Args: resource_id: Resource I | STRING |
| HIGH | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 991 | Poll rule status until it reaches target state. Args: client: ALB client instance rule_id: Rul | STRING |
| HIGH | roll/pipeline/agentic/llm_proxy/proxy_utils.py | 28 | Generate text through proxy with support for multimodal inputs. This function formats messages using chat temp | STRING |
| HIGH | roll/pipeline/agentic/env_manager/proxy_env_manager.py | 187 | Core inference handler shared by Push (HTTP) and Pull (ModelService) modes. Args: body: Pa | STRING |
| HIGH | roll/platforms/platform.py | 169 | Generate the runtime environment variables required for vLLM execution on the specified GPU rank. | STRING |
| HIGH | roll/distributed/scheduler/rollout_mock_mixin.py | 162 | Load pre-recorded DataProto from disk (strict mode). Args: global_step: Current training s | STRING |
| HIGH | roll/distributed/scheduler/protocol.py | 707 | Slice the DataProto and return a new DataProto object. Args: start (int, optional): Start | STRING |
| HIGH | roll/distributed/scheduler/rollout_scheduler.py | 713 | Thin wrapper: Delegate shrink operation to RequestScheduler. v4.6 ARCHITECTURAL CHANGE: RolloutScheduler no lon | STRING |
| HIGH | roll/distributed/scheduler/rollout_scheduler.py | 754 | Thin wrapper: Delegate expand operation to RequestScheduler. v4.6 ARCHITECTURAL CHANGE: RolloutScheduler no lon | STRING |
| HIGH | roll/distributed/scheduler/router.py | 323 | Complete atomic shrink operation: validate → rebalance → offload → update routing. Orchestrates the full worker | STRING |
| HIGH | roll/distributed/scheduler/router.py | 383 | Complete atomic expand operation: validate → load → rebalance → update routing. Orchestrates the full worker ex | STRING |
| HIGH | roll/distributed/scheduler/router.py | 1081 | Abort requests on shrinking workers, clear mappings for natural re-dispatch. Args: shrink_dp_ranks: | STRING |
| HIGH | roll/distributed/scheduler/router.py | 1116 | Internal implementation of shrink rebalancing. PRE-CONDITION: routing_lock MUST be held by caller (shrink_worke | STRING |
| HIGH | roll/distributed/scheduler/router.py | 1187 | Add workers and rebalance via src_rank-level abort. Args: expand_dp_ranks: DP ranks to add to activ | STRING |
| HIGH | roll/distributed/scheduler/router.py | 1220 | Internal implementation of expand rebalancing. PRE-CONDITION: routing_lock MUST be held by caller (expand_worke | STRING |
| HIGH | roll/distributed/strategy/strategy.py | 245 | Compute divergence loss between student and teacher distributions with support for distributed training. | STRING |
| HIGH | roll/utils/sequence_packing.py | 152 | Split mini_batch into micro batches with sequence packing strategy. This function: 1. Calculat | STRING |
| HIGH | roll/utils/hash_utils.py | 7 | Compute the SHA256 hash of a Python object. This function handles basic types, None, lists, tuples, dictionarie | STRING |
| HIGH | roll/utils/qwen_vl_utils.py | 154 | calculate the number of frames for video used for model inputs. Args: ele (dict): a dict contains the confi | STRING |
| HIGH | roll/utils/qwen_vl_utils.py | 244 | Calculate the start and end frame indices based on the given time range. Args: ele (dict): A dictionar | STRING |
| HIGH | roll/utils/config_utils.py | 16 | Calculate the data parallel size for Megatron. Megatron uses: DP = Total_GPUs / (TP × PP × CP × EP) | STRING |
| HIGH | roll/third_party/megatron/fused_entropy.py | 450 | Fused entropy forward pass with in-place output tensors. This function computes the entropy of each row in the | STRING |
| HIGH | roll/third_party/megatron/fused_entropy.py | 781 | Entropy backward pass using fused kernel. This function computes the gradient of entropy with respect to the i | STRING |
| HIGH | roll/third_party/megatron/router_replay_utils.py | 227 | Reorder and merge per-VPP layer blocks into a contiguous layer dimension. Given a tensor shaped as [bs*vpp_siz | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | mcore_adapter/src/mcore_adapter/platforms/rocm.py | 0 | update environment variables to control device visibility. args: env_vars (dict): dictionary of current environment vari | STRING |
| HIGH | mcore_adapter/src/mcore_adapter/platforms/platform.py | 0 | update environment variables to control device visibility. args: env_vars (dict): dictionary of current environment vari | STRING |
| HIGH | roll/platforms/rocm.py | 0 | update environment variables to control device visibility. args: env_vars (dict): dictionary of current environment vari | STRING |
| HIGH | roll/platforms/platform.py | 0 | update environment variables to control device visibility. args: env_vars (dict): dictionary of current environment vari | STRING |
| HIGH | …mcore_adapter/models/qwen2_5_vl/modeling_qwen2_5_vl.py | 0 | inputs_embeds: [s, b, h] or [s/tp, b, h] when sequence parallel ranges: sequence range | STRING |
| HIGH | …mcore_adapter/models/qwen3_omni/modeling_qwen3_omni.py | 0 | inputs_embeds: [s, b, h] or [s/tp, b, h] when sequence parallel ranges: sequence range | STRING |
| HIGH | …src/mcore_adapter/models/qwen2_vl/modeling_qwen2_vl.py | 0 | inputs_embeds: [s, b, h] or [s/tp, b, h] when sequence parallel ranges: sequence range | STRING |
| HIGH | …r/src/mcore_adapter/models/qwen3_5/modeling_qwen3_5.py | 0 | inputs_embeds: [s, b, h] or [s/tp, b, h] when sequence parallel ranges: sequence range | STRING |
| HIGH | …mcore_adapter/models/qwen2_5_vl/modeling_qwen2_5_vl.py | 0 | calculate split plan and local data according to workload, assuming workload proportional to length args: input_lengths | STRING |
| HIGH | …src/mcore_adapter/models/qwen2_vl/modeling_qwen2_vl.py | 0 | calculate split plan and local data according to workload, assuming workload proportional to length args: input_lengths | STRING |
| HIGH | …r/src/mcore_adapter/models/qwen3_5/modeling_qwen3_5.py | 0 | calculate split plan and local data according to workload, assuming workload proportional to length args: input_lengths | STRING |
| HIGH | …src/mcore_adapter/models/qwen3_vl/modeling_qwen3_vl.py | 0 | calculate split plan and local data according to workload, assuming workload proportional to length args: input_lengths | STRING |
| HIGH | roll/pipeline/base_worker.py | 0 | loss func接口定义: data: dataproto, 由train_step透传 output_tensor: torch.tensor, model.forward()的输出tensor | STRING |
| HIGH | roll/pipeline/rlvr/actor_pg_worker.py | 0 | loss func接口定义: data: dataproto, 由train_step透传 output_tensor: torch.tensor, model.forward()的输出tensor | STRING |
| HIGH | roll/pipeline/rlvr/actor_worker.py | 0 | loss func接口定义: data: dataproto, 由train_step透传 output_tensor: torch.tensor, model.forward()的输出tensor | STRING |
| HIGH | roll/pipeline/agentic/agentic_actor_pg_worker.py | 0 | loss func接口定义: data: dataproto, 由train_step透传 output_tensor: torch.tensor, model.forward()的输出tensor | STRING |
| HIGH | roll/pipeline/agentic/agentic_actor_worker.py | 0 | loss func接口定义: data: dataproto, 由train_step透传 output_tensor: torch.tensor, model.forward()的输出tensor | STRING |
| HIGH | roll/pipeline/dpo/actor_worker.py | 0 | loss func接口定义: data: dataproto, 由train_step透传 output_tensor: torch.tensor, model.forward()的输出tensor | STRING |
| HIGH | …vr/rewards/multiple_choice_boxed_rule_reward_worker.py | 0 | 提取输入字符串中最后一个"end_think"标签之后的内容， 并移除结果字符串开头的所有换行符。 args: input_string: 原始字符串。 returns: 提取并处理后的字符串。如果未找到"end_think"标签，则返回空 | STRING |
| HIGH | …peline/rlvr/rewards/crossthinkqa_rule_reward_worker.py | 0 | 提取输入字符串中最后一个"end_think"标签之后的内容， 并移除结果字符串开头的所有换行符。 args: input_string: 原始字符串。 returns: 提取并处理后的字符串。如果未找到"end_think"标签，则返回空 | STRING |
| HIGH | …ipeline/rlvr/rewards/general_val_rule_reward_worker.py | 0 | 提取输入字符串中最后一个"end_think"标签之后的内容， 并移除结果字符串开头的所有换行符。 args: input_string: 原始字符串。 returns: 提取并处理后的字符串。如果未找到"end_think"标签，则返回空 | STRING |
| HIGH | roll/pipeline/rlvr/rewards/ifeval_rule_reward_worker.py | 0 | 一个示例 reward worker，用于执行 ifeval 验证并把每个 func 的结果放到 output.tensors 中。 在此示例里，ground_truths的str | STRING |
| HIGH | …peline/rlvr/rewards/crossthinkqa_rule_reward_worker.py | 0 | 一个示例 reward worker，用于执行 ifeval 验证并把每个 func 的结果放到 output.tensors 中。 在此示例里，ground_truths的str | STRING |
| HIGH | …ipeline/rlvr/rewards/general_val_rule_reward_worker.py | 0 | 一个示例 reward worker，用于执行 ifeval 验证并把每个 func 的结果放到 output.tensors 中。 在此示例里，ground_truths的str | STRING |
| HIGH | roll/pipeline/agentic/env_manager/base_env_manager.py | 0 | 1. each time run_rollout_loop is called, it will continuously play episodes until it receives a command that data collec | STRING |
| HIGH | roll/pipeline/agentic/env_manager/traj_env_manager.py | 0 | 1. each time run_rollout_loop is called, it will continuously play episodes until it receives a command that data collec | STRING |
| HIGH | …ll/pipeline/agentic/env_manager/vl_traj_env_manager.py | 0 | 1. each time run_rollout_loop is called, it will continuously play episodes until it receives a command that data collec | STRING |
| HIGH | roll/distributed/strategy/megatron_strategy.py | 0 | input_ids [[p, p, r, r, r, 0, 0]] p: prompt, r: response, 0: pad response_mask [[0, 0, 1, 1, 1, 0, 0]] | STRING |
| HIGH | roll/distributed/strategy/fsdp2_strategy.py | 0 | input_ids [[p, p, r, r, r, 0, 0]] p: prompt, r: response, 0: pad response_mask [[0, 0, 1, 1, 1, 0, 0]] | STRING |
| HIGH | roll/models/func_providers.py | 0 | input_ids [[p, p, r, r, r, 0, 0]] p: prompt, r: response, 0: pad response_mask [[0, 0, 1, 1, 1, 0, 0]] | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | roll/pipeline/rlvr/rlvr_pipeline.py | 161 | for domain in self.pipeline_config.actor_train.data_args.domain_interleave_probs.keys(): | CODE |
| CRITICAL | roll/pipeline/rlvr/rlvr_pipeline.py | 693 | self.pipeline_config.actor_train.strategy_args.strategy_config.get("pipeline_model_paral | CODE |
| CRITICAL | roll/pipeline/rlvr/rlvr_pipeline.py | 694 | self.pipeline_config.actor_train.strategy_args.strategy_config.get("virtual_pipeline_mod | CODE |
| CRITICAL | roll/pipeline/rlvr/rlvr_pipeline.py | 859 | self.pipeline_config.actor_train.strategy_args.strategy_config.get("pipeline_mod | CODE |
| CRITICAL | roll/pipeline/rlvr/rlvr_pipeline.py | 860 | self.pipeline_config.actor_train.strategy_args.strategy_config.get("virtual_pipe | CODE |
| CRITICAL | roll/pipeline/rlvr/rlvr_rollout_pipeline.py | 35 | assert self.pipeline_config.actor_infer.strategy_args.strategy_config.get("load_format", "dummy") != "dummy" | CODE |
| CRITICAL | roll/pipeline/rlvr/rlvr_rollout_pipeline.py | 39 | assert self.pipeline_config.actor_infer.strategy_args.strategy_config.get("sleep_level", 1) == 1, ( | CODE |
| CRITICAL | roll/pipeline/rlvr/rlvr_vlm_rollout_pipeline.py | 281 | for domain in self.pipeline_config.actor_train.data_args.domain_interleave_probs.keys(): | CODE |
| CRITICAL | roll/pipeline/rlvr/rlvr_vlm_pipeline.py | 198 | for domain in self.pipeline_config.actor_train.data_args.domain_interleave_probs.keys(): | CODE |
| CRITICAL | roll/pipeline/agentic/agentic_pipeline.py | 429 | self.pipeline_config.actor_train.strategy_args.strategy_config.get("pipeline_model_p | CODE |
| CRITICAL | roll/pipeline/agentic/agentic_pipeline.py | 430 | self.pipeline_config.actor_train.strategy_args.strategy_config.get("virtual_pipeline | CODE |
| CRITICAL | roll/pipeline/agentic/agentic_pipeline.py | 541 | self.pipeline_config.actor_train.strategy_args.strategy_config.get("pipeline_model_p | CODE |
| CRITICAL | roll/pipeline/agentic/agentic_pipeline.py | 542 | self.pipeline_config.actor_train.strategy_args.strategy_config.get("virtual_pipeline | CODE |
| CRITICAL⚡ | roll/distributed/strategy/veomni_strategy.py | 238 | generation_config = self.worker.pipeline_config.actor_infer.generating_args.to_dict() | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | roll/pipeline/agentic/agentic_pipeline.py | 270 | # Step 0: active_dp_ranks initialized with all ranks {0,1,2,3}, no expand needed | COMMENT |
| LOW⚡ | roll/pipeline/agentic/tools/mcp_tool.py | 339 | # Step 1: Find the schema for the requested tool. | STRING |
| LOW⚡ | roll/pipeline/agentic/tools/mcp_tool.py | 347 | # Step 2: Use the jsonschema library to validate the parameters. | STRING |
| LOW⚡ | roll/distributed/strategy/megatron_strategy.py | 633 | # Step 1: Correct sequence-major reshape: [1, S/cp_size*B, L, topk] → [S/cp_size, B, L, topk] | COMMENT |
| LOW⚡ | roll/distributed/strategy/megatron_strategy.py | 638 | # Step 2: Permute to batch-major: [B, S/cp_size, L, topk] | COMMENT |
| LOW⚡ | roll/distributed/strategy/megatron_strategy.py | 641 | # Step 3: CP gather to reconstruct full sequence: [B, S_actual, L, topk] | COMMENT |
| LOW⚡ | roll/distributed/strategy/megatron_strategy.py | 645 | # Step 4: pad back to seq_length so downstream (finalize cat, broadcast, | COMMENT |
| LOW⚡ | roll/utils/sequence_packing.py | 229 | # Step 4: VP interleaved schedule requires num_microbatches % microbatch_group_size_per_vp_stage == 0. | COMMENT |
| LOW⚡ | roll/utils/sequence_packing.py | 234 | # Step 5: Calculate workload for load balancing | COMMENT |
| LOW⚡ | roll/utils/sequence_packing.py | 240 | # Step 6: Partition samples into micro batches with balanced workload | COMMENT |
| LOW⚡ | roll/utils/sequence_packing.py | 247 | # Step 7: Sort and reorder for better pipeline scheduling | COMMENT |
| LOW | roll/utils/sequence_packing.py | 202 | # Step 2: Calculate initial number of micro batches | COMMENT |
| LOW | roll/utils/sequence_packing.py | 215 | # Step 3: Synchronize across DP ranks (all ranks must have same count) | COMMENT |
| LOW | roll/utils/sequence_packing.py | 272 | # Step 8: Generate micro batches | COMMENT |
| LOW | roll/configs/base_config.py | 837 | # Step 1: Merge reference + teacher into unified _reference_configs dict. | COMMENT |
| LOW | roll/configs/base_config.py | 876 | # Step 2: Pure OPD mode | COMMENT |
| LOW | roll/configs/base_config.py | 897 | # Step 3: Mixed OPD mode | COMMENT |
| LOW | …s_roll/docs/User Guides/Pipeline/dpo_pipeline_start.md | 188 | ### Step 1: Configure Settings | COMMENT |
| LOW | …s_roll/docs/User Guides/Pipeline/dpo_pipeline_start.md | 198 | ### Step 2: Prepare Environment and Dependencies | COMMENT |
| LOW⚡ | …s_roll/docs/User Guides/Pipeline/dpo_pipeline_start.md | 210 | ### Step 3: Launch the Pipeline | COMMENT |
| LOW⚡ | …s_roll/docs/User Guides/Pipeline/dpo_pipeline_start.md | 218 | ### Step 4: Monitoring | COMMENT |
| LOW⚡ | …s_roll/docs/User Guides/Pipeline/dpo_pipeline_start.md | 228 | ### Step 5: Outputs and Results | COMMENT |
| LOW | …ll/docs/User Guides/Pipeline/distill_pipeline_start.md | 193 | ### Step 1: Configure Settings | COMMENT |
| LOW | …ll/docs/User Guides/Pipeline/distill_pipeline_start.md | 203 | ### Step 2: Prepare Environment and Dependencies | COMMENT |
| LOW⚡ | …ll/docs/User Guides/Pipeline/distill_pipeline_start.md | 215 | ### Step 3: Launch the Pipeline | COMMENT |
| LOW⚡ | …ll/docs/User Guides/Pipeline/distill_pipeline_start.md | 223 | ### Step 4: Monitoring | COMMENT |
| LOW⚡ | …ll/docs/User Guides/Pipeline/distill_pipeline_start.md | 233 | ### Step 5: Outputs and Results | COMMENT |
| LOW | …ll/docs/User Guides/Pipeline/vl_rlvr_pipeline_start.md | 287 | ### Step 1: Configure Settings | COMMENT |
| LOW | …ll/docs/User Guides/Pipeline/vl_rlvr_pipeline_start.md | 298 | ### Step 2: Prepare Environment and Dependencies | COMMENT |
| LOW⚡ | …ll/docs/User Guides/Pipeline/vl_rlvr_pipeline_start.md | 310 | ### Step 3: Launch the Pipeline | COMMENT |
| LOW⚡ | …ll/docs/User Guides/Pipeline/vl_rlvr_pipeline_start.md | 318 | ### Step 4: Monitoring | COMMENT |
| LOW⚡ | …ll/docs/User Guides/Pipeline/vl_rlvr_pipeline_start.md | 328 | ### Step 5: Outputs and Results | COMMENT |
| LOW | …ll/docs/User Guides/Pipeline/agentic_pipeline_start.md | 205 | ### Step 1: Configuration Setup | COMMENT |
| LOW | …ll/docs/User Guides/Pipeline/agentic_pipeline_start.md | 216 | ### Step 2: Environment and Dependency Preparation | COMMENT |
| LOW⚡ | …ll/docs/User Guides/Pipeline/agentic_pipeline_start.md | 228 | ### Step 3: Starting the Pipeline | COMMENT |
| LOW⚡ | …ll/docs/User Guides/Pipeline/agentic_pipeline_start.md | 236 | ### Step 4: Monitoring | COMMENT |
| LOW⚡ | …ll/docs/User Guides/Pipeline/agentic_pipeline_start.md | 246 | ### Step 5: Output and Results | COMMENT |
| LOW | …er Guides/Pipeline/on_policy_distill_pipeline_start.md | 375 | ### Step 1: Configuration Setup | COMMENT |
| LOW | …er Guides/Pipeline/on_policy_distill_pipeline_start.md | 386 | ### Step 2: Prepare Environment and Dependencies | COMMENT |
| LOW⚡ | …er Guides/Pipeline/on_policy_distill_pipeline_start.md | 398 | ### Step 3: Launch the Pipeline | COMMENT |
| LOW⚡ | …er Guides/Pipeline/on_policy_distill_pipeline_start.md | 406 | ### Step 4: Monitoring | COMMENT |
| LOW⚡ | …er Guides/Pipeline/on_policy_distill_pipeline_start.md | 416 | ### Step 5: Outputs and Results | COMMENT |
| LOW | …s_roll/docs/User Guides/Pipeline/sft_pipeline_start.md | 215 | ### Step 1: Configuration | COMMENT |
| LOW | …s_roll/docs/User Guides/Pipeline/sft_pipeline_start.md | 228 | ### Step 2: Prepare Environment and Dependencies | COMMENT |
| LOW⚡ | …s_roll/docs/User Guides/Pipeline/sft_pipeline_start.md | 239 | ### Step 3: Launch the Pipeline | COMMENT |
| LOW⚡ | …s_roll/docs/User Guides/Pipeline/sft_pipeline_start.md | 247 | ### Step 4: Monitoring | COMMENT |
| LOW⚡ | …s_roll/docs/User Guides/Pipeline/sft_pipeline_start.md | 256 | ### Step 5: Outputs and Results | COMMENT |
| LOW | …_roll/docs/User Guides/Pipeline/rlvr_pipeline_start.md | 301 | ### Step 1: Configure Settings | COMMENT |
| LOW | …_roll/docs/User Guides/Pipeline/rlvr_pipeline_start.md | 312 | ### Step 2: Prepare Environment and Dependencies | COMMENT |
| LOW⚡ | …_roll/docs/User Guides/Pipeline/rlvr_pipeline_start.md | 324 | ### Step 3: Launch the Pipeline | COMMENT |
| LOW⚡ | …_roll/docs/User Guides/Pipeline/rlvr_pipeline_start.md | 332 | ### Step 4: Monitoring | COMMENT |
| LOW⚡ | …_roll/docs/User Guides/Pipeline/rlvr_pipeline_start.md | 342 | ### Step 5: Outputs and Results | COMMENT |
| LOW | …l/docs/User Guides/Hardware Support/ascend_npu_rlvr.md | 15 | ## Step 1: Environment Setup | COMMENT |
| LOW | …l/docs/User Guides/Hardware Support/ascend_npu_rlvr.md | 102 | ## Step 2: Data Preparation | COMMENT |
| LOW | …l/docs/User Guides/Hardware Support/ascend_npu_rlvr.md | 191 | ## Step 3: Model Preparation | COMMENT |
| LOW | …l/docs/User Guides/Hardware Support/ascend_npu_rlvr.md | 225 | ## Step 4: Write the NPU Configuration | COMMENT |
| LOW | …l/docs/User Guides/Hardware Support/ascend_npu_rlvr.md | 471 | ## Step 5: Launch Training | COMMENT |
| LOW | …l/docs/User Guides/Hardware Support/ascend_npu_rlvr.md | 648 | ## Step 6: Monitor & Evaluate | COMMENT |
| LOW | …l/docs/User Guides/Hardware Support/ascend_npu_rlvr.md | 693 | ## Step 7: Resume from Checkpoint | COMMENT |
| LOW | …cs/User Guides/Hardware Support/ascend_npu_examples.md | 32 | ### Step 1: Start the Container | COMMENT |
| 19 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | mcore_adapter/examples/data/dpo_zh_demo.json | 3735 | "value": "创建一个完整的程序像这样将是一个复杂且漫长的过程，涉及图形和音频处理。然而，我可以指导您完成初始步骤，并为您提供资源，帮助您构建项目的简单文本版本。\n\n要获取天气数据，您可以使用OpenWeatherMa | CODE |
| HIGH | tests/pipeline/rlvr_megatron_config.yaml | 19 | # api_key: your_api_key | COMMENT |
| HIGH⚡ | tests/pipeline/agentic_pipeline_config.yaml | 16 | # api_key: your_api_key | COMMENT |
| HIGH⚡ | tests/pipeline/agentic_pipeline_config.yaml | 27 | # api_key: your_api_key | COMMENT |
| HIGH⚡ | …2.5-7B-agentic_megatron/agentic_val_webshop_gigpo.yaml | 31 | # api_key: your_api_key | COMMENT |
| HIGH⚡ | …s/qwen2.5-7B-agentic_megatron/agentic_val_webshop.yaml | 31 | # api_key: your_api_key | COMMENT |
| HIGH | …/User Guides/Tracker & Metrics/trackers_and_metrics.md | 81 | api_key: your_api_key # Your SwanLab API key | CODE |
| HIGH | …/User Guides/Tracker & Metrics/trackers_and_metrics.md | 61 | api_key: your_api_key # 您的 SwanLab API 密钥 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | mcore_adapter/src/mcore_adapter/checkpointing.py | 71 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/checkpointing.py | 116 | CODE | |
| LOW | …/src/mcore_adapter/models/converter/model_converter.py | 50 | CODE | |
| LOW | …mcore_adapter/models/qwen2_5_vl/modeling_qwen2_5_vl.py | 342 | CODE | |
| LOW | …apter/src/mcore_adapter/models/deepseek_v3/__init__.py | 89 | CODE | |
| LOW | …mcore_adapter/models/qwen3_omni/modeling_qwen3_omni.py | 225 | CODE | |
| LOW | …_adapter/src/mcore_adapter/models/glm4_moe/__init__.py | 80 | CODE | |
| LOW | …src/mcore_adapter/models/qwen2_vl/modeling_qwen2_vl.py | 322 | CODE | |
| LOW | …e_adapter/src/mcore_adapter/models/qwen3_5/__init__.py | 166 | CODE | |
| LOW | …r/src/mcore_adapter/models/qwen3_5/modeling_qwen3_5.py | 271 | CODE | |
| LOW | …src/mcore_adapter/models/qwen3_vl/transformer_block.py | 175 | CODE | |
| LOW | …src/mcore_adapter/models/qwen3_vl/modeling_qwen3_vl.py | 61 | CODE | |
| LOW | …src/mcore_adapter/models/qwen3_vl/modeling_qwen3_vl.py | 418 | CODE | |
| LOW | mcore_adapter/src/mcore_adapter/adapters/lora_layer.py | 38 | CODE | |
| LOW | roll/pipeline/base_worker.py | 136 | CODE | |
| LOW | roll/pipeline/base_worker.py | 366 | CODE | |
| LOW | roll/pipeline/base_worker.py | 551 | CODE | |
| LOW | roll/pipeline/base_worker.py | 675 | CODE | |
| LOW | roll/pipeline/base_worker.py | 737 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 1720 | CODE | |
| LOW | …vr/rewards/multiple_choice_boxed_rule_reward_worker.py | 160 | CODE | |
| LOW | …l/pipeline/rlvr/rewards/remote_reward_system_worker.py | 528 | CODE | |
| LOW | roll/pipeline/rlvr/rewards/ifeval_rule_reward_worker.py | 665 | CODE | |
| LOW | …peline/rlvr/rewards/crossthinkqa_rule_reward_worker.py | 262 | CODE | |
| LOW | …ipeline/rlvr/rewards/general_val_rule_reward_worker.py | 185 | CODE | |
| LOW | …ll/pipeline/rlvr/rewards/code_sandbox_reward_worker.py | 864 | CODE | |
| LOW | roll/pipeline/distill/distill_worker.py | 112 | CODE | |
| LOW | roll/pipeline/distill/distill_worker.py | 161 | CODE | |
| LOW | roll/pipeline/distill/distill_worker.py | 187 | CODE | |
| LOW | roll/pipeline/distill/distill_worker.py | 516 | CODE | |
| LOW | roll/pipeline/diffusion/rewards/geneval_scorer.py | 12 | CODE | |
| LOW | …ll/pipeline/diffusion/rewards/geneval_reward_worker.py | 134 | CODE | |
| LOW | …diffusion/models/scheduling_flow_match_sde_discrete.py | 48 | CODE | |
| LOW | …/diffusion/models/qwen_image/qwen_image_transformer.py | 31 | CODE | |
| LOW | …sion/models/qwen_image/vllm_omni_qwen_image_adapter.py | 237 | CODE | |
| LOW | roll/pipeline/dpo/actor_worker.py | 85 | CODE | |
| LOW | roll/pipeline/sft/sft_worker.py | 38 | CODE | |
| LOW | roll/pipeline/sft/sft_worker.py | 49 | CODE | |
| LOW | roll/pipeline/sft/sft_worker.py | 65 | CODE | |
| LOW | roll/distributed/scheduler/decorator.py | 248 | CODE | |
| LOW | roll/distributed/executor/worker.py | 210 | CODE | |
| LOW | roll/distributed/strategy/sglang_strategy.py | 316 | CODE | |
| LOW | roll/distributed/strategy/mock_strategy.py | 77 | CODE | |
| LOW | roll/distributed/strategy/vllm_strategy.py | 462 | CODE | |
| LOW | roll/distributed/strategy/vllm_strategy.py | 523 | CODE | |
| LOW | roll/distributed/strategy/fsdp2_strategy.py | 1629 | CODE | |
| LOW | roll/distributed/strategy/hf_strategy.py | 142 | CODE | |
| LOW | roll/utils/fsdp_utils.py | 449 | CODE | |
| LOW | roll/utils/fsdp_utils.py | 709 | CODE | |
| LOW | roll/utils/fsdp_utils.py | 747 | CODE | |
| LOW | roll/utils/collective/pg_utils.py | 11 | CODE | |
| LOW | roll/utils/context_parallel/ulysses_attention.py | 61 | CODE | |
| LOW | roll/utils/context_parallel/ulysses_attention.py | 361 | CODE | |
| LOW | roll/utils/context_parallel/ulysses_attention.py | 244 | CODE | |
| LOW | roll/models/model_providers.py | 415 | CODE | |
| LOW | roll/third_party/vllm/patch_transformers.py | 9 | CODE | |
| LOW | roll/third_party/vllm/patch_transformers.py | 85 | CODE | |
| LOW | roll/third_party/vllm_omni/worker.py | 284 | CODE | |
| LOW | roll/third_party/megatron/mtp_patcher.py | 52 | CODE | |
| LOW | roll/third_party/megatron/router_replay_utils.py | 263 | CODE | |
| 5 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …src/mcore_adapter/parallel_functions/vocab_parallel.py | 56 | # Create a mask of valid vocab ids (1 means it needs to be masked). | COMMENT |
| MEDIUM | …src/mcore_adapter/parallel_functions/vocab_parallel.py | 210 | # Create a mask of valid vocab ids (1 means it needs to be masked). | COMMENT |
| MEDIUM | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 1291 | # Initialize COCO object for ground truth | COMMENT |
| MEDIUM | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 1315 | # Initialize COCO object for ground truth | COMMENT |
| MEDIUM | roll/distributed/scheduler/protocol.py | 733 | # Create a slice object | COMMENT |
| MEDIUM | roll/datasets/collator.py | 299 | # Create a batched list from single object, differ with hf's single element list | COMMENT |
| MEDIUM | roll/utils/local_code/testing_util.py | 2 | # This file is a slightly modified version of the original code from LiveCodeBench: | COMMENT |
| MEDIUM | roll/utils/context_parallel/ulysses_attention.py | 1 | # This file is modified from https://github.com/feifeibear/long-context-attention | COMMENT |
| MEDIUM | roll/utils/context_parallel/globals.py | 1 | # This file is modified from https://github.com/feifeibear/long-context-attention | COMMENT |
| MEDIUM | roll/utils/context_parallel/all_to_all.py | 1 | # This file is modified from https://github.com/feifeibear/long-context-attention | COMMENT |
| MEDIUM | roll/utils/context_parallel/hf_flash_attention_patch.py | 264 | # Create a dummy that matches the query batch size. | COMMENT |
| MEDIUM | …ird_party/vllm/vllm_0_11_0/ray_distributed_executor.py | 69 | # Create the parallel GPU workers. | COMMENT |
| MEDIUM | …ird_party/vllm/vllm_0_11_0/ray_distributed_executor.py | 103 | # Create the workers. | COMMENT |
| MEDIUM | …distributed/strategy/test_vllm_strategy_beam_search.py | 238 | # Create a batch with dummy tensors to satisfy DataProto requirements | COMMENT |
| MEDIUM | …/distributed/strategy/grad_norm/test_grad_norm_unit.py | 20 | # Create a parameter with known gradient | COMMENT |
| MEDIUM | …/distributed/strategy/grad_norm/test_grad_norm_unit.py | 75 | # Create a simple loss: L = w1[0]^2 + w1[1]^2 + w2[0]^2 | COMMENT |
| MEDIUM | …distributed/strategy/grad_norm/test_fsdp2_grad_norm.py | 233 | # Create a very simple model for easy verification | COMMENT |
| MEDIUM | …t_parallel/test_fsdp2_cp_qwen3_hf_rmpad_equivalence.py | 298 | # Create a small packed input to probe | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | mcore_adapter/src/mcore_adapter/__init__.py | 6 | __all__ = ["McaModelConfig", "McaGPTModel", "TrainingArguments", "Seq2SeqTrainingArguments", "McaTrainer"] | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/rocm.py | 28 | def set_allocator_settings(cls, env: str) -> None: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/rocm.py | 53 | def update_env_vars_for_visible_devices(cls, env_vars: dict, gpu_ranks: list) -> None: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/__init__.py | 55 | __all__ = [ | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/npu.py | 26 | def set_allocator_settings(cls, env: str) -> None: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/platform.py | 111 | def set_allocator_settings(cls, env: str) -> None: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/platform.py | 126 | def update_env_vars_for_visible_devices(cls, env_vars: dict, gpu_ranks: list) -> None: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/cuda.py | 30 | def set_allocator_settings(cls, env: str) -> None: | CODE |
| LOW | mcore_adapter/src/mcore_adapter/platforms/unknown.py | 24 | def set_allocator_settings(cls, env: str) -> None: | CODE |
| LOW | …apter/src/mcore_adapter/parallel_functions/__init__.py | 6 | __all__ = ["context_parallel_gather", "encoder_sequence_parallel_gather", "encoder_small_batch_size_gather", "vocab_para | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/__init__.py | 27 | __all__ = ["McaModelConfig", "McaGPTModel", "AutoConfig", "AutoModel", "VirtualModels"] | CODE |
| LOW | …dapter/src/mcore_adapter/models/qwen3_next/__init__.py | 220 | __all__ = ["Qwen3NextConfig", "Qwen3NextModel"] | CODE |
| LOW | mcore_adapter/src/mcore_adapter/models/auto/__init__.py | 5 | __all__ = ["AutoConfig", "AutoModel", "register_config", "register_model"] | CODE |
| LOW | …_adapter/src/mcore_adapter/models/kimi_k25/__init__.py | 179 | __all__ = ["KimiK2_5Model"] | CODE |
| LOW | …dapter/src/mcore_adapter/models/qwen2_5_vl/__init__.py | 83 | __all__ = ["Qwen2_5_VLConfig", "Qwen2_5_VLModel"] | CODE |
| LOW | …apter/src/mcore_adapter/models/deepseek_v3/__init__.py | 311 | __all__ = ["DeepSeekV3Model"] | CODE |
| LOW | …dapter/src/mcore_adapter/models/qwen3_omni/__init__.py | 143 | __all__ = ["Qwen3OmniMoeConfig", "Qwen3OmniMoeModel"] | CODE |
| LOW | …_adapter/src/mcore_adapter/models/qwen2_vl/__init__.py | 83 | __all__ = ["Qwen2VLConfig", "Qwen2VLModel"] | CODE |
| LOW | …e_adapter/src/mcore_adapter/models/qwen3_5/__init__.py | 316 | __all__ = ["Qwen3_5Config", "Qwen3_5Model"] | CODE |
| LOW | …ore_adapter/src/mcore_adapter/models/llama/__init__.py | 64 | __all__ = ["LlamaConfig", "LlamaModel"] | CODE |
| LOW | …_adapter/src/mcore_adapter/models/qwen3_vl/__init__.py | 92 | __all__ = ["Qwen3VLConfig", "Qwen3VLModel"] | CODE |
| LOW | mcore_adapter/src/mcore_adapter/adapters/__init__.py | 31 | __all__ = [ | CODE |
| LOW | mcore_adapter/src/mcore_adapter/trainer/__init__.py | 7 | __all__ = ["McaTrainer", "DPOTrainer", "DPOConfig", "RewardTrainer"] | CODE |
| LOW | roll/pipeline/agentic/proxy/proxy_server.py | 13 | logger = logging.getLogger(__name__) | CODE |
| LOW | roll/pipeline/agentic/proxy/router/__init__.py | 9 | __all__ = ["ProxyRouter", "ALBProxyRouter", "IngressProxyRouter", "batch_cleanup", "create_proxy_router"] | CODE |
| LOW | roll/pipeline/agentic/agent_runner/__init__.py | 3 | __all__ = ["AgentRunner", "EpisodeResult"] | CODE |
| LOW | roll/pipeline/agentic/agent_runner/rock/__init__.py | 5 | __all__ = ["RockAgentRunner", "PushModeRunner", "PullModeRunner"] | CODE |
| LOW⚡ | …ipeline/agentic/agent_runner/rock/rock_agent_runner.py | 79 | def set_episode_context(self, output_queue, group_id: int, episode_id: int) -> None: | CODE |
| LOW | roll/pipeline/agentic/env_manager/message_tracker.py | 195 | def update_tools(self, tools: List[dict]) -> None: | CODE |
| LOW⚡ | roll/pipeline/diffusion/tensor_transfer.py | 39 | def set_gpu_tensor_transfer_enabled(self, enabled: bool) -> None: | CODE |
| LOW | roll/pipeline/diffusion/models/__init__.py | 15 | __all__ = [ | CODE |
| LOW | roll/pipeline/diffusion/models/qwen_image/__init__.py | 12 | __all__ = [ | CODE |
| LOW | roll/pipeline/diffusion/models/wan/__init__.py | 5 | __all__ = ["WanDiffusionAdapter"] | CODE |
| LOW | roll/platforms/rocm.py | 28 | def set_allocator_settings(cls, env: str) -> None: | CODE |
| LOW | roll/platforms/rocm.py | 56 | def update_env_vars_for_visible_devices(cls, env_vars: dict, gpu_ranks: list) -> None: | CODE |
| LOW | roll/platforms/__init__.py | 74 | __all__ = [ | CODE |
| LOW | roll/platforms/npu.py | 29 | def set_allocator_settings(cls, env: str) -> None: | CODE |
| LOW | roll/platforms/platform.py | 109 | def set_allocator_settings(cls, env: str) -> None: | CODE |
| LOW | roll/platforms/platform.py | 132 | def update_env_vars_for_visible_devices(cls, env_vars: dict, gpu_ranks: list) -> None: | CODE |
| LOW | roll/platforms/cuda.py | 28 | def set_allocator_settings(cls, env: str) -> None: | CODE |
| LOW | roll/platforms/unknown.py | 23 | def set_allocator_settings(cls, env: str) -> None: | CODE |
| LOW | roll/distributed/scheduler/transfer_backend.py | 234 | __all__ = ["init_transfer_backend", "put", "get", "delete"] | CODE |
| LOW | roll/utils/qwen_vl_utils.py | 43 | logger = logging.getLogger(__name__) | CODE |
| LOW | roll/utils/context_parallel/__init__.py | 4 | __all__ = ["set_upg_manager", "get_ulysses_group", "apply_ulysses_patch", "unapply_ulysses_patch"] | CODE |
| LOW | roll/third_party/vllm/gdn_patcher.py | 20 | logger = logging.getLogger(__name__) | CODE |
| LOW | roll/third_party/vllm/__init__.py | 216 | __all__ = ["create_async_llm"] | CODE |
| LOW | roll/third_party/vllm_omni/__init__.py | 151 | __all__ = [ | CODE |
| LOW | roll/third_party/megatron/optimizer.py | 14 | logger = logging.getLogger(__name__) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | mcore_adapter/src/mcore_adapter/checkpointing.py | 41 | release = metastring == "release" | COMMENT |
| LOW | mcore_adapter/src/mcore_adapter/platforms/platform.py | 41 | # available dispatch keys: | COMMENT |
| LOW | …src/mcore_adapter/models/qwen3_vl/transformer_block.py | 241 | # size (mbs) == 1, since in this case, 'hidden_states.transpose()' | COMMENT |
| LOW | roll/pipeline/rlvr/rlvr_vlm_pipeline.py | 121 | ) | COMMENT |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 441 | COMMENT | |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 461 | # maxDets - [1 10 100] M=3 thresholds on max detections per image | COMMENT |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 481 | # date - date evaluation was performed | COMMENT |
| LOW | …l/pipeline/rlvr/rewards/remote_reward_system_worker.py | 1 | # Copyright 2025 alibaba-inc. and/or its affiliates | COMMENT |
| LOW | roll/pipeline/agentic/agentic_pipeline.py | 321 | metrics.update(val_metrics) | COMMENT |
| LOW | …diffusion/models/scheduling_flow_match_sde_discrete.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates | COMMENT |
| LOW | …/diffusion/models/qwen_image/qwen_image_transformer.py | 1 | # Copyright 2025 Bytedance Ltd. and/or its affiliates | COMMENT |
| LOW | roll/platforms/platform.py | 41 | # use "CPU" as a fallback for platforms not registered in PyTorch | COMMENT |
| LOW | roll/utils/taskgroups.py | 1 | # borrow from cpython | COMMENT |
| LOW | roll/utils/taskgroups.py | 121 | # # If this flag is set we *must* call uncancel(). | COMMENT |
| LOW | roll/utils/taskgroups.py | 281 | # "not cancelled" later in __aexit__. Example situation that | COMMENT |
| LOW | roll/third_party/fsdp2/tiled_mlp.py | 1 | # Copyright 2024 Bytedance Ltd. and/or its affiliates | COMMENT |
| LOW | roll/third_party/vllm/fp8.py | 21 | logger = get_logger() | COMMENT |
| LOW | roll/third_party/megatron/fused_entropy.py | 841 | ) | COMMENT |
| LOW | roll/third_party/megatron/fused_entropy.py | 861 | COMMENT | |
| LOW | tests/pipeline/rlvr_megatron_config.yaml | 181 | # tag_included: [reference] | COMMENT |
| LOW | tests/pipeline/rlvr_megatron_config.yaml | 201 | # infer_batch_size: 1 | COMMENT |
| LOW | tests/pipeline/agentic_pipeline_config.yaml | 21 | # - agentic | COMMENT |
| LOW | …distributed/strategy/log_probs/layer_states_capture.py | 61 | return | COMMENT |
| LOW | tests/third_party/vllm/test_vllm_mem_oom.py | 61 | # snapshot_last = tracemalloc.take_snapshot() | COMMENT |
| LOW | tests/third_party/vllm/test_vllm_mem_oom.py | 81 | # | COMMENT |
| LOW | …2.5-7B-agentic_megatron/agentic_val_webshop_gigpo.yaml | 21 | # name: ${exp_name}_webshop | COMMENT |
| LOW | …s/qwen2.5-7B-agentic_megatron/agentic_val_webshop.yaml | 21 | # name: ${exp_name}_webshop | COMMENT |
| LOW | …vr_megatron/rlvr_config_8gpus_llm_as_judge_server.yaml | 81 | reward_pretrain: Qwen/Qwen2.5-7B | COMMENT |
| LOW | …5-7B-rlvr_megatron/rlvr_config_8gpus_llm_as_judge.yaml | 81 | reward_pretrain: Qwen/Qwen2.5-7B | COMMENT |
| LOW | …s/qwen3-next-80BA3B-rlvr_megatron/rlvr_config_amd.yaml | 81 | reward_pretrain: Qwen/Qwen3-Next-80B-A3B-Instruct | COMMENT |
| LOW | …mples/qwen3-next-80BA3B-rlvr_megatron/rlvr_config.yaml | 81 | reward_pretrain: Qwen/Qwen3-Next-80B-A3B-Instruct | COMMENT |
| LOW | …mples/qwen3-30BA3B-rlvr_megatron/rlvr_config_lora.yaml | 241 | # # NOTE: llm as judge 也需要gpu, 不能和actor infer共享gpu | COMMENT |
| LOW | …mples/qwen3-30BA3B-rlvr_megatron/rlvr_config_lora.yaml | 261 | # strategy_args: | COMMENT |
| LOW | examples/qwen3-omni/audio_test_80G.yaml | 41 | use_kl_loss: true | COMMENT |
| LOW | examples/qwen3-omni/audio_test_80G.yaml | 81 | # "ability": "speech_recognition", | COMMENT |
| LOW | …mples/agentic_demo/run_openreward_endless_terminals.sh | 1 | #!/bin/bash | COMMENT |
| LOW | examples/qwen3_agentic_gem/start_retrieval_server.sh | 1 | #!/bin/bash | COMMENT |
| LOW | examples/qwen2.5-7B-rlvr-offpolicy/rlvr_config.yaml | 21 | # tracker_kwargs: | COMMENT |
| LOW | examples/qwen2.5-7B-rlvr-offpolicy/rlvr_config.yaml | 201 | # crossthinkqa: | COMMENT |
| LOW | examples/qwen2.5-7B-rlvr-offpolicy/rlvr_config.yaml | 221 | # infer_batch_size: 4 | COMMENT |
| LOW | examples/qwen2.5-7B-rlvr-offpolicy/rlvr_config.yaml | 241 | # judge_prompt: Qwen2.5-7B-Instruct-RLVR-prompt | COMMENT |
| LOW | examples/qwen2.5-7B-rlvr-offpolicy/rlvr_config.yaml | 261 | # strategy_config: null | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …src/mcore_adapter/parallel_functions/vocab_parallel.py | 85 | # Check if we can use fused kernel (only for TP=1) | COMMENT |
| LOW | …core_adapter/parallel_functions/fused_cross_entropy.py | 202 | # Set loss to 0 if this index should be ignored, otherwise compute normally | COMMENT |
| LOW | …core_adapter/parallel_functions/fused_cross_entropy.py | 456 | # Set dloss to 0 if this index should be ignored | COMMENT |
| LOW | mcore_adapter/src/mcore_adapter/trainer/trainer.py | 720 | # Check if continuing training from a checkpoint | COMMENT |
| LOW | roll/pipeline/rlvr/rlvr_pipeline.py | 276 | # Assign clusters to attributes (preserving original order semantics) | COMMENT |
| LOW | roll/pipeline/rlvr/rlvr_vlm_pipeline.py | 283 | # Assign clusters to attributes (preserving original order semantics) | COMMENT |
| LOW | roll/pipeline/rlvr/rewards/detection_reward_worker.py | 1013 | # Check if boxes overlap | COMMENT |
| LOW | roll/pipeline/agentic/agentic_pipeline.py | 941 | # Check if this DP rank's GPUs are NOT in the freed set | COMMENT |
| LOW | roll/pipeline/agentic/utils.py | 494 | # Check if this teacher has a routing mask (set by pipeline when needs_teacher_routing) | COMMENT |
| LOW | roll/pipeline/agentic/tools/mcp_tool.py | 374 | # Check if the item is a text block and has non-empty text | STRING |
| LOW⚡ | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 704 | # Check if clean_dir is empty and remove it if so | COMMENT |
| LOW | roll/pipeline/agentic/proxy/router/alb_proxy_router.py | 951 | # Add rules to listener and save rule ids to file | COMMENT |
| LOW | roll/distributed/scheduler/protocol.py | 1046 | # Check if any data has this key, not just the first one | COMMENT |
| LOW | roll/distributed/scheduler/rollout_scheduler.py | 173 | # Check if this episode has been submitted | COMMENT |
| LOW | roll/distributed/strategy/vllm_strategy.py | 404 | # Check if beam search is requested | COMMENT |
| LOW | roll/utils/functionals.py | 1634 | # Check if this teacher has a routing mask (set by pipeline when needs_teacher_routing) | COMMENT |
| LOW | roll/utils/train_infer_corrections.py | 227 | # Check if required fields are present | COMMENT |
| LOW | roll/utils/train_infer_corrections.py | 267 | # Check if mask is already sliced (shape [B, T-1]) or full (shape [B, T]) | COMMENT |
| LOW | roll/third_party/vllm/gdn_patcher.py | 47 | # Check if already patched (has _original_build attribute) | COMMENT |
| LOW | roll/third_party/vllm/gdn_patcher.py | 52 | # Check if the fix is already in the source | COMMENT |
| LOW | roll/third_party/vllm_omni/async_omni.py | 122 | # Set ROLL_VLLM_OMNI_RPC_TIMEOUT_S to a positive float (seconds) to enable. | COMMENT |
| LOW | …ted/strategy/log_probs/test_fsdp_vlm_log_probs_perf.py | 211 | # Check if results are numerically equivalent | COMMENT |
| LOW | …ributed/strategy/log_probs/analyze_layer_divergence.py | 40 | # Check if it's a layer_states file | COMMENT |
| LOW | …ributed/strategy/log_probs/analyze_layer_divergence.py | 168 | # Check if this is a nested structure (layer states) or flat (embeddings) | COMMENT |
| LOW | …ributed/strategy/log_probs/analyze_layer_divergence.py | 518 | # Check if embeddings show significant divergence | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | roll/pipeline/agentic/agentic_pipeline.py | 270 | # Step 0: active_dp_ranks initialized with all ranks {0,1,2,3}, no expand needed | COMMENT |
| LOW⚡ | roll/pipeline/agentic/tools/mcp_tool.py | 339 | # Step 1: Find the schema for the requested tool. | STRING |
| LOW⚡ | roll/pipeline/agentic/tools/mcp_tool.py | 347 | # Step 2: Use the jsonschema library to validate the parameters. | STRING |
| LOW⚡ | roll/distributed/strategy/megatron_strategy.py | 633 | # Step 1: Correct sequence-major reshape: [1, S/cp_size*B, L, topk] → [S/cp_size, B, L, topk] | COMMENT |
| LOW⚡ | roll/distributed/strategy/megatron_strategy.py | 638 | # Step 2: Permute to batch-major: [B, S/cp_size, L, topk] | COMMENT |
| LOW⚡ | roll/distributed/strategy/megatron_strategy.py | 641 | # Step 3: CP gather to reconstruct full sequence: [B, S_actual, L, topk] | COMMENT |
| LOW⚡ | roll/distributed/strategy/megatron_strategy.py | 645 | # Step 4: pad back to seq_length so downstream (finalize cat, broadcast, | COMMENT |
| LOW⚡ | roll/utils/sequence_packing.py | 229 | # Step 4: VP interleaved schedule requires num_microbatches % microbatch_group_size_per_vp_stage == 0. | COMMENT |
| LOW⚡ | roll/utils/sequence_packing.py | 234 | # Step 5: Calculate workload for load balancing | COMMENT |
| LOW⚡ | roll/utils/sequence_packing.py | 240 | # Step 6: Partition samples into micro batches with balanced workload | COMMENT |
| LOW⚡ | roll/utils/sequence_packing.py | 247 | # Step 7: Sort and reorder for better pipeline scheduling | COMMENT |
| LOW | roll/utils/sequence_packing.py | 202 | # Step 2: Calculate initial number of micro batches | COMMENT |
| LOW | roll/utils/sequence_packing.py | 215 | # Step 3: Synchronize across DP ranks (all ranks must have same count) | COMMENT |
| LOW | roll/utils/sequence_packing.py | 272 | # Step 8: Generate micro batches | COMMENT |
| LOW | roll/configs/base_config.py | 837 | # Step 1: Merge reference + teacher into unified _reference_configs dict. | COMMENT |
| LOW | roll/configs/base_config.py | 876 | # Step 2: Pure OPD mode | COMMENT |
| LOW | roll/configs/base_config.py | 897 | # Step 3: Mixed OPD mode | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | mcore_adapter/src/mcore_adapter/trainer/trainer.py | 880 | # if loss is nan or inf simply add the average of previous logged losses | COMMENT |
| MEDIUM | roll/pipeline/agentic/tools/mcp_tool.py | 213 | """Generates a comprehensive prompt using the cached tool metadata.""" | STRING |
| MEDIUM | …ted/strategy/log_probs/test_fsdp_vlm_log_probs_perf.py | 272 | """Test VLM logprobs with CP2 and comprehensive performance statistics.""" | STRING |
| MEDIUM | tests/third_party/vllm/vllm_generate_test.py | 36 | # "content": "Your role as an assistant involves thoroughly exploring questions through a systematic long think | COMMENT |
| MEDIUM⚡ | …s/docusaurus-plugin-content-docs/current/ROLL_map.html | 24 | <script src="https://cdn.jsdelivr.net/npm/d3@7.9.0/dist/d3.min.js"></script><script src="https://cdn.jsdelivr.net/npm/ma | CODE |
| MEDIUM⚡ | …s/docusaurus-plugin-content-docs/current/ROLL_map.html | 24 | <script src="https://cdn.jsdelivr.net/npm/d3@7.9.0/dist/d3.min.js"></script><script src="https://cdn.jsdelivr.net/npm/ma | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tests/distributed/executor/test_ray_debugger.py | 20 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | roll/distributed/strategy/fsdp2_diffusion_strategy.py | 311 | # TODO: implement fsdp2 inference | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …/openreward_endless_terminals_reinforce_qwen35_2b.yaml | 5 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …docs/current/User Guides/Agentic/prefix_aggregation.md | 139 | [*base_chat_history, msg], # base_chat_history = [dummy_sys, dummy_user] | CODE |