The RL Bridge for LLM-based Agent Applications. Made Simple & Flexible.
This report presents the forensic synthetic code analysis of areal-project/AReaL, a Python project with 5,539 GitHub stars. SynthScan v2.0 examined 272,775 lines of code across 1109 source files, recording 5392 pattern matches distributed across 22 syntactic categories. The overall adjusted score of 30.6 places this repository in the Strong AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 5392 distinct pattern matches across 22 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. 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 diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | pyproject.toml | 219 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.toml | 221 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.toml | 283 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.toml | 285 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.toml | 306 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.toml | 308 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.vllm.toml | 230 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.vllm.toml | 232 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.vllm.toml | 314 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.vllm.toml | 316 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.vllm.toml | 337 | # ============================================================================= | COMMENT |
| MEDIUM | pyproject.vllm.toml | 339 | # ============================================================================= | COMMENT |
| MEDIUM | tests/test_per_layer_optim_step.py | 22 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_per_layer_optim_step.py | 24 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tests/test_per_layer_optim_step.py | 119 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tests/test_per_layer_optim_step.py | 121 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_per_layer_optim_step.py | 253 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_per_layer_optim_step.py | 255 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tests/test_seqpack.py | 461 | # ============================================================================= | COMMENT |
| MEDIUM⚡ | tests/test_seqpack.py | 463 | # ============================================================================= | COMMENT |
| MEDIUM⚡ | tests/test_seqpack.py | 979 | # ============================================================================= | COMMENT |
| MEDIUM⚡ | tests/test_seqpack.py | 981 | # ============================================================================= | COMMENT |
| MEDIUM | tests/test_seqpack.py | 27 | # ============================================================================= | COMMENT |
| MEDIUM | tests/test_seqpack.py | 29 | # ============================================================================= | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 30 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 32 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 81 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 83 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 219 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 221 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 242 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 244 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 301 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 303 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 354 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_slurm_scheduler.py | 356 | # ============================================================================ | COMMENT |
| MEDIUM | tests/test_slurm_scheduler.py | 154 | # ============================================================================ | COMMENT |
| MEDIUM | tests/test_slurm_scheduler.py | 156 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | tests/test_kk_allocate.py | 223 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tests/test_kk_allocate.py | 225 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tests/test_kk_allocate.py | 461 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tests/test_kk_allocate.py | 463 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tests/test_kk_allocate.py | 550 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tests/test_kk_allocate.py | 552 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 34 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 36 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 62 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 64 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 114 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 116 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 158 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 160 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 373 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 375 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 426 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_kk_allocate.py | 428 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/test_local_scheduler.py | 39 | # ============================================================================ | COMMENT |
| MEDIUM | tests/test_local_scheduler.py | 41 | # ============================================================================ | COMMENT |
| MEDIUM | tests/test_inference_engines.py | 149 | # ============================================================================ | COMMENT |
| MEDIUM | tests/test_inference_engines.py | 151 | # ============================================================================ | COMMENT |
| 892 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .opencode/skills/add-reward/SKILL.md | 122 | def test_reward_correct_answer(): | CODE |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 369 | def test_state_dict_roundtrip(): | CODE |
| LOW | .opencode/skills/add-unit-tests/SKILL.md | 52 | def test_function_under_condition_returns_expected(): | CODE |
| LOW⚡ | .opencode/skills/add-unit-tests/SKILL.md | 104 | def test_slow_but_required_in_ci(): | CODE |
| LOW⚡ | .opencode/skills/add-unit-tests/SKILL.md | 115 | def test_distributed_function(monkeypatch): | CODE |
| LOW | tests/test_train_controller.py | 157 | def create_mock_distributed_batch(size=4, seq_len=10): | CODE |
| LOW | tests/test_train_controller.py | 245 | def test_destroy_handles_errors(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 264 | def test_destroy_requests_reverse_order(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 284 | def test_merge_tensors_reorders_results(self): | CODE |
| LOW | tests/test_train_controller.py | 295 | def test_merge_tensors_with_tensor_results(self): | CODE |
| LOW | tests/test_train_controller.py | 422 | def test_custom_function_call_with_distributed_batch( | CODE |
| LOW | tests/test_train_controller.py | 446 | def test_custom_function_call_with_regular_args(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 467 | def test_custom_function_call_filters_dp_heads(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 482 | def test_create_process_group_is_dummy(self, train_controller, parallel_strategy): | CODE |
| LOW | tests/test_train_controller.py | 506 | def test_connect_engine_sets_rollout(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 520 | def test_connect_engine_warns_on_change(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 536 | def test_connect_engine_same_rollout_no_warning(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 551 | def test_check_rollout_engine_connected_raises_when_not_connected( | CODE |
| LOW | tests/test_train_controller.py | 563 | def test_check_rollout_engine_connected_passes_when_connected( | CODE |
| LOW | tests/test_train_controller.py | 579 | def test_prepare_batch_delegates_to_rollout(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 607 | def test_rollout_batch_delegates_to_rollout(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 638 | def test_update_weights_raises_when_not_connected(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 681 | def test_prepare_dispatch_splits_distributed_batch(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_train_controller.py | 695 | def test_prepare_dispatch_partitions_without_duplication( | CODE |
| LOW | tests/test_train_controller.py | 722 | def test_prepare_dispatch_replicates_non_batch_args( | CODE |
| LOW | tests/test_train_controller.py | 739 | def test_prepare_dispatch_handles_kwargs(self, train_controller, ft_spec): | CODE |
| LOW | tests/test_trackio_backend.py | 15 | def test_default_mode_is_disabled(self): | CODE |
| LOW | tests/test_trackio_backend.py | 20 | def test_default_optional_fields_are_none(self): | CODE |
| LOW⚡ | tests/test_trackio_backend.py | 40 | def test_invalid_mode_raises_error(self): | CODE |
| LOW⚡ | tests/test_trackio_backend.py | 47 | def test_all_valid_modes_accepted(self): | CODE |
| LOW⚡ | tests/test_trackio_backend.py | 57 | def test_trackio_field_exists(self): | CODE |
| LOW⚡ | tests/test_trackio_backend.py | 62 | def test_trackio_field_default_is_disabled(self): | CODE |
| LOW | tests/test_trackio_backend.py | 108 | def test_trackio_init_called_when_enabled( | CODE |
| LOW | tests/test_trackio_backend.py | 125 | def test_trackio_not_init_when_disabled( | CODE |
| LOW | tests/test_trackio_backend.py | 142 | def test_trackio_log_called_on_commit( | CODE |
| LOW | tests/test_trackio_backend.py | 162 | def test_trackio_finish_called_on_close( | CODE |
| LOW | tests/test_trackio_backend.py | 181 | def test_trackio_not_logged_when_disabled( | CODE |
| LOW | tests/test_network_ipv6_utils.py | 31 | def test_dual_stack_environment_executes_correct_branch(ip_stack): | CODE |
| LOW⚡ | tests/test_network_ipv6_utils.py | 79 | def test_format_host_for_url_idempotent(): | CODE |
| LOW⚡ | tests/test_network_ipv6_utils.py | 85 | def test_get_loopback_ip_returns_bindable_address(): | CODE |
| LOW⚡ | tests/test_network_ipv6_utils.py | 91 | def test_find_free_ports_ignores_out_of_range_excludes(): | CODE |
| LOW | tests/test_tree_training.py | 222 | def test_tree_training_forward(engine_type, tree_attn_backend): | CODE |
| LOW | tests/test_tree_training.py | 308 | def test_tree_training_forward_backward(engine_type, tree_attn_backend): | CODE |
| LOW | tests/test_train_engine.py | 41 | def gradient_checkpointing_enable(self, **kwargs): | CODE |
| LOW | tests/test_train_engine.py | 204 | def test_hf_save_load_weights(tmp_path_factory, engine, mock_input): | CODE |
| LOW | tests/test_train_engine.py | 229 | def test_dcp_save_load_weights(tmp_path_factory, engine, mock_input): | CODE |
| LOW | tests/test_train_engine.py | 261 | def test_train_engine_config_accepts_builtin_and_kernel_attn_impls(attn_impl): | CODE |
| LOW | tests/test_train_engine.py | 281 | def test_train_engine_config_rejects_invalid_kernel_attn_impl(attn_impl): | CODE |
| LOW | tests/test_train_engine.py | 296 | def test_create_llm_actor_or_critic_forwards_attn_impl( | CODE |
| LOW | tests/test_train_engine.py | 343 | def test_create_device_model_applies_use_kernels(monkeypatch, memory_efficient_load): | CODE |
| LOW | tests/test_train_engine.py | 392 | def test_fsdp_engine_config_construction(): | CODE |
| LOW | tests/test_train_engine.py | 423 | def test_fsdp_engine_alloc_mode_construction(): | CODE |
| LOW | tests/test_reward_norm_variable_group.py | 41 | def test_variable_group_sizes_normalize_each_group_independently(): | CODE |
| LOW | tests/test_reward_norm_variable_group.py | 67 | def test_group_sizes_none_matches_fixed_group_size(): | CODE |
| LOW | tests/test_reward_norm_variable_group.py | 78 | def test_variable_group_with_zero_variance_group_is_finite(): | CODE |
| LOW | tests/test_reward_norm_variable_group.py | 111 | def test_leave_one_out_singleton_group_outputs_zero(): | CODE |
| LOW | tests/test_reward_norm_variable_group.py | 130 | def test_group_sizes_sum_mismatch_raises(): | CODE |
| LOW | tests/test_reward_norm_variable_group.py | 138 | def test_group_sizes_non_positive_raises(): | CODE |
| LOW | tests/test_reward_norm_variable_group.py | 165 | def test_batched_call_pass_meta_provides_traj_group_sizes(): | CODE |
| LOW⚡ | tests/test_warmup_process_groups.py | 24 | def test_noop_when_dist_uninitialized(mock_all_reduce): | CODE |
| 2224 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/test_warmup_process_groups.py | 8 | CODE | |
| LOW | tests/test_perf_trace_converter.py | 1 | CODE | |
| LOW | tests/test_megatron_async_save.py | 16 | CODE | |
| LOW | tests/utils.py | 7 | CODE | |
| LOW | tests/utils.py | 7 | CODE | |
| LOW | tests/test_reassemble_cp_logprobs.py | 15 | CODE | |
| LOW | tests/test_examples.py | 688 | CODE | |
| LOW | tests/test_examples.py | 768 | CODE | |
| LOW | tests/experimental/archon/test_hf_parity_qwen2.py | 1 | CODE | |
| LOW | tests/experimental/archon/test_moe_common.py | 25 | CODE | |
| LOW | tests/experimental/archon/conftest.py | 107 | CODE | |
| LOW | tests/experimental/archon/conftest.py | 115 | CODE | |
| LOW | tests/experimental/archon/test_hf_parity_qwen3.py | 1 | CODE | |
| LOW | tests/experimental/archon/test_hf_parity_qwen3_moe.py | 1 | CODE | |
| LOW | tests/experimental/archon/test_hf_parity_qwen3_5_moe.py | 1 | CODE | |
| LOW | tests/experimental/archon/test_async_checkpoint.py | 11 | CODE | |
| LOW | tests/experimental/archon/utils.py | 22 | CODE | |
| LOW | tests/experimental/archon/utils.py | 22 | CODE | |
| LOW | tests/experimental/archon/utils.py | 22 | CODE | |
| LOW | tests/experimental/archon/test_qwen3_5.py | 14 | CODE | |
| LOW | tests/experimental/archon/test_moe_hf_parity.py | 23 | CODE | |
| LOW | tests/experimental/archon/test_hf_parity_qwen3_5.py | 1 | CODE | |
| LOW | …experimental/archon/torchrun/run_pp_gradient_verify.py | 12 | CODE | |
| LOW | tests/experimental/archon/torchrun/run_pp_tests.py | 21 | CODE | |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 24 | CODE | |
| LOW | tests/experimental/archon/fp8/test_fp8_scale_layout.py | 8 | CODE | |
| LOW | tests/experimental/archon/fp8/test_conversion.py | 11 | CODE | |
| LOW | tests/experimental/archon/fp8/test_moe_dispatch.py | 23 | CODE | |
| LOW | tests/experimental/archon/fp8/test_fp8_linear.py | 20 | CODE | |
| LOW | …sts/experimental/archon/fp8/torchrun/run_checkpoint.py | 2 | CODE | |
| LOW | …xperimental/archon/fp8/torchrun/run_sharded_dequant.py | 16 | CODE | |
| LOW | tests/experimental/openai/test_proxy_gateway.py | 3 | CODE | |
| LOW | tests/experimental/openai/test_proxy_integration.py | 1 | CODE | |
| LOW | tests/experimental/openai/test_proxy_rollout_server.py | 3 | CODE | |
| LOW | tests/experimental/openai/test_online_agent.py | 3 | CODE | |
| LOW | …experimental/openai/test_streaming_chat_completions.py | 10 | CODE | |
| LOW | tests/infra/test_launcher_utils.py | 1 | CODE | |
| LOW | tests/infra/sandbox/test_runner.py | 5 | CODE | |
| LOW | tests/infra/sandbox/test_client_manager.py | 3 | CODE | |
| LOW | tests/infra/data_service/test_epoch_crossing.py | 15 | CODE | |
| LOW | tests/infra/data_service/test_guard.py | 1 | CODE | |
| LOW | tests/infra/data_service/test_gateway.py | 1 | CODE | |
| LOW | tests/infra/data_service/test_auth.py | 1 | CODE | |
| LOW | tests/infra/data_service/test_router.py | 1 | CODE | |
| LOW | tests/infra/data_service/test_worker.py | 1 | CODE | |
| LOW | tests/infra/data_service/test_performance.py | 1 | CODE | |
| LOW | tests/infra/data_service/test_trainer_compat.py | 1 | CODE | |
| LOW | tests/infra/data_service/test_data_service_e2e.py | 1 | CODE | |
| LOW | tests/infra/data_service/test_controller.py | 1 | CODE | |
| LOW | tests/v2/weight_update/test_wu_controller.py | 2 | CODE | |
| LOW | tests/v2/weight_update/conftest.py | 10 | CODE | |
| LOW | tests/v2/weight_update/test_sglang_integration.py | 10 | CODE | |
| LOW | tests/v2/weight_update/test_kv_store.py | 2 | CODE | |
| LOW | tests/v2/weight_update/test_pair_registry.py | 2 | CODE | |
| LOW | tests/v2/weight_update/test_disk_integration.py | 2 | CODE | |
| LOW | tests/v2/training_service/fake_train_engine.py | 3 | CODE | |
| LOW | tests/v2/training_service/test_worker_unit.py | 3 | CODE | |
| LOW | tests/v2/training_service/test_controller_unit.py | 1 | CODE | |
| LOW | tests/v2/training_service/test_gateway_unit.py | 3 | CODE | |
| LOW | tests/v2/training_service/test_data_proxy_unit.py | 3 | CODE | |
| 627 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .opencode/skills/add-reward/SKILL.md | 61 | except Exception: | CODE |
| LOW | tests/test_rtensor.py | 57 | except Exception: | CODE |
| LOW | tests/test_slurm_scheduler.py | 60 | except Exception as e: | CODE |
| LOW | tests/test_local_scheduler.py | 2109 | except Exception: | CODE |
| LOW⚡ | tests/test_offload.py | 93 | except Exception as e: | CODE |
| LOW | tests/test_cuda_deterministic.py | 307 | except Exception as e: | CODE |
| LOW | tests/test_cuda_deterministic.py | 338 | except Exception: | CODE |
| LOW | tests/test_sglang_pp_distributed.py | 296 | except Exception: | CODE |
| LOW | tests/test_adv_norm_config.py | 1073 | except Exception as e: | CODE |
| LOW⚡ | tests/experimental/archon/conftest.py | 32 | except Exception: | CODE |
| LOW | tests/experimental/archon/conftest.py | 118 | except Exception: | CODE |
| LOW⚡ | tests/experimental/archon/conftest.py | 174 | except Exception: | CODE |
| LOW | tests/experimental/archon/test_weight_sync.py | 162 | except Exception: | CODE |
| LOW | tests/experimental/archon/test_weight_sync.py | 220 | except Exception: | CODE |
| LOW | tests/experimental/archon/test_weight_sync.py | 282 | except Exception: | CODE |
| LOW | tests/experimental/archon/test_weight_sync.py | 378 | except Exception: | CODE |
| LOW⚡ | tests/experimental/archon/test_grpo.py | 447 | except Exception as e: | CODE |
| LOW | …/experimental/archon/torchrun/run_qwen3_parallelize.py | 551 | except Exception as e: | CODE |
| LOW | …experimental/archon/torchrun/run_pp_gradient_verify.py | 578 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_archon_engine_pp.py | 167 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_archon_engine_pp.py | 197 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_archon_engine_pp.py | 231 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_archon_engine_pp.py | 286 | except Exception as e: | CODE |
| LOW | tests/experimental/archon/torchrun/run_parallel_dims.py | 222 | except Exception as e: | CODE |
| LOW | tests/experimental/archon/torchrun/run_parallel_dims.py | 396 | except Exception as e: | CODE |
| LOW | tests/experimental/archon/torchrun/run_ep_tests.py | 818 | except Exception as e: | CODE |
| LOW | tests/experimental/archon/torchrun/run_pp_tests.py | 901 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 149 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 294 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 461 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 585 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 778 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 1008 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 1197 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 1359 | except Exception as e: | CODE |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 1467 | except Exception as e: | CODE |
| LOW | …ts/experimental/archon/torchrun/run_pp_combinations.py | 558 | except Exception as e: | CODE |
| LOW | …ts/experimental/archon/torchrun/run_pp_combinations.py | 629 | except Exception as e: | CODE |
| LOW | …sts/experimental/archon/fp8/torchrun/run_checkpoint.py | 140 | except Exception as e: | CODE |
| LOW | …sts/experimental/archon/fp8/torchrun/run_checkpoint.py | 191 | except Exception as e: | CODE |
| LOW | …xperimental/archon/fp8/torchrun/run_sharded_dequant.py | 244 | except Exception as e: | CODE |
| LOW | tests/infra/data_service/test_data_service_e2e.py | 35 | except Exception as exc: | CODE |
| LOW⚡ | tests/torchrun/run_sglang_pp_weight_sync.py | 275 | except Exception as e: | CODE |
| LOW⚡ | tests/torchrun/run_sglang_pp_weight_sync.py | 443 | except Exception as e: | CODE |
| LOW | tests/torchrun/run_fsdp_memory_efficient_lora.py | 116 | except Exception as e: | CODE |
| LOW | tests/torchrun/run_lock.py | 72 | except Exception: | CODE |
| LOW | tests/v2/weight_update/test_kv_store.py | 99 | except Exception as exc: | CODE |
| LOW | …/v2/weight_update/torchrun/run_nccl_weight_transfer.py | 65 | except Exception as e: | CODE |
| LOW | …/v2/weight_update/torchrun/run_nccl_weight_transfer.py | 110 | except Exception as e: | CODE |
| LOW | …/v2/weight_update/torchrun/run_nccl_weight_transfer.py | 233 | except Exception as e: | CODE |
| LOW | …/v2/weight_update/torchrun/run_nccl_weight_transfer.py | 283 | except Exception as e: | CODE |
| LOW | …sts/v2/training_service/test_controller_integration.py | 173 | except Exception as exc: | CODE |
| LOW | tests/v2/inference_service/integration_utils.py | 62 | except Exception as e: | CODE |
| MEDIUM | tests/fp8/model_hooks.py | 306 | def hook(module, input, output): | CODE |
| MEDIUM | tests/fp8/model_hooks.py | 325 | def input_hook(module, input): | CODE |
| MEDIUM | tests/fp8/model_hooks.py | 344 | def backward_hook(module, grad_input, grad_output): | CODE |
| MEDIUM | tests/fp8/model_hooks.py | 510 | def backward_hook(module, grad_input, grad_output): | CODE |
| LOW | tests/fp8/model_hooks.py | 317 | except Exception as e: | CODE |
| LOW | tests/fp8/model_hooks.py | 336 | except Exception as e: | CODE |
| LOW | tests/fp8/model_hooks.py | 352 | except Exception as e: | CODE |
| 401 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .opencode/skills/add-reward/SKILL.md | 20 | ### Step 1: Create Reward File | COMMENT |
| LOW | .opencode/skills/add-reward/SKILL.md | 80 | ### Step 2: Register in __init__.py | COMMENT |
| LOW | .opencode/skills/add-reward/SKILL.md | 99 | ### Step 3: Handle Blocking Operations | COMMENT |
| LOW | .opencode/skills/add-reward/SKILL.md | 114 | ### Step 4: Add Tests | COMMENT |
| LOW | .opencode/skills/add-dataset/SKILL.md | 20 | ### Step 1: Create Dataset File | COMMENT |
| LOW | .opencode/skills/add-dataset/SKILL.md | 107 | ### Step 2: Register in __init__.py | COMMENT |
| LOW | .opencode/skills/add-dataset/SKILL.md | 129 | ### Step 3: Add Config (Optional) | COMMENT |
| LOW | .opencode/skills/add-dataset/SKILL.md | 140 | ### Step 4: Add Tests | COMMENT |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 29 | ### Step 1: Analyze the Target Model Architecture | COMMENT |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 66 | ### Step 2: Select the Reference Model | COMMENT |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 90 | ### Step 3: Implement `args.py` | COMMENT |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 131 | ### Step 4: Implement `model.py` | COMMENT |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 178 | ### Step 5: Implement `rope.py` | COMMENT |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 200 | ### Step 6: Implement `state_dict_adapter.py` | COMMENT |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 243 | ### Step 7: Implement `parallelize.py` | COMMENT |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 282 | ### Step 8: Create `spec.py` and Register | COMMENT |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 315 | ### Step 9: Register in `__init__.py` | COMMENT |
| LOW | .opencode/skills/add-archon-model/SKILL.md | 325 | ### Step 10: Verify and Test | COMMENT |
| LOW | .opencode/skills/add-workflow/SKILL.md | 28 | ### Step 1: Create Workflow File | COMMENT |
| LOW | .opencode/skills/add-workflow/SKILL.md | 105 | ### Step 2: Register in __init__.py | COMMENT |
| LOW | .opencode/skills/add-workflow/SKILL.md | 118 | ### Step 3: Update Entry Script | COMMENT |
| LOW | .opencode/skills/add-workflow/SKILL.md | 129 | ### Step 4: Add Tests | COMMENT |
| LOW | .opencode/skills/add-unit-tests/SKILL.md | 21 | ### Step 1: Understand Test Types | COMMENT |
| LOW | .opencode/skills/add-unit-tests/SKILL.md | 33 | ### Step 2: Create Test File Structure | COMMENT |
| LOW | .opencode/skills/add-unit-tests/SKILL.md | 47 | ### Step 3: Write Test Functions | COMMENT |
| LOW | .opencode/skills/add-unit-tests/SKILL.md | 65 | ### Step 4: Add Pytest Markers and CI Strategy | COMMENT |
| LOW⚡ | .opencode/skills/add-unit-tests/SKILL.md | 108 | ### Step 5: Mock Distributed Environment | COMMENT |
| LOW⚡ | .opencode/skills/add-unit-tests/SKILL.md | 122 | ### Step 6: Handle GPU Dependencies | COMMENT |
| LOW⚡ | tests/experimental/openai/test_proxy_gateway.py | 358 | # Step 2: populate queue again for the post-refresh session. | COMMENT |
| LOW⚡ | tests/experimental/openai/test_proxy_gateway.py | 368 | # Step 3: refresh — same api_key triggers auto-end + new session. | COMMENT |
| LOW | tests/experimental/openai/test_proxy_gateway.py | 339 | # Step 1: populate ready queue and start initial session. | COMMENT |
| LOW | tests/fp8/test_fp8_tensor.py | 409 | # Step 1: View to 4D | COMMENT |
| LOW | tests/fp8/test_fp8_tensor.py | 423 | # Step 2: Split into Q, K, V along dim=1 | COMMENT |
| LOW | tests/fp8/test_fp8_tensor.py | 451 | # Step 3: Reshape to 2D | COMMENT |
| LOW⚡ | tests/fp8/model_hooks.py | 123 | # Step 1: Prepare micro-batches | COMMENT |
| LOW⚡ | tests/fp8/model_hooks.py | 126 | # Step 2: Define loss functions | COMMENT |
| LOW⚡ | tests/fp8/model_hooks.py | 153 | # Step 3: Compute total loss weight | COMMENT |
| LOW⚡ | tests/fp8/model_hooks.py | 158 | # Step 4: Forward-backward using Megatron's pipeline function | COMMENT |
| LOW | tests/fp8/model_hooks.py | 193 | # Step 5: Collect gradients before optimizer.step() | COMMENT |
| LOW⚡ | .agents/skills/translate-doc-zh/SKILL.md | 16 | ### Step 1: Validate the source path | COMMENT |
| LOW⚡ | .agents/skills/translate-doc-zh/SKILL.md | 23 | ### Step 2: Resolve the target path | COMMENT |
| LOW⚡ | .agents/skills/translate-doc-zh/SKILL.md | 28 | ### Step 3: Choose translation mode | COMMENT |
| LOW | .agents/skills/upgrade-deps/SKILL.md | 172 | ### Step 0: Parse Input and Record Baseline | COMMENT |
| LOW | .agents/skills/upgrade-deps/SKILL.md | 239 | ### Step 1: Update Pyproject Files | COMMENT |
| LOW | .agents/skills/upgrade-deps/SKILL.md | 253 | ### Step 2: Lock Dependencies (Variant-Aware) | COMMENT |
| LOW | .agents/skills/upgrade-deps/SKILL.md | 280 | ### Step 3: Resolve Dependency Conflicts | COMMENT |
| LOW | .agents/skills/upgrade-deps/SKILL.md | 312 | ### Step 4: Update Dockerfile (If Required) | COMMENT |
| LOW | .agents/skills/upgrade-deps/SKILL.md | 354 | ### Step 5: Identify Updated Focused Packages | COMMENT |
| LOW | .agents/skills/upgrade-deps/SKILL.md | 383 | ### Step 6: API Compatibility Audit | COMMENT |
| LOW | .agents/skills/upgrade-deps/SKILL.md | 466 | ### Step 7: Run Pre-Commit | COMMENT |
| LOW | .agents/skills/upgrade-deps/SKILL.md | 472 | ### Step 8: Generate Upgrade Summary | COMMENT |
| LOW | .agents/skills/upgrade-deps/SKILL.md | 523 | ### Step 9: Create PR and Trigger CI (Optional) | COMMENT |
| LOW | .agents/skills/add-reward/SKILL.md | 20 | ### Step 1: Create Reward File | COMMENT |
| LOW | .agents/skills/add-reward/SKILL.md | 80 | ### Step 2: Register in __init__.py | COMMENT |
| LOW | .agents/skills/add-reward/SKILL.md | 99 | ### Step 3: Handle Blocking Operations | COMMENT |
| LOW | .agents/skills/add-reward/SKILL.md | 114 | ### Step 4: Add Tests | COMMENT |
| LOW | .agents/skills/add-dataset/SKILL.md | 20 | ### Step 1: Create Dataset File | COMMENT |
| LOW | .agents/skills/add-dataset/SKILL.md | 107 | ### Step 2: Register in __init__.py | COMMENT |
| LOW | .agents/skills/add-dataset/SKILL.md | 129 | ### Step 3: Add Config (Optional) | COMMENT |
| LOW | .agents/skills/add-dataset/SKILL.md | 140 | ### Step 4: Add Tests | COMMENT |
| 181 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | .opencode/skills/add-reward/SKILL.md | 0 | compute reward for a single completion. args: prompt: prompt string completions: completion string (model output) prompt | STRING |
| HIGH | .agents/skills/add-reward/SKILL.md | 0 | compute reward for a single completion. args: prompt: prompt string completions: completion string (model output) prompt | STRING |
| HIGH | .claude/skills/add-reward/SKILL.md | 0 | compute reward for a single completion. args: prompt: prompt string completions: completion string (model output) prompt | STRING |
| HIGH | .opencode/skills/add-reward/SKILL.md | 0 | extract the answer from a completion string. implement your extraction logic here. | STRING |
| HIGH | .agents/skills/add-reward/SKILL.md | 0 | extract the answer from a completion string. implement your extraction logic here. | STRING |
| HIGH | .claude/skills/add-reward/SKILL.md | 0 | extract the answer from a completion string. implement your extraction logic here. | STRING |
| HIGH | .opencode/skills/add-dataset/SKILL.md | 0 | load dataset for sft training. args: path: path to dataset (huggingface hub or local path) split: dataset split (train/v | STRING |
| HIGH | .agents/skills/add-dataset/SKILL.md | 0 | load dataset for sft training. args: path: path to dataset (huggingface hub or local path) split: dataset split (train/v | STRING |
| HIGH | .claude/skills/add-dataset/SKILL.md | 0 | load dataset for sft training. args: path: path to dataset (huggingface hub or local path) split: dataset split (train/v | STRING |
| HIGH | .opencode/skills/add-dataset/SKILL.md | 0 | load dataset for rl training. args: path: path to dataset split: dataset split tokenizer: tokenizer for length filtering | STRING |
| HIGH | .agents/skills/add-dataset/SKILL.md | 0 | load dataset for rl training. args: path: path to dataset split: dataset split tokenizer: tokenizer for length filtering | STRING |
| HIGH | .claude/skills/add-dataset/SKILL.md | 0 | load dataset for rl training. args: path: path to dataset split: dataset split tokenizer: tokenizer for length filtering | STRING |
| HIGH | .opencode/skills/add-workflow/SKILL.md | 0 | run a single episode. must be async and non-blocking. | STRING |
| HIGH | .agents/skills/add-workflow/SKILL.md | 0 | run a single episode. must be async and non-blocking. | STRING |
| HIGH | .claude/skills/add-workflow/SKILL.md | 0 | run a single episode. must be async and non-blocking. | STRING |
| HIGH | .opencode/skills/add-unit-tests/SKILL.md | 0 | test that function returns expected value under condition. | STRING |
| HIGH | .agents/skills/add-unit-tests/SKILL.md | 0 | test that function returns expected value under condition. | STRING |
| HIGH | .claude/skills/add-unit-tests/SKILL.md | 0 | test that function returns expected value under condition. | STRING |
| HIGH | tests/test_train_engine.py | 0 | create mock padded input data (same format for huggingface) for testing. returns a dict with input_ids, attention_mask, | STRING |
| HIGH | tests/test_megatron_engine.py | 0 | create mock padded input data (same format for huggingface) for testing. returns a dict with input_ids, attention_mask, | STRING |
| HIGH | tests/torchrun/run_megatron_engine_distributed.py | 0 | create mock padded input data (same format for huggingface) for testing. returns a dict with input_ids, attention_mask, | STRING |
| HIGH | tests/torchrun/run_fsdp_ulysses_forward.py | 0 | create mock padded input data (same format for huggingface) for testing. returns a dict with input_ids, attention_mask, | STRING |
| HIGH | tests/torchrun/run_fsdp_ulysses_train_batch.py | 0 | create mock padded input data (same format for huggingface) for testing. returns a dict with input_ids, attention_mask, | STRING |
| HIGH | …sts/v2/inference_service/test_data_proxy_standalone.py | 0 | mock arealopenai client that returns a valid chatcompletion. | STRING |
| HIGH | tests/v2/inference_service/test_data_proxy_version.py | 0 | mock arealopenai client that returns a valid chatcompletion. | STRING |
| HIGH | tests/v2/inference_service/test_data_proxy_pause.py | 0 | mock arealopenai client that returns a valid chatcompletion. | STRING |
| HIGH | areal/experimental/engine/archon_engine.py | 0 | drain this worker's client-side rtensor fetch buffer. called via rpc by ``traincontroller.clear_batches`` at step end so | STRING |
| HIGH | areal/engine/fsdp_engine.py | 0 | drain this worker's client-side rtensor fetch buffer. called via rpc by ``traincontroller.clear_batches`` at step end so | STRING |
| HIGH | areal/engine/megatron_engine.py | 0 | drain this worker's client-side rtensor fetch buffer. called via rpc by ``traincontroller.clear_batches`` at step end so | STRING |
| HIGH | areal/engine/sglang_remote.py | 0 | drain this worker's client-side rtensor fetch buffer. called via rpc by ``traincontroller.clear_batches`` at step end so | STRING |
| HIGH | areal/engine/vllm_remote.py | 0 | drain this worker's client-side rtensor fetch buffer. called via rpc by ``traincontroller.clear_batches`` at step end so | STRING |
| HIGH | areal/experimental/engine/archon_engine.py | 0 | expose local fetch-buffer stats for post-step drain verification. | STRING |
| HIGH | areal/engine/fsdp_engine.py | 0 | expose local fetch-buffer stats for post-step drain verification. | STRING |
| HIGH | areal/engine/megatron_engine.py | 0 | expose local fetch-buffer stats for post-step drain verification. | STRING |
| HIGH | areal/engine/sglang_remote.py | 0 | expose local fetch-buffer stats for post-step drain verification. | STRING |
| HIGH | areal/engine/vllm_remote.py | 0 | expose local fetch-buffer stats for post-step drain verification. | STRING |
| HIGH | areal/experimental/engine/archon_engine.py | 0 | temporarily onload parameters for offload-unsafe operations. reentrant: nested calls increment depth; only the outermost | STRING |
| HIGH | areal/engine/fsdp_engine.py | 0 | temporarily onload parameters for offload-unsafe operations. reentrant: nested calls increment depth; only the outermost | STRING |
| HIGH | areal/engine/megatron_engine.py | 0 | temporarily onload parameters for offload-unsafe operations. reentrant: nested calls increment depth; only the outermost | STRING |
| HIGH | areal/experimental/openai/client.py | 0 | set reward for a specific completion/response by its id. | STRING |
| HIGH | areal/experimental/openai/cache.py | 0 | set reward for a specific completion/response by its id. | STRING |
| HIGH | areal/experimental/openai/proxy/client_session.py | 0 | set reward for a specific completion/response by its id. | STRING |
| HIGH | areal/experimental/openai/client.py | 0 | set reward for the most recent completion/response. | STRING |
| HIGH | areal/experimental/openai/cache.py | 0 | set reward for the most recent completion/response. | STRING |
| HIGH | areal/experimental/openai/proxy/client_session.py | 0 | set reward for the most recent completion/response. | STRING |
| HIGH | areal/infra/scheduler/slurm.py | 0 | fork new worker processes from existing workers. creates new worker processes by forking from existing workers of the ta | STRING |
| HIGH | areal/infra/scheduler/local.py | 0 | fork new worker processes from existing workers. creates new worker processes by forking from existing workers of the ta | STRING |
| HIGH | areal/api/scheduler_api.py | 0 | fork new worker processes from existing workers. creates new worker processes by forking from existing workers of the ta | STRING |
| HIGH | areal/infra/controller/train_controller.py | 0 | validate that rollout engine has been connected via connect_engine(). | STRING |
| HIGH | areal/engine/fsdp_engine.py | 0 | validate that rollout engine has been connected via connect_engine(). | STRING |
| HIGH | areal/engine/megatron_engine.py | 0 | validate that rollout engine has been connected via connect_engine(). | STRING |
| HIGH | areal/infra/data_service/controller/controller.py | 0 | ensure _workers_ready is signaled even if _bg_initialize fails. | STRING |
| HIGH | areal/v2/training_service/controller/controller.py | 0 | ensure _workers_ready is signaled even if _bg_initialize fails. | STRING |
| HIGH | areal/v2/inference_service/controller/controller.py | 0 | ensure _workers_ready is signaled even if _bg_initialize fails. | STRING |
| HIGH | areal/v2/training_service/gateway/auth.py | 0 | extract api token from authorization header. raises httpexception(401) if missing or malformed. | STRING |
| HIGH | areal/v2/inference_service/data_proxy/app.py | 0 | extract api token from authorization header. raises httpexception(401) if missing or malformed. | STRING |
| HIGH | areal/v2/inference_service/gateway/auth.py | 0 | extract api token from authorization header. raises httpexception(401) if missing or malformed. | STRING |
| HIGH | areal/workflow/langchain/math_agent.py | 0 | run the agent on a math problem. args: data: input data containing "messages" and "answer" **extra_kwargs: contains base | STRING |
| HIGH | areal/workflow/anthropic/math_agent.py | 0 | run the agent on a math problem. args: data: input data containing "messages" and "answer" **extra_kwargs: contains base | STRING |
| HIGH | areal/workflow/anthropic/claude_math_agent.py | 0 | run the agent on a math problem. args: data: input data containing "messages" and "answer" **extra_kwargs: contains base | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/test_train_controller.py | 76 | CODE | |
| LOW | tests/test_tree_training.py | 108 | CODE | |
| LOW | tests/test_tree_training.py | 134 | CODE | |
| LOW | tests/test_allocation_mode.py | 203 | CODE | |
| LOW | tests/test_rollout_controller.py | 76 | CODE | |
| LOW | tests/test_rollout_controller.py | 489 | CODE | |
| LOW | tests/test_local_scheduler.py | 2031 | CODE | |
| LOW | tests/test_local_scheduler.py | 2243 | CODE | |
| LOW | tests/test_local_scheduler.py | 2364 | CODE | |
| LOW | tests/test_local_scheduler.py | 2491 | CODE | |
| LOW | tests/test_packed_vs_padded_consistency.py | 132 | CODE | |
| LOW | tests/test_packed_vs_padded_consistency.py | 230 | CODE | |
| LOW | tests/test_sglang_pp_distributed.py | 77 | CODE | |
| LOW | tests/test_examples.py | 26 | CODE | |
| LOW | tests/test_examples.py | 886 | CODE | |
| LOW | tests/test_examples.py | 903 | CODE | |
| LOW | tests/experimental/archon/test_weight_sync.py | 263 | CODE | |
| LOW | tests/experimental/archon/test_weight_sync.py | 440 | CODE | |
| LOW | tests/experimental/archon/test_forward.py | 300 | CODE | |
| LOW | …experimental/archon/torchrun/run_pp_gradient_verify.py | 308 | CODE | |
| LOW | tests/experimental/archon/torchrun/run_pp_tests.py | 251 | CODE | |
| LOW | tests/experimental/archon/torchrun/run_pp_tests.py | 277 | CODE | |
| LOW | tests/experimental/archon/torchrun/run_pp_tests.py | 321 | CODE | |
| LOW | tests/experimental/archon/torchrun/run_pp_tests.py | 569 | CODE | |
| LOW | tests/experimental/archon/torchrun/run_tp_forward.py | 110 | CODE | |
| LOW | tests/experimental/archon/torchrun/dist_utils.py | 155 | CODE | |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 620 | CODE | |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 810 | CODE | |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 1040 | CODE | |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 1233 | CODE | |
| LOW | …s/experimental/archon/torchrun/run_checkpoint_tests.py | 1405 | CODE | |
| LOW | …ts/experimental/archon/torchrun/run_pp_combinations.py | 465 | CODE | |
| LOW | tests/torchrun/run_fsdp_optimizer_dtype.py | 71 | CODE | |
| LOW | tests/torchrun/run_sglang_pp_weight_sync.py | 287 | CODE | |
| LOW | tests/torchrun/run_perf_tracer.py | 12 | CODE | |
| LOW | tests/torchrun/run_megatron_engine_distributed.py | 643 | CODE | |
| LOW | tests/torchrun/run_megatron_engine_vlm_distributed.py | 307 | CODE | |
| LOW | …/v2/weight_update/torchrun/run_nccl_weight_transfer.py | 123 | CODE | |
| LOW | tests/fp8/test_fp8_rmsnorm.py | 174 | CODE | |
| LOW | tests/fp8/test_fp8_rmsnorm.py | 281 | CODE | |
| LOW | tests/fp8/model_hooks.py | 101 | CODE | |
| LOW | tests/fp8/model_hooks.py | 214 | CODE | |
| LOW | tests/fp8/model_hooks.py | 264 | CODE | |
| LOW | tests/fp8/engine_utils.py | 35 | CODE | |
| LOW | docs/generate_cli_docs.py | 38 | CODE | |
| LOW | docs/generate_cli_docs.py | 143 | CODE | |
| LOW | docs/generate_cli_docs.py | 186 | CODE | |
| LOW | examples/tir/tools/python_tool.py | 120 | CODE | |
| LOW | …mples/experimental/inference_service/online_rollout.py | 12 | CODE | |
| LOW | …perimental/inference_service/human_in_the_loop_demo.py | 201 | CODE | |
| LOW | examples/experimental/inference_service/tau2_rollout.py | 156 | CODE | |
| LOW | examples/agent_service/run_agent_service.py | 42 | CODE | |
| LOW | examples/agent_service/agent.py | 101 | CODE | |
| LOW | examples/tau2/agent.py | 95 | CODE | |
| LOW | examples/scaffolding/search_agent_controller.py | 126 | CODE | |
| LOW | examples/scaffolding/core/task_collection.py | 222 | CODE | |
| LOW | examples/scaffolding/core/task_collection.py | 353 | CODE | |
| LOW | examples/scaffolding/tests/test_controllers.py | 152 | CODE | |
| LOW | examples/scaffolding/tests/test_self_contained.py | 35 | CODE | |
| LOW | examples/terminal_bench/agent/chat_agent_trace.py | 190 | CODE | |
| 176 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | tests/experimental/openai/test_proxy_gateway.py | 358 | # Step 2: populate queue again for the post-refresh session. | COMMENT |
| LOW⚡ | tests/experimental/openai/test_proxy_gateway.py | 368 | # Step 3: refresh — same api_key triggers auto-end + new session. | COMMENT |
| LOW | tests/experimental/openai/test_proxy_gateway.py | 339 | # Step 1: populate ready queue and start initial session. | COMMENT |
| LOW | tests/fp8/test_fp8_tensor.py | 409 | # Step 1: View to 4D | COMMENT |
| LOW | tests/fp8/test_fp8_tensor.py | 423 | # Step 2: Split into Q, K, V along dim=1 | COMMENT |
| LOW | tests/fp8/test_fp8_tensor.py | 451 | # Step 3: Reshape to 2D | COMMENT |
| LOW⚡ | tests/fp8/model_hooks.py | 123 | # Step 1: Prepare micro-batches | COMMENT |
| LOW⚡ | tests/fp8/model_hooks.py | 126 | # Step 2: Define loss functions | COMMENT |
| LOW⚡ | tests/fp8/model_hooks.py | 153 | # Step 3: Compute total loss weight | COMMENT |
| LOW⚡ | tests/fp8/model_hooks.py | 158 | # Step 4: Forward-backward using Megatron's pipeline function | COMMENT |
| LOW | tests/fp8/model_hooks.py | 193 | # Step 5: Collect gradients before optimizer.step() | COMMENT |
| LOW⚡ | examples/countdown/countdown.py | 452 | # Step 1: 1+2=3 | COMMENT |
| LOW⚡ | examples/countdown/countdown.py | 453 | # Step 2: 3*3=9 | COMMENT |
| LOW⚡ | examples/countdown/countdown.py | 454 | # Step 3: 9*3=27 | COMMENT |
| LOW⚡ | examples/countdown/countdown.py | 455 | # Step 4: 27+3=30 | COMMENT |
| LOW⚡ | examples/countdown/countdown.py | 459 | # Step 1: 24/2 = 12 | COMMENT |
| LOW⚡ | examples/countdown/countdown.py | 460 | # Step 2: 12 + 2 = 14 | COMMENT |
| LOW⚡ | examples/scaffolding/controllers.py | 500 | # Step 1: Run generation (yields task lists for worker execution) | COMMENT |
| LOW⚡ | examples/scaffolding/controllers.py | 503 | # Step 2: Create reward tasks and compute rewards locally | COMMENT |
| LOW⚡ | …eal/experimental/models/archon/moe_weight_converter.py | 249 | # Step 1: Store metadata for from_hf reconstruction | COMMENT |
| LOW⚡ | …eal/experimental/models/archon/moe_weight_converter.py | 255 | # Step 2: Calculate local expert indices from placements | COMMENT |
| LOW⚡ | …eal/experimental/models/archon/moe_weight_converter.py | 267 | # Step 3: Store indices for from_hf reconstruction | COMMENT |
| LOW⚡ | …eal/experimental/models/archon/moe_weight_converter.py | 270 | # Step 4: Create new placements for individual expert weights (2D) | COMMENT |
| LOW | …eal/experimental/models/archon/moe_weight_converter.py | 290 | # Step 5: Extract local tensor and split into individual experts | COMMENT |
| LOW | areal/experimental/models/archon/expert_parallel.py | 129 | # Step 1: Exchange token counts via all-to-all | COMMENT |
| LOW⚡ | areal/experimental/models/archon/expert_parallel.py | 162 | # Step 2: All-to-all to dispatch tokens | COMMENT |
| LOW⚡ | areal/experimental/models/archon/expert_parallel.py | 170 | # Step 3: Permute for grouped_mm alignment | COMMENT |
| LOW⚡ | areal/experimental/models/archon/expert_parallel.py | 203 | # Step 1: Unpermute to pre-permutation order | COMMENT |
| LOW⚡ | areal/experimental/models/archon/expert_parallel.py | 206 | # Step 2: All-to-all to combine (reverse direction) | COMMENT |
| LOW | areal/utils/save_load.py | 24 | # Step 1: Identify if the input is a Hugging Face repo ID or local path | COMMENT |
| LOW⚡ | areal/utils/save_load.py | 39 | # Step 2: Download the repo if it's a Hugging Face repo ID | COMMENT |
| LOW⚡ | areal/utils/save_load.py | 47 | # Step 3: Load all .safetensors and .bin files | COMMENT |
| LOW | areal/utils/data.py | 1452 | # Step 1: Compute mean | COMMENT |
| LOW | areal/utils/data.py | 1496 | # Step 2: Compute std | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 134 | # Step 1: Numerical stability - subtract max | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 141 | # Step 2: Compute exp in-place and sum across all ranks | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 146 | # Step 3: Get the logit value at labels position | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 160 | # Step 4: Compute log probability | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 164 | # Step 5: Compute softmax in-place for backward (reuse exp_logits memory) | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 264 | # Step 1: Numerical stability - subtract max (shared) | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 271 | # Step 2: Compute exp and sum_exp (shared) | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 277 | # Step 3: Compute softmax in-place (shared) | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 281 | # Step 4: For logprobs - get labels logit | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 295 | # Step 5: For entropy - compute sum(softmax * logits) | COMMENT |
| LOW⚡ | areal/utils/functional/vocab_parallel.py | 302 | # Step 6: Compute final results | COMMENT |
| LOW | areal/utils/functional/vocab_parallel.py | 344 | # Step 1: Compute entropy gradient contribution | COMMENT |
| LOW | areal/utils/functional/vocab_parallel.py | 360 | # Step 2: Add logprobs gradient contribution | COMMENT |
| LOW | areal/utils/functional/functional.py | 212 | # Step 0: Validate input shapes. | COMMENT |
| LOW⚡ | areal/utils/functional/functional.py | 229 | # Step 1: Compute log ratio = log(π_proximal / π_behave) | COMMENT |
| LOW⚡ | areal/utils/functional/functional.py | 235 | # Step 2: Compute metric value (reuse existing KLEstimator sign conventions) | COMMENT |
| LOW⚡ | areal/utils/functional/functional.py | 262 | # Step 3: Compute behave_imp_weight (needed for both modes) | COMMENT |
| LOW⚡ | areal/utils/functional/functional.py | 267 | # Step 4: Aggregate and filter | COMMENT |
| LOW | areal/utils/functional/functional.py | 413 | # Step 5: Update loss_mask or keep it based on action mode | COMMENT |
| LOW | areal/models/transformers/vision_sp_shard.py | 291 | # Step 1: Get image assignment based on patch counts | COMMENT |
| LOW⚡ | areal/models/transformers/vision_sp_shard.py | 310 | # Step 2: Extract local inputs (use CPU grid_thw to avoid GPU→CPU syncs | COMMENT |
| LOW⚡ | areal/models/transformers/vision_sp_shard.py | 317 | # Step 3: Process local images | COMMENT |
| LOW⚡ | areal/models/transformers/vision_sp_shard.py | 342 | # Step 4: Unpack deepstack if present (Qwen3-VL returns (embeddings, list[Tensor])) | COMMENT |
| LOW⚡ | areal/models/transformers/vision_sp_shard.py | 347 | # Step 5: All-gather (contiguous assignment, no reordering needed) | COMMENT |
| LOW | areal/models/transformers/vision_sp_shard.py | 363 | # Step 6: All-gather deepstack embeddings (all ranks must participate) | COMMENT |
| LOW⚡ | areal/v2/training_service/controller/controller.py | 169 | # Step 0: Create world_size guards via scheduler (one per GPU rank) | COMMENT |
| 39 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/test_staleness_manager.py | 24 | def set_version(self, version: int) -> None: | CODE |
| LOW | tests/utils.py | 12 | __all__ = ["get_dataset_path", "get_model_path"] | CODE |
| LOW | tests/experimental/archon/utils.py | 34 | __all__ = [ | CODE |
| LOW | tests/infra/data_service/test_trainer_compat.py | 16 | def set_epoch(self, epoch: int) -> None: | CODE |
| LOW⚡ | tests/torchrun/run_sglang_pp_weight_sync.py | 45 | logger = logging.getLogger(__name__) | CODE |
| LOW⚡ | tests/v2/inference_service/test_data_proxy_pause.py | 142 | async def _set_paused(pause_state: PauseState, value: bool) -> None: | CODE |
| LOW | examples/tir/tools/__init__.py | 18 | __all__ = [ | CODE |
| LOW | …perimental/inference_service/human_in_the_loop_demo.py | 105 | def _set_reward(gateway_addr: str, api_key: str, reward: float) -> None: | CODE |
| LOW | examples/scaffolding/__init__.py | 35 | __all__ = [ | CODE |
| LOW | examples/scaffolding/_compat.py | 36 | __all__ = [ | CODE |
| LOW | examples/scaffolding/core/controller.py | 16 | logger = logging.getLogger(__name__) | CODE |
| LOW | examples/scaffolding/core/__init__.py | 36 | __all__ = [ | CODE |
| LOW | examples/terminal_bench/agent/__init__.py | 5 | __all__ = [ | CODE |
| LOW | examples/terminal_bench/workflow/__init__.py | 4 | __all__ = ["CamelRLVRWorkflow", "build_docker_image"] | CODE |
| LOW | areal/__init__.py | 32 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/model_spec.py | 131 | __all__ = [ | CODE |
| LOW | …eal/experimental/models/archon/moe_weight_converter.py | 446 | __all__ = ["MoEConversionState", "MoEWeightConverter"] | CODE |
| LOW | areal/experimental/models/archon/ulysses.py | 18 | __all__ = [ | CODE |
| LOW | …al/experimental/models/archon/activation_checkpoint.py | 310 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/__init__.py | 34 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/utils.py | 161 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/parallel_dims.py | 21 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/expert_parallel.py | 508 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/pipeline_parallel.py | 40 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/base.py | 168 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/attention/__init__.py | 7 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/attention/varlen.py | 13 | __all__ = ["varlen_attn", "VarlenAttentionWrapper"] | CODE |
| LOW | areal/experimental/models/archon/attention/varlen.py | 162 | def _setup_context(ctx: Any, inputs: tuple[Any, ...], output: Any) -> None: | CODE |
| LOW | areal/experimental/models/archon/attention/sdpa.py | 15 | __all__ = ["SDPAWrapper", "create_block_causal_mask_2d"] | CODE |
| LOW | areal/experimental/models/archon/qwen2/__init__.py | 12 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen2/spec.py | 25 | __all__ = ["QWEN2_SPEC"] | CODE |
| LOW | …/experimental/models/archon/qwen2/infra/parallelize.py | 361 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen2/model/model.py | 379 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen2/model/rope.py | 155 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen2/model/args.py | 70 | __all__ = ["Qwen2ModelArgs"] | CODE |
| LOW | areal/experimental/models/archon/qwen3/__init__.py | 12 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen3/spec.py | 25 | __all__ = ["QWEN3_SPEC"] | CODE |
| LOW | …/experimental/models/archon/qwen3/infra/parallelize.py | 436 | def _setup_fsdp_prefetch(model: nn.Module) -> None: | CODE |
| LOW | …/experimental/models/archon/qwen3/infra/parallelize.py | 751 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen3/model/model.py | 493 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen3/model/rope.py | 12 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen3/model/args.py | 111 | __all__ = ["Qwen3ModelArgs"] | CODE |
| LOW | areal/experimental/models/archon/qwen3_5/__init__.py | 12 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen3_5/spec.py | 29 | __all__ = ["QWEN3_5_SPEC"] | CODE |
| LOW | …xperimental/models/archon/qwen3_5/infra/parallelize.py | 298 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen3_5/model/model.py | 671 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen3_5/model/rope.py | 149 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/qwen3_5/model/args.py | 182 | __all__ = ["Qwen3_5ModelArgs"] | CODE |
| LOW | areal/experimental/models/archon/moe/token_reorderer.py | 73 | __all__ = ["TokenReorderer"] | CODE |
| LOW | areal/experimental/models/archon/moe/__init__.py | 17 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/moe/grouped_experts.py | 288 | __all__ = ["GroupedExperts"] | CODE |
| LOW | areal/experimental/models/archon/moe/utils.py | 290 | __all__ = [ | CODE |
| LOW | areal/experimental/models/archon/moe/kernels.py | 9 | __all__ = ["generate_permute_indices", "fill_indices_wrapper"] | CODE |
| LOW | areal/experimental/models/archon/moe/args.py | 109 | __all__ = ["MoEArgs"] | CODE |
| LOW | areal/experimental/models/archon/moe/router.py | 308 | __all__ = ["TokenChoiceTopKRouter"] | CODE |
| LOW | areal/experimental/models/archon/moe/moe.py | 261 | __all__ = ["MoE", "FeedForward"] | CODE |
| LOW | areal/experimental/engine/archon_weight_sync.py | 31 | logger = logging.getLogger(__name__) | CODE |
| LOW | areal/experimental/openai/client.py | 1371 | def set_reward(self, id: str, reward: float) -> None: | CODE |
| LOW | areal/experimental/openai/client.py | 1377 | def set_last_reward(self, reward: float) -> None: | CODE |
| LOW | areal/experimental/openai/cache.py | 85 | def set_reward(self, interaction_id: str, reward: float) -> None: | CODE |
| 92 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/test_tree_training.py | 258 | # Check if results match with detailed error reporting | COMMENT |
| LOW | tests/test_tree_training.py | 456 | # Check if gradients are close: | COMMENT |
| LOW⚡ | tests/test_slurm_scheduler.py | 23 | # Check if 'srun' exists in the system PATH | COMMENT |
| LOW | tests/test_fsdp_grad.py | 17 | # Check if CUDA is available | COMMENT |
| LOW | tests/test_local_scheduler.py | 2093 | # Check if process died | COMMENT |
| LOW | tests/test_examples.py | 90 | # Check if process has terminated | COMMENT |
| LOW | tests/experimental/archon/test_checkpoint_e2e.py | 391 | # Check if weight tying is enabled | COMMENT |
| LOW | tests/experimental/archon/test_qwen3_5.py | 891 | # Set wq to output zeros for the gate half. | COMMENT |
| LOW | tests/experimental/openai/test_client_with_tool.py | 281 | # Check if tool call was made (might depend on model capability) | COMMENT |
| LOW | tests/experimental/openai/test_client.py | 367 | # Set rewards to leaf nodes only, which should be c_a1, c_a2, c_b1 | COMMENT |
| LOW | tests/experimental/openai/test_client.py | 571 | # Set rewards to leaf nodes only, which should be c_a1 | COMMENT |
| LOW | tests/fp8/test_fp8_rmsnorm.py | 296 | # Check if it's a combined file or individual file | COMMENT |
| LOW | tests/fp8/engine_utils.py | 69 | # Check if this is a CUDA kernel event | COMMENT |
| LOW | tests/fp8/engine_utils.py | 81 | # Check if this is a gemm-related kernel | COMMENT |
| LOW | tests/fp8/engine_utils.py | 128 | # Check if this is a gemm-related operation (may be at higher level) | COMMENT |
| LOW | tests/fp8/engine_utils.py | 130 | # Check if we already have this in gemm_events | COMMENT |
| LOW | tests/fp8/test_fp8_conversion.py | 81 | # Check if tensor can be quantized (needs to satisfy block size requirements) | COMMENT |
| LOW | .claude/hooks/check-expert-update.sh | 5 | # Check if jq is available | COMMENT |
| LOW | docs/generate_cli_docs.py | 147 | # Check if it's a Union type (includes both Union[Type, None] and Type | None syntax) | COMMENT |
| LOW | docs/generate_cli_docs.py | 150 | # Check if it's a union with None (optional type) | COMMENT |
| LOW | examples/tir/tir_workflow.py | 203 | # Check if tool start marker is detected | COMMENT |
| LOW⚡ | examples/countdown/reward_score.py | 31 | # Check if all numbers in equation are available | COMMENT |
| LOW | examples/terminal_bench/agent/chat_agent_trace.py | 94 | # Check if we've reached max parse errors | STRING |
| LOW | examples/terminal_bench/agent/chat_agent_trace.py | 217 | # Check if this call is from a RegisteredAgentToolkit to prevent tool | COMMENT |
| LOW | examples/terminal_bench/agent/chat_agent_trace.py | 348 | # Check if we've reached max parse errors | COMMENT |
| LOW | .github/workflows/build-docker-image.yml | 279 | # Check if instance is running | COMMENT |
| LOW | .github/workflows/tag-release-image.yml | 217 | # Check if instance is running | COMMENT |
| LOW | areal/experimental/models/archon/qwen3/model/args.py | 62 | # Check if MoE is enabled | COMMENT |
| LOW | …mental/models/archon/qwen3/model/state_dict_adapter.py | 465 | # Check if all experts collected | COMMENT |
| LOW | areal/experimental/models/archon/qwen3_5/model/args.py | 118 | # Check if MoE is enabled | COMMENT |
| LOW | areal/experimental/openai/cache.py | 126 | # Assign rewards to interactions in cache based on their creation order | COMMENT |
| LOW | areal/infra/async_task_runner.py | 522 | # Check if thread is still alive | COMMENT |
| LOW | areal/infra/remote_inf_engine.py | 106 | # Check if results are InteractionWithTokenLogpReward dicts | COMMENT |
| LOW | areal/infra/remote_inf_engine.py | 653 | # Check if it's a RolloutWorkflow class | COMMENT |
| LOW | areal/infra/remote_inf_engine.py | 664 | # Check if it's a RolloutWorkflow instance | COMMENT |
| LOW | areal/infra/workflow_executor.py | 164 | # Check if all values are InteractionWithTokenLogpReward | COMMENT |
| LOW | areal/infra/scheduler/slurm.py | 1361 | # Check if still running, force kill if needed | COMMENT |
| LOW | areal/infra/scheduler/slurm.py | 1620 | # Check if retryable | COMMENT |
| LOW | areal/infra/scheduler/slurm.py | 1006 | # Check if fork mode is enabled | STRING |
| LOW | areal/infra/scheduler/local.py | 701 | # Check if fork mode is enabled | COMMENT |
| LOW | areal/infra/scheduler/local.py | 1680 | # Check if worker died (forked workers have process=None) | COMMENT |
| LOW | areal/infra/scheduler/local.py | 1730 | # Check if process has exited (forked workers have process=None) | COMMENT |
| LOW | areal/infra/scheduler/local.py | 1768 | # Check if worker died (forked workers have process=None) | COMMENT |
| LOW | areal/infra/scheduler/ray.py | 479 | # Check if fork mode is enabled | COMMENT |
| LOW | areal/infra/scheduler/ray.py | 526 | # Check if this is a colocated role | COMMENT |
| LOW | areal/infra/scheduler/ray.py | 572 | # Check if this is a forked role (has its own workers) | COMMENT |
| LOW | areal/infra/utils/concurrent.py | 71 | # Check if we're already in an async context | COMMENT |
| LOW | areal/infra/utils/proc.py | 65 | # Check if stdbuf is available (not present on macOS by default) | COMMENT |
| LOW | areal/tools/profile_fsdp.py | 383 | # Print results - sorted by CUDA time | COMMENT |
| LOW | areal/tools/profile_archon.py | 341 | # Print results - sorted by CUDA time | COMMENT |
| LOW | areal/utils/fs.py | 80 | # Check if path is on network filesystem | COMMENT |
| LOW | areal/utils/name_resolve.py | 515 | # Check if key exists when replace=False | COMMENT |
| LOW | areal/utils/name_resolve.py | 762 | # Check if this is a delete event | COMMENT |
| LOW | areal/utils/name_resolve.py | 819 | # Check if key matches prefix (exact match or starts with prefix/) | COMMENT |
| LOW | areal/utils/name_resolve.py | 968 | # Check if key exists when replace=False | COMMENT |
| LOW | areal/utils/name_resolve.py | 1022 | # Check if key exists | COMMENT |
| LOW | areal/models/mcore/hf_load.py | 489 | # Check if any HF weight is FP8 (has _scale_inv suffix) | COMMENT |
| LOW | areal/models/transformers/qwen3_vl.py | 109 | # Check if hidden_states is a DTensor (TP is enabled) | COMMENT |
| LOW | areal/api/cli_args.py | 311 | # Check if equal to the default value | COMMENT |
| LOW | areal/api/alloc_mode.py | 789 | # Check if name is provided | COMMENT |
| 6 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | areal/experimental/models/archon/fp8_checkpoint.py | 234 | Dequantize all FP8 weights in *hf_state_dict* to *target_dtype*. Detects FP8 weights by their ``float8_e4m3fn`` dty | STRING |
| HIGH | …eal/experimental/models/archon/moe_weight_converter.py | 71 | Calculate start/end indices for [StridedShard(dim=i), Shard(dim=i)] placement. GPU Layout (strided_shard_rank, | STRING |
| HIGH | areal/experimental/models/archon/qwen3/model/model.py | 42 | Determine if a layer should use MoE instead of dense FFN. Args: layer_id: The layer index (0-based). | STRING |
| HIGH | areal/experimental/openai/client.py | 86 | Validate that ``value`` is a list of dictionaries or BaseModel objects. Args: name: Name of the argument be | STRING |
| HIGH | areal/experimental/openai/client.py | 276 | Convert a Responses API input item into Chat Completions message dicts. Handles ``output_text``, ``input_text``, `` | STRING |
| HIGH | areal/infra/platforms/platform.py | 69 | Fallback attribute accessor for device-specific Torch modules. This method is called when the requested attribut | STRING |
| HIGH | areal/utils/seqpack.py | 168 | Return the allocation function for the given algorithm name. Args: algorithm: One of ``"ffd"`` or ``"kk"``. | STRING |
| HIGH | areal/utils/seqpack.py | 453 | Partition *values* into groups using the Karmarkar-Karp differencing method. This is a **drop-in replacement** for | STRING |
| HIGH | areal/utils/seqpack.py | 541 | Splits `nums` into K groups such that the maximum difference between group sums is minimized. Returns indices | STRING |
| HIGH | areal/utils/name_resolve.py | 642 | Get the value for a key. Args: name: Key to retrieve Returns: The value as a s | STRING |
| HIGH | areal/utils/name_resolve.py | 658 | Get a value with lock already acquired. Args: name: Key to retrieve Returns: T | STRING |
| HIGH | areal/utils/name_resolve.py | 1055 | Get the value for a key. Args: name: Key to retrieve Returns: The value as a s | STRING |
| HIGH | areal/utils/network.py | 13 | Find the local IP address for outbound route to `probe_host:probe_port`. Args: probe_host: Remote addr | STRING |
| HIGH | areal/utils/network.py | 119 | Find multiple free ports within a specified range. Args: count: Number of free ports to find p | STRING |
| HIGH | areal/api/alloc_mode.py | 1137 | Convert parsed result to _AllocationMode object. Args: result: Parsed result (list of ModelAllocati | STRING |
| HIGH | areal/engine/megatron_utils/fp8/config.py | 9 | Extract block size from quantization configuration. Args: quantization_config: Quantization configuration d | STRING |
| HIGH | areal/engine/megatron_utils/fp8/tensor_helper.py | 313 | Convert Transformer Engine Float8BlockwiseQTensor to FP8BlockwiseTensorHelper. Args: tensor: Transf | STRING |
| HIGH | areal/engine/fsdp_utils/optimizer.py | 20 | Convert string to corresponding torch dtype, only supports bfloat16 and float32. Args: dtype_str: Data | STRING |
| HIGH | areal/trainer/ppo/actor.py | 735 | Resolve the proximal policy log-probabilities based on the method. This function determines the final proximal | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tests/test_train_engine.py | 128 | # Create the engine using from_pretrained method, without TrainEngineConfig | COMMENT |
| MEDIUM | tests/test_rollout_controller.py | 29 | # Create a mutable SchedulingSpec that can be modified by the controller | COMMENT |
| MEDIUM⚡ | tests/experimental/archon/test_state_dict_adapter.py | 63 | # Create a minimal HF state dict | COMMENT |
| MEDIUM | tests/experimental/archon/test_weight_sync.py | 189 | # Create a fake tensor with correct shape on CPU | COMMENT |
| MEDIUM | tests/experimental/openai/test_proxy_integration.py | 234 | # Create a session | COMMENT |
| MEDIUM | tests/fp8/test_fp8_rmsnorm.py | 231 | # Create a dummy loss (sum of output) | COMMENT |
| MEDIUM⚡ | examples/countdown/reward_score.py | 44 | # Define a regex pattern that only allows numbers, operators, parentheses, and whitespace | COMMENT |
| MEDIUM | examples/scaffolding/worker.py | 201 | # Create a worker | STRING |
| MEDIUM | examples/scaffolding/worker.py | 239 | # Create an async OpenAI client pointing to the SGLang server | COMMENT |
| MEDIUM | examples/terminal_bench/agent/chat_agent_trace.py | 131 | # Create an error tool calling record | STRING |
| MEDIUM | examples/terminal_bench/agent/chat_agent_trace.py | 144 | # Create the error record | STRING |
| MEDIUM | areal/infra/remote_inf_engine.py | 794 | # Create a shallow copy of the input request | COMMENT |
| MEDIUM⚡ | areal/infra/rpc/guard/engine_blueprint.py | 48 | # Define the constraint | COMMENT |
| MEDIUM | areal/tools/plot_session_trace.py | 1020 | # Create a separate figure for each rank | COMMENT |
| MEDIUM | areal/tools/plot_session_trace.py | 1030 | # Create a figure for this rank | COMMENT |
| MEDIUM | areal/tools/validate_docker_installation.py | 202 | # Create an FP8 recipe | COMMENT |
| MEDIUM | areal/tools/validate_docker_installation.py | 223 | # Create a simple model and optimizer | COMMENT |
| MEDIUM | areal/utils/recover.py | 390 | # This method is called by check_if_recover to check if the experiment should | COMMENT |
| MEDIUM | areal/models/tree_attn/tree.py | 375 | # Create an empty dummy trie | COMMENT |
| MEDIUM | areal/models/tree_attn/tree.py | 761 | # Create a minimal valid block mask for empty trees | COMMENT |
| MEDIUM | areal/v2/inference_service/sglang/scheduler.py | 220 | # Create a scheduler and run the event loop | COMMENT |
| MEDIUM | areal/workflow/openai_agent/math_agent.py | 67 | # Create the main orchestrator agent with handoffs | COMMENT |
| MEDIUM | areal/api/reward_api.py | 47 | """This function is a placeholder for the reward function that will be used in the RLVR pipeline. | STRING |
| MEDIUM | areal/engine/megatron_utils/fp8/__init__.py | 5 | # This module provides FP8 quantization and dequantization utilities for | COMMENT |
| MEDIUM | areal/engine/megatron_utils/fp8/tensor_helper.py | 32 | # Create a tensor subclass that wraps rowwise_data | COMMENT |
| MEDIUM | areal/trainer/rl_trainer.py | 1029 | # Create a working copy of config | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | examples/scaffolding/search_agent_controller.py | 152 | # the SGLang context window. | COMMENT |
| MEDIUM⚡ | examples/scaffolding/README.md | 63 | # Step 4: Create ScaffoldingLlm (orchestrates controllers with workers) | COMMENT |
| MEDIUM | examples/scaffolding/core/worker.py | 2 | # Vendored from tensorrt_llm.scaffolding.worker | COMMENT |
| MEDIUM | examples/scaffolding/core/task.py | 2 | # Vendored from tensorrt_llm.scaffolding.task | COMMENT |
| MEDIUM⚡ | examples/scaffolding/core/math_utils.py | 2 | # Vendored from tensorrt_llm.scaffolding.math_utils | COMMENT |
| MEDIUM | examples/scaffolding/core/controller.py | 2 | # Vendored from tensorrt_llm.scaffolding.controller | COMMENT |
| MEDIUM | examples/scaffolding/core/__init__.py | 2 | # Vendored from TensorRT-LLM scaffolding framework. | COMMENT |
| MEDIUM | examples/scaffolding/core/__init__.py | 3 | # Core scaffolding primitives adapted for standalone use in AReaL. | COMMENT |
| MEDIUM | examples/scaffolding/core/scaffolding_llm.py | 2 | # Vendored from tensorrt_llm.scaffolding.scaffolding_llm | COMMENT |
| MEDIUM | examples/scaffolding/core/result.py | 2 | # Vendored from tensorrt_llm.scaffolding.result | COMMENT |
| MEDIUM | examples/scaffolding/core/task_collection.py | 2 | # Vendored from tensorrt_llm.scaffolding.task_collection | COMMENT |
| MEDIUM⚡ | areal/experimental/openai/client.py | 355 | # prompt + generation past the backend model's context window. | COMMENT |
| MEDIUM | areal/utils/logging.py | 34 | # - white: Controllers, RPC, Inference wrappers (orchestration) | COMMENT |
| MEDIUM | areal/utils/logging.py | 123 | # Inference service - white (orchestration) | COMMENT |
| MEDIUM | areal/v2/cli/inference/client.py | 15 | # the scaffold names directly. | COMMENT |
| MEDIUM | areal/v2/inference_service/vllm/bridge.py | 36 | # Compute effective max_new_tokens (cap by remaining context window) | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | tests/test_adv_norm_config.py | 599 | # With single element, unbiased std should return zero (undefined) | COMMENT |
| HIGH⚡ | areal/infra/utils/slurm.py | 50 | if kill -0 "$pid" 2>/dev/null; then | CODE |
| HIGH⚡ | areal/infra/utils/slurm.py | 52 | kill "$pid" 2>/dev/null || true | CODE |
| HIGH⚡ | areal/infra/utils/slurm.py | 59 | if kill -0 "$pid" 2>/dev/null; then | CODE |
| HIGH⚡ | areal/infra/utils/slurm.py | 60 | kill -9 "$pid" 2>/dev/null || true | CODE |
| HIGH | areal/infra/utils/slurm.py | 112 | if ! kill -0 "$pid" 2>/dev/null; then | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/test_rollout_controller.py | 798 | CODE | |
| LOW | tests/experimental/archon/torchrun/dist_utils.py | 21 | CODE | |
| LOW | tests/experimental/archon/torchrun/dist_utils.py | 131 | CODE | |
| LOW | tests/experimental/openai/test_cache.py | 27 | CODE | |
| LOW | tests/v2/inference_service/test_inf_bridge.py | 63 | CODE | |
| LOW | .agents/skills/review-pr/sync_review_pr_refs.py | 48 | CODE | |
| LOW | examples/tir/tir_workflow.py | 273 | CODE | |
| LOW | examples/tir/tools/daytona_python_tool.py | 74 | CODE | |
| LOW | examples/terminal_bench/agent/camel_terminal_agent.py | 39 | CODE | |
| LOW | examples/terminal_bench/workflow/camel_rlvr_workflow.py | 25 | CODE | |
| LOW | areal/experimental/camel/openai_model.py | 194 | CODE | |
| LOW | areal/experimental/models/archon/expert_parallel.py | 214 | CODE | |
| LOW | …/experimental/models/archon/qwen3/infra/parallelize.py | 302 | CODE | |
| LOW | areal/experimental/models/archon/moe/utils.py | 248 | CODE | |
| LOW | areal/experimental/models/archon/moe/utils.py | 285 | CODE | |
| LOW | areal/experimental/openai/client.py | 547 | CODE | |
| LOW | areal/experimental/openai/client.py | 570 | CODE | |
| LOW | areal/experimental/openai/client.py | 592 | CODE | |
| LOW | areal/experimental/openai/client.py | 1031 | CODE | |
| LOW | areal/infra/remote_inf_engine.py | 946 | CODE | |
| LOW | areal/infra/scheduler/slurm.py | 73 | CODE | |
| LOW | areal/infra/scheduler/local.py | 100 | CODE | |
| LOW | areal/infra/sandbox/runner.py | 103 | CODE | |
| LOW | areal/models/mcore/lightning_attention.py | 151 | CODE | |
| LOW | areal/models/mcore/lightning_attention.py | 174 | CODE | |
| LOW | areal/models/mcore/lightning_attention.py | 342 | CODE | |
| LOW | areal/models/transformers/vision_sp_shard.py | 196 | CODE | |
| LOW | areal/v2/weight_update/nccl_group.py | 18 | CODE | |
| LOW | areal/v2/weight_update/controller/controller.py | 106 | CODE | |
| LOW | areal/engine/core/distributed.py | 79 | CODE | |
| LOW | areal/engine/megatron_utils/checkpointer.py | 228 | CODE | |
| LOW | areal/engine/megatron_utils/packed_context_parallel.py | 425 | CODE | |
| LOW | areal/engine/vllm_ext/areal_vllm_server.py | 359 | CODE | |
| LOW | areal/engine/fsdp_utils/optimizer.py | 45 | CODE | |
| LOW | areal/trainer/ppo/actor.py | 420 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | pyproject.vllm.toml | 1 | # vLLM variant of the AReaL project configuration. | COMMENT |
| LOW | tests/test_megatron_engine_distributed.py | 261 | _run_test_with_torchrun( | COMMENT |
| LOW | tests/test_adv_norm_config.py | 1161 | COMMENT | |
| LOW | tests/experimental/archon/torchrun/run_cp_forward.py | 301 | # Run with `torchrun --nproc_per_node=N` to test with multiple GPUs | COMMENT |
| LOW | tests/torchrun/run_megatron_engine_distributed.py | 41 | "qwen3_5": "megatron-bridge", | COMMENT |
| LOW | examples/environ_ref.yaml | 21 | NCCL_SET_THREAD_NAME: "1" | COMMENT |
| LOW | examples/countdown/countdown.py | 441 | type=str, | COMMENT |
| LOW | examples/search_agent/tongyi_deepresearch/prompt.py | 1 | # SYSTEM_PROMPT = """You are a deep research assistant. Your core function is to conduct thorough, multi-source investig | COMMENT |
| LOW | examples/search_agent/tongyi_deepresearch/prompt.py | 21 | # import numpy as np | COMMENT |
| LOW | areal/infra/platforms/platform.py | 41 | # use "CPU" as a fallback for platforms not registered in PyTorch | COMMENT |
| LOW | areal/infra/rpc/rtensor.py | 301 | COMMENT | |
| LOW | areal/infra/rpc/guard/engine_blueprint.py | 581 | # contain shard ids from DP-head results. Remotizing on non-DP-head | COMMENT |
| LOW | areal/utils/logging.py | 21 | ) | COMMENT |
| LOW | areal/utils/functional/vocab_parallel.py | 341 | # Strategy: First compute entropy gradient (needs original softmax values), | COMMENT |
| LOW | areal/v2/inference_service/data_proxy/app.py | 801 | # ========================================================================= | COMMENT |
| LOW | areal/api/cli_args.py | 1841 | # to vLLM, achieving enable_*=False behavior. | COMMENT |
| LOW | areal/engine/fsdp_engine.py | 521 | # directly destroy all groups. Otherwise, process group | COMMENT |
| LOW | areal/engine/megatron_engine.py | 421 | COMMENT | |
| LOW | areal/engine/megatron_engine.py | 1001 | # Step 1: Prepare micro-batches | COMMENT |
| LOW | areal/engine/megatron_engine.py | 1741 | if gen_pp_size > 1: | COMMENT |
| LOW | areal/engine/sglang_remote.py | 281 | pp_rank = int(group_name.rsplit("_", 1)[-1]) | COMMENT |
| LOW | areal/engine/megatron_utils/checkpointer.py | 1 | # SPDX-License-Identifier: Apache-2.0 | COMMENT |
| LOW | areal/engine/megatron_utils/checkpointer.py | 301 | torch.distributed.barrier() | COMMENT |
| LOW | areal/engine/megatron_utils/checkpointer.py | 461 | async_save=self.async_save, | COMMENT |
| LOW | areal/engine/megatron_utils/packed_context_parallel.py | 301 | packed_seq_params = None | COMMENT |
| LOW | areal/engine/megatron_utils/megatron.py | 141 | return param | COMMENT |
| LOW | areal/engine/megatron_utils/fp8/__init__.py | 1 | # SPDX-License-Identifier: Apache-2.0 | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tests/test_math_verify_reward.py | 498 | """Advanced LaTeX formula tests for robust mathematical notation.""" | STRING |
| MEDIUM | tests/experimental/archon/torchrun/run_cp_forward.py | 259 | # Use cosine similarity for comparison (more robust to numerical errors) | COMMENT |
| MEDIUM | examples/search_agent/tongyi_deepresearch/prompt.py | 1 | # SYSTEM_PROMPT = """You are a deep research assistant. Your core function is to conduct thorough, multi-source investig | COMMENT |
| MEDIUM | examples/search_agent/tongyi_deepresearch/prompt.py | 1 | # SYSTEM_PROMPT = """You are a deep research assistant. Your core function is to conduct thorough, multi-source investig | COMMENT |
| MEDIUM | examples/search_agent/tongyi_deepresearch/prompt.py | 38 | SYSTEM_PROMPT = """You are a deep research assistant. Your core function is to conduct thorough, multi-source investigat | CODE |
| LOW | areal/tools/perf_trace_converter.py | 493 | # Replace .jsonl extension with .json, or just add .json | COMMENT |
| MEDIUM⚡ | areal/utils/seqpack.py | 387 | """Compute comprehensive packing quality metrics for a given partition. | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | docs/zh/best_practices/debugging.md | 72 | asyncio.run(MyAgent().run(data, base_url="https://api.openai.com/v1", api_key="YOUR_API_KEY")) | CODE |
| HIGH | docs/en/best_practices/debugging.md | 79 | asyncio.run(MyAgent().run(data, base_url="https://api.openai.com/v1", api_key="YOUR_API_KEY")) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/v2/inference_service/test_inf_bridge.py | 573 | "image_url": {"url": "placeholder"}, | CODE |
| LOW | tests/v2/inference_service/test_image_input.py | 101 | assert vllm_content[1]["image_url"]["url"] == "placeholder" | CODE |
| LOW | tests/v2/inference_service/test_image_input.py | 369 | "image_url": {"url": "placeholder"}, | CODE |
| LOW | tests/v2/inference_service/test_image_input.py | 405 | {"type": "image_url", "image_url": {"url": "placeholder"}}, | CODE |
| LOW | tests/v2/inference_service/test_image_input.py | 406 | {"type": "image_url", "image_url": {"url": "placeholder"}}, | CODE |
| LOW | tests/v2/inference_service/test_image_input.py | 443 | {"type": "image_url", "image_url": {"url": "placeholder"}}, | CODE |
| LOW | tests/v2/inference_service/test_image_input.py | 444 | {"type": "image_url", "image_url": {"url": "placeholder"}}, | CODE |
| LOW | tests/v2/inference_service/test_image_input.py | 476 | {"type": "image_url", "image_url": {"url": "placeholder"}}, | CODE |
| LOW⚡ | tests/v2/inference_service/test_data_proxy_chat.py | 396 | headers={"Authorization": "Bearer fake-key"}, | CODE |
| LOW | areal/experimental/openai/client.py | 227 | "image_url": {"url": "placeholder"}, | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | examples/scaffolding/core/worker.py | 21 | async def run_task(self, task: Task) -> TaskStatus: | CODE |
| LOW | areal/v2/agent_service/gateway/bridge.py | 34 | async def handle_request(self, request: Request) -> Any: ... | CODE |
| LOW | areal/v2/agent_service/gateway/bridge.py | 48 | async def handle_request(self, request: Request) -> Any: | CODE |
| LOW | areal/v2/agent_service/gateway/bridge.py | 335 | async def handle_request(self, request: Request) -> Any: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/uv_sync.sh | 4 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | areal/models/mcore/registry.py | 320 | share_embeddings_and_output_weights=False, # TODO: implement share output weights | CODE |