AI Slop Code RIsk Monitor

areal-project/AReaL

The RL Bridge for LLM-based Agent Applications. Made Simple & Flexible.

30.3 High pattern signal View on GitHub

Maintenance and Governance Review

This report summarizes scanner evidence for areal-project/AReaL, a Python project with 5,827 GitHub stars. SynthScan examined 366,024 lines of code across 1386 source files, recording 7579 pattern matches distributed across 23 syntactic categories. The legacy adjusted pattern signal is 30.3 (High 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.

30.3
Adjusted Signal
30.3
Raw Pattern Score
100%
Time Factor
2026-10-10
Last Push
5.8K
Stars
Python
Language
366.0K
Lines of Code
1.4K
Files
7.6K
Pattern Hits
2026-10-12
Scan Date
0.18
HC Hit Rate

Risk Review · v3

Use each vector to guide manual verification of the underlying findings.

Cognitive Ownership Risk 49.6/100 · MEDIUM

Can maintainers explain intent, assumptions, and trade-offs? 4820 finding(s).

Hallucinated Dependency & Supply Chain Risk 10.6/100 · LOW

Are imports declared and package/API names verified? 806 finding(s).

Agent Over-Engineering Ratio 70.8/100 · HIGH

Are wrappers, guards, and repeated structures necessary? 5897 finding(s).

PR Review Velocity Impact 77.7/100 · CRITICAL

Which changes need focused human review? 7579 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

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.

Severity Breakdown

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.

CRITICAL 0HIGH 252MEDIUM 1076LOW 6251

Directory Score Breakdown

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.

Pattern Findings

The scanner identified 7579 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.

Hyper-Verbose Identifiers3878 hits · 3682 pts
SeverityFileLineSnippetContext
LOW.opencode/skills/add-reward/SKILL.md122def test_reward_correct_answer():CODE
LOW.opencode/skills/add-archon-model/SKILL.md369def test_state_dict_roundtrip():CODE
LOW.opencode/skills/add-unit-tests/SKILL.md52def test_function_under_condition_returns_expected():CODE
LOW⚡.opencode/skills/add-unit-tests/SKILL.md104def test_slow_but_required_in_ci():CODE
LOW⚡.opencode/skills/add-unit-tests/SKILL.md115def test_distributed_function(monkeypatch):CODE
LOWtests/test_train_controller.py159def create_mock_distributed_batch(size=4, seq_len=10):CODE
LOWtests/test_train_controller.py254 def test_destroy_handles_errors(self, train_controller, ft_spec):CODE
LOWtests/test_train_controller.py273 def test_destroy_requests_reverse_order(self, train_controller, ft_spec):CODE
LOWtests/test_train_controller.py293 def test_merge_tensors_reorders_results(self):CODE
LOWtests/test_train_controller.py304 def test_merge_tensors_with_tensor_results(self):CODE
LOWtests/test_train_controller.py431 def test_custom_function_call_with_distributed_batch(CODE
LOWtests/test_train_controller.py455 def test_custom_function_call_with_regular_args(self, train_controller, ft_spec):CODE
LOWtests/test_train_controller.py476 def test_custom_function_call_filters_dp_heads(self, train_controller, ft_spec):CODE
LOWtests/test_train_controller.py491 def test_create_process_group_is_dummy(self, train_controller, parallel_strategy):CODE
LOWtests/test_train_controller.py515 def test_connect_engine_sets_rollout(self, train_controller, ft_spec):CODE
LOWtests/test_train_controller.py529 def test_connect_engine_warns_on_change(self, train_controller, ft_spec):CODE
LOWtests/test_train_controller.py545 def test_connect_engine_same_rollout_no_warning(self, train_controller, ft_spec):CODE
LOWtests/test_train_controller.py560 def test_check_rollout_engine_connected_raises_when_not_connected(CODE
LOWtests/test_train_controller.py572 def test_check_rollout_engine_connected_passes_when_connected(CODE
LOWtests/test_train_controller.py589 def test_prepare_batch_delegates_to_rollout(CODE
LOWtests/test_train_controller.py627 def test_rollout_batch_delegates_to_rollout(CODE
LOWtests/test_train_controller.py667 def test_update_weights_raises_when_not_connected(self, train_controller, ft_spec):CODE
LOWtests/test_train_controller.py710 def test_prepare_dispatch_splits_distributed_batch(self, train_controller, ft_spec):CODE
LOWtests/test_train_controller.py724 def test_prepare_dispatch_partitions_without_duplication(CODE
LOWtests/test_train_controller.py751 def test_prepare_dispatch_replicates_non_batch_args(CODE
LOWtests/test_train_controller.py768 def test_prepare_dispatch_handles_kwargs(self, train_controller, ft_spec):CODE
LOWtests/test_train_controller.py787 def test_storage_clear_surfaces_per_node_failures_and_stats(self):CODE
LOWtests/test_train_controller.py828 def test_failed_storage_clear_is_retried_on_next_call(self):CODE
LOWtests/test_train_controller.py849 def test_second_storage_clear_failure_cleans_workers_then_raises(self):CODE
LOWtests/test_train_controller.py878 def test_worker_cleanup_failure_preserves_exhausted_storage_state(self):CODE
LOWtests/test_train_controller.py917 def test_storage_clear_propagates_cancellation(self):CODE
LOWtests/test_train_controller.py932 def test_storage_clear_cancellation_keeps_batch_state_atomic(self):CODE
LOW⚡tests/test_slurm_terminal_state.py14 def test_node_fail_maps_to_failed(self):CODE
LOW⚡tests/test_slurm_terminal_state.py20 def test_terminal_states_are_not_active(self, state):CODE
LOW⚡tests/test_slurm_terminal_state.py24 def test_live_states_are_active(self, state):CODE
LOWtests/test_slurm_terminal_state.py41 def test_maps_sacct_output_to_a_job_state(self, output, expected):CODE
LOWtests/test_slurm_terminal_state.py45 def test_returns_none_when_sacct_has_no_record(self):CODE
LOWtests/test_slurm_terminal_state.py56 def test_returns_none_when_sacct_is_unavailable(self, error):CODE
LOWtests/test_slurm_terminal_state.py60 def test_reads_only_the_first_record(self):CODE
LOWtests/test_incomplete_rollout_groups.py50def test_rollout_group_size_contract_rejects_invalid_threshold(CODE
LOWtests/test_incomplete_rollout_groups.py68async def test_grouped_rollout_keeps_each_usable_member_once(rollout_stats):CODE
LOWtests/test_incomplete_rollout_groups.py89async def test_grouped_rollout_marks_empty_group_unusable(rollout_stats):CODE
LOWtests/test_incomplete_rollout_groups.py111async def test_grouped_rollout_applies_estimator_minimum(rollout_stats):CODE
LOWtests/test_incomplete_rollout_groups.py134async def test_grouped_rollout_keeps_singleton_by_default(rollout_stats):CODE
LOWtests/test_incomplete_rollout_groups.py148async def test_group_relative_tensor_slot_retains_split_rows(rollout_stats):CODE
LOWtests/test_incomplete_rollout_groups.py162async def test_group_relative_interaction_slot_retains_split_rows(rollout_stats):CODE
LOWtests/test_incomplete_rollout_groups.py183def test_executor_propagates_group_contract_error_without_retry(dynamic_bs):CODE
LOWtests/test_incomplete_rollout_groups.py220def test_group_training_metrics_report_actual_size_and_token_weight():CODE
LOWtests/test_incomplete_rollout_groups.py241def test_actor_loss_keeps_existing_token_weighted_group_reduction():CODE
LOW⚡tests/test_incomplete_rollout_groups.py266def test_min_usable_group_size_defaults_to_estimator_minimum(normalization):CODE
LOW⚡tests/test_incomplete_rollout_groups.py273def test_batch_relative_estimator_keeps_usable_singleton():CODE
LOW⚡tests/test_incomplete_rollout_groups.py279def test_explicit_min_usable_group_size_overrides_derivation():CODE
LOW⚡tests/test_incomplete_rollout_groups.py288def test_group_statistics_reject_explicit_singleton_minimum():CODE
LOW⚡tests/test_incomplete_rollout_groups.py296def test_batch_relative_estimator_accepts_explicit_singleton_minimum():CODE
LOW⚡tests/test_incomplete_rollout_groups.py305def test_dynamic_collection_backfills_from_ready_groups():CODE
LOWtests/test_incomplete_rollout_groups.py320def test_dynamic_collection_aborts_after_consecutive_empty_rounds():CODE
LOWtests/test_incomplete_rollout_groups.py334def test_dynamic_collection_empty_streak_resets_on_progress():CODE
LOWtests/test_incomplete_rollout_groups.py351def test_dynamic_collection_tolerates_fast_all_reject_bursts():CODE
LOWtests/test_incomplete_rollout_groups.py366def test_fixed_collection_rejects_undersized_batch():CODE
LOW⚡tests/test_zigzag_indices.py67def test_vectorized_matches_loop_reference(cp_size, seq_lens, builder):CODE
3818 more matches not shown…
Decorative Section Separators977 hits · 3376 pts
SeverityFileLineSnippetContext
MEDIUMpyproject.toml218# =============================================================================COMMENT
MEDIUMpyproject.toml220# =============================================================================COMMENT
MEDIUMpyproject.toml325# =============================================================================COMMENT
MEDIUMpyproject.toml327# =============================================================================COMMENT
MEDIUMpyproject.toml348# =============================================================================COMMENT
MEDIUMpyproject.toml350# =============================================================================COMMENT
MEDIUMpyproject.vllm.toml229# =============================================================================COMMENT
MEDIUMpyproject.vllm.toml231# =============================================================================COMMENT
MEDIUMpyproject.vllm.toml324# =============================================================================COMMENT
MEDIUMpyproject.vllm.toml326# =============================================================================COMMENT
MEDIUMpyproject.vllm.toml347# =============================================================================COMMENT
MEDIUMpyproject.vllm.toml349# =============================================================================COMMENT
MEDIUMtests/test_per_layer_optim_step.py22# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_per_layer_optim_step.py24# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡tests/test_per_layer_optim_step.py119# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡tests/test_per_layer_optim_step.py121# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_per_layer_optim_step.py253# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_per_layer_optim_step.py255# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡tests/test_seqpack.py463# =============================================================================COMMENT
MEDIUM⚡tests/test_seqpack.py465# =============================================================================COMMENT
MEDIUM⚡tests/test_seqpack.py981# =============================================================================COMMENT
MEDIUM⚡tests/test_seqpack.py983# =============================================================================COMMENT
MEDIUMtests/test_seqpack.py27# =============================================================================COMMENT
MEDIUMtests/test_seqpack.py29# =============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py30# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py32# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py81# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py83# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py219# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py221# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py242# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py244# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py301# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py303# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py354# ============================================================================COMMENT
MEDIUM⚡tests/test_slurm_scheduler.py356# ============================================================================COMMENT
MEDIUMtests/test_slurm_scheduler.py154# ============================================================================COMMENT
MEDIUMtests/test_slurm_scheduler.py156# ============================================================================COMMENT
MEDIUM⚡tests/test_kk_allocate.py223# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡tests/test_kk_allocate.py225# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡tests/test_kk_allocate.py461# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡tests/test_kk_allocate.py463# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡tests/test_kk_allocate.py550# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡tests/test_kk_allocate.py552# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py34# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py36# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py62# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py64# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py114# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py116# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py158# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py160# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py373# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py375# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py426# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_kk_allocate.py428# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_local_scheduler.py39# ============================================================================COMMENT
MEDIUMtests/test_local_scheduler.py41# ============================================================================COMMENT
MEDIUMtests/test_inference_engines.py254# ============================================================================COMMENT
MEDIUMtests/test_inference_engines.py256# ============================================================================COMMENT
917 more matches not shown…
Empty Error Handlers155 hits · 775 pts
SeverityFileLineSnippetContext
HIGHtests/test_rtensor.py115except Exception:CODE
HIGHtests/test_local_scheduler.py1620except EngineCallError:CODE
HIGHtests/test_local_scheduler.py2178except (CODE
HIGHtests/test_local_scheduler.py2234except (CODE
HIGHtests/test_local_scheduler.py2088except (CODE
HIGHtests/test_local_scheduler.py2109except Exception:CODE
HIGHtests/test_local_scheduler.py2292except (CODE
HIGHtests/test_local_scheduler.py2538except (CODE
HIGHtests/test_local_scheduler.py2419except (CODE
HIGHtests/test_mopd_gpu.py82except ProcessLookupError:CODE
HIGHtests/test_cuda_deterministic.py338except Exception:CODE
HIGHtests/test_sglang_pp_distributed.py222except ValueError:CODE
HIGHtests/test_sglang_pp_distributed.py230except (ProcessLookupError, PermissionError, OSError):CODE
HIGHtests/test_sglang_pp_distributed.py234except OSError:CODE
HIGHtests/test_sglang_pp_distributed.py133except TimeoutError:CODE
HIGHtests/test_examples.py95except TimeoutError:CODE
HIGHtests/experimental/archon/test_weight_sync.py162except Exception:CODE
HIGHtests/experimental/archon/test_weight_sync.py378except Exception:CODE
HIGHtests/experimental/archon/test_async_checkpoint.py264except RuntimeError:CODE
HIGHtests/experimental/openai/test_proxy_gateway.py386except asyncio.CancelledError:CODE
HIGHtests/experimental/openai/test_proxy_gateway.py434except asyncio.CancelledError:CODE
HIGHtests/experimental/openai/test_proxy_gateway.py691except (asyncio.CancelledError, Exception):CODE
HIGHtests/experimental/openai/test_proxy_gateway.py750except asyncio.CancelledError:CODE
HIGHtests/infra/test_process_supervisor.py50except json.JSONDecodeError:CODE
HIGHtests/infra/test_process_supervisor.py111except psutil.NoSuchProcess:CODE
HIGHtests/infra/test_process_supervisor.py165except psutil.NoSuchProcess:CODE
HIGHtests/infra/test_process_supervisor.py241except psutil.NoSuchProcess:CODE
HIGHtests/infra/data_service/test_epoch_crossing.py65except httpx.HTTPError:CODE
HIGHtests/infra/data_service/test_data_service_e2e.py200except httpx.HTTPError:CODE
HIGHtests/infra/data_service/test_data_service_e2e.py63except httpx.HTTPError:CODE
HIGHtests/v2/weight_update/test_sglang_integration.py83except (httpx.ConnectError, httpx.ReadTimeout):CODE
HIGHtests/fp8/engine_utils.py150except Exception:CODE
HIGHexamples/agent_service/run_agent_service.py36except httpx.ConnectError:CODE
HIGHexamples/scaffolding/controllers.py848except Exception:CODE
HIGH…/scaffolding/tests/test_scaffolding_llm_integration.py999except Exception:CODE
HIGH…/scaffolding/tests/test_scaffolding_llm_integration.py1054except Exception:CODE
HIGHexamples/terminal_bench/agent/chat_agent_trace.py214except ImportError:CODE
HIGHexamples/terminal_bench/agent/chat_agent_trace.py50except Exception:CODE
HIGHexamples/terminal_bench/agent/camel_terminal_agent.py335except Exception:CODE
HIGHexamples/swe/arena_agent.py390except asyncio.CancelledError:CODE
HIGHexamples/swe/arena_agent.py461except FileExistsError:CODE
HIGHexamples/swe/preprocessors.py145except (json.JSONDecodeError, TypeError):CODE
HIGHexamples/math/boba_grpo.py55except Exception:CODE
HIGHareal/version.py87except (subprocess.CalledProcessError, FileNotFoundError):CODE
HIGHareal/experimental/openai/tool_call_parser.py591except ModuleNotFoundError:CODE
HIGHareal/experimental/openai/tool_call_parser.py604except ModuleNotFoundError:CODE
HIGHareal/experimental/openai/client.py1991except ImportError:CODE
HIGHareal/experimental/openai/client.py664except (json.JSONDecodeError, TypeError):CODE
HIGHareal/experimental/openai/proxy/proxy_rollout_server.py1171except asyncio.CancelledError:CODE
HIGHareal/infra/async_task_runner.py684except RuntimeError:CODE
HIGHareal/infra/launcher/local.py85except psutil.NoSuchProcess:CODE
HIGHareal/infra/launcher/ray.py180except (AttributeError, OSError, ValueError):CODE
HIGHareal/infra/launcher/ray.py186except Exception:CODE
HIGHareal/infra/launcher/ray.py215except OSError:CODE
HIGHareal/infra/launcher/ray.py297except ray.exceptions.GetTimeoutError:CODE
HIGHareal/infra/launcher/ray.py220except Exception:CODE
HIGHareal/infra/platforms/rocm.py71except ImportError:CODE
HIGHareal/infra/platforms/cuda.py40except ImportError:CODE
HIGHareal/infra/platforms/unknown.py39except ImportError:CODE
HIGHareal/infra/scheduler/slurm.py74except ValueError:CODE
95 more matches not shown…
Unused Imports784 hits · 746 pts
SeverityFileLineSnippetContext
LOWtests/test_awex_delta_common.py9CODE
LOWtests/test_warmup_process_groups.py8CODE
LOWtests/test_mopd_teacher_manager.py3CODE
LOWtests/test_filter_function.py3CODE
LOWtests/test_megatron_mopd_teacher.py3CODE
LOWtests/test_prm_runner.py3CODE
LOWtests/test_token_rewards_advantage.py3CODE
LOWtests/test_swe_preprocessors.py1CODE
LOWtests/test_perf_trace_converter.py1CODE
LOWtests/test_prm_config.py3CODE
LOWtests/test_megatron_async_save.py17CODE
LOWtests/utils.py7CODE
LOWtests/utils.py7CODE
LOWtests/test_interaction_token_rewards.py3CODE
LOWtests/test_mopd_gpu.py5CODE
LOWtests/test_virl39k.py3CODE
LOWtests/test_geometry3k_agent.py3CODE
LOWtests/test_reassemble_cp_logprobs.py15CODE
LOWtests/test_examples.py737CODE
LOWtests/test_examples.py817CODE
LOWtests/test_profile_example.py1CODE
LOWtests/test_mopd_rtensor.py3CODE
LOWtests/test_grouped_rollout_workflow.py3CODE
LOWtests/experimental/archon/test_hf_parity_qwen2.py1CODE
LOWtests/experimental/archon/test_moe_common.py25CODE
LOWtests/experimental/archon/conftest.py107CODE
LOWtests/experimental/archon/conftest.py115CODE
LOWtests/experimental/archon/test_hf_parity_qwen3.py1CODE
LOWtests/experimental/archon/test_hf_parity_qwen3_moe.py1CODE
LOWtests/experimental/archon/test_hf_parity_qwen3_5_moe.py1CODE
LOWtests/experimental/archon/test_async_checkpoint.py11CODE
LOWtests/experimental/archon/utils.py22CODE
LOWtests/experimental/archon/utils.py22CODE
LOWtests/experimental/archon/utils.py22CODE
LOWtests/experimental/archon/test_qwen3_5.py14CODE
LOWtests/experimental/archon/test_moe_hf_parity.py23CODE
LOWtests/experimental/archon/test_hf_parity_qwen3_5.py1CODE
LOW…experimental/archon/torchrun/run_pp_gradient_verify.py12CODE
LOWtests/experimental/archon/torchrun/run_pp_tests.py21CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py24CODE
LOWtests/experimental/archon/fp8/test_fp8_scale_layout.py8CODE
LOWtests/experimental/archon/fp8/test_conversion.py11CODE
LOWtests/experimental/archon/fp8/test_moe_dispatch.py23CODE
LOWtests/experimental/archon/fp8/test_fp8_linear.py20CODE
LOW…sts/experimental/archon/fp8/torchrun/run_checkpoint.py2CODE
LOW…xperimental/archon/fp8/torchrun/run_sharded_dequant.py16CODE
LOWtests/experimental/openai/test_proxy_gateway.py3CODE
LOWtests/experimental/openai/test_proxy_integration.py1CODE
LOWtests/experimental/openai/test_proxy_rollout_server.py3CODE
LOWtests/experimental/openai/test_online_agent.py3CODE
LOW…/experimental/openai/test_context_overflow_recovery.py3CODE
LOWtests/experimental/openai/test_vlm_trajectory.py3CODE
LOW…experimental/openai/test_streaming_chat_completions.py10CODE
LOWtests/experimental/openai/test_tensor_reference.py3CODE
LOWtests/experimental/openai/test_retry_orphan.py9CODE
LOWtests/infra/test_proc.py1CODE
LOWtests/infra/test_remote_inf_engine.py1CODE
LOWtests/infra/test_local_launcher.py1CODE
LOWtests/infra/test_launcher_utils.py1CODE
LOWtests/infra/sandbox/test_runner.py5CODE
724 more matches not shown…
Excessive Try-Catch Wrapping586 hits · 605 pts
SeverityFileLineSnippetContext
LOW.opencode/skills/add-reward/SKILL.md61 except Exception:CODE
MEDIUMtests/test_swe_sft_cache.py590def build(label, source, attempt_id):CODE
LOWtests/test_swe_sft_cache.py601 except Exception as error:CODE
LOWtests/test_rtensor.py115 except Exception:CODE
LOWtests/test_slurm_scheduler.py60 except Exception as e:CODE
LOW⚡tests/test_ray_scheduler.py86 except Exception as e:CODE
LOWtests/test_local_scheduler.py2109 except Exception:CODE
LOW⚡tests/test_offload.py93 except Exception as e:CODE
LOWtests/test_cuda_deterministic.py307 except Exception as e:CODE
LOWtests/test_cuda_deterministic.py338 except Exception:CODE
LOWtests/test_sglang_pp_distributed.py296 except Exception:CODE
LOWtests/test_adv_norm_config.py1073 except Exception as e:CODE
LOW⚡tests/experimental/archon/conftest.py32except Exception:CODE
LOWtests/experimental/archon/conftest.py118except Exception:CODE
LOW⚡tests/experimental/archon/conftest.py174 except Exception:CODE
LOWtests/experimental/archon/test_weight_sync.py162 except Exception:CODE
LOWtests/experimental/archon/test_weight_sync.py220 except Exception:CODE
LOWtests/experimental/archon/test_weight_sync.py282 except Exception:CODE
LOWtests/experimental/archon/test_weight_sync.py378 except Exception:CODE
LOW⚡tests/experimental/archon/test_grpo.py447 except Exception as e:CODE
LOW…/experimental/archon/torchrun/run_qwen3_parallelize.py551 except Exception as e:CODE
LOW…experimental/archon/torchrun/run_pp_gradient_verify.py578 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_archon_engine_pp.py167 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_archon_engine_pp.py197 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_archon_engine_pp.py231 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_archon_engine_pp.py286 except Exception as e:CODE
LOWtests/experimental/archon/torchrun/run_parallel_dims.py222 except Exception as e:CODE
LOWtests/experimental/archon/torchrun/run_parallel_dims.py396 except Exception as e:CODE
LOWtests/experimental/archon/torchrun/run_ep_tests.py818 except Exception as e:CODE
LOWtests/experimental/archon/torchrun/run_pp_tests.py901 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py149 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py294 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py461 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py585 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py778 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py1008 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py1197 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py1359 except Exception as e:CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py1467 except Exception as e:CODE
LOW…ts/experimental/archon/torchrun/run_pp_combinations.py558 except Exception as e:CODE
LOW…ts/experimental/archon/torchrun/run_pp_combinations.py629 except Exception as e:CODE
LOW…sts/experimental/archon/fp8/torchrun/run_checkpoint.py140 except Exception as e:CODE
LOW…sts/experimental/archon/fp8/torchrun/run_checkpoint.py191 except Exception as e:CODE
LOW…xperimental/archon/fp8/torchrun/run_sharded_dequant.py244 except Exception as e:CODE
LOWtests/infra/data_service/test_data_service_e2e.py35 except Exception as exc:CODE
LOW⚡tests/torchrun/run_sglang_pp_weight_sync.py275 except Exception as e:CODE
LOW⚡tests/torchrun/run_sglang_pp_weight_sync.py443 except Exception as e:CODE
LOWtests/torchrun/run_fsdp_memory_efficient_lora.py116 except Exception as e:CODE
LOWtests/torchrun/run_lock.py72 except Exception:CODE
LOWtests/v2/weight_update/test_kv_store.py99 except Exception as exc:CODE
LOW…/v2/weight_update/torchrun/run_nccl_weight_transfer.py65 except Exception as e:CODE
LOW…/v2/weight_update/torchrun/run_nccl_weight_transfer.py110 except Exception as e:CODE
LOW…/v2/weight_update/torchrun/run_nccl_weight_transfer.py233 except Exception as e:CODE
LOW…/v2/weight_update/torchrun/run_nccl_weight_transfer.py283 except Exception as e:CODE
LOW…sts/v2/training_service/test_controller_integration.py173 except Exception as exc:CODE
LOWtests/v2/inference_service/integration_utils.py62 except Exception as e:CODE
MEDIUMtests/fp8/model_hooks.py308def hook(module, input, output):CODE
MEDIUMtests/fp8/model_hooks.py327def input_hook(module, input):CODE
MEDIUMtests/fp8/model_hooks.py346def backward_hook(module, grad_input, grad_output):CODE
MEDIUMtests/fp8/model_hooks.py512def backward_hook(module, grad_input, grad_output):CODE
526 more matches not shown…
Structural Annotation Overuse245 hits · 419 pts
SeverityFileLineSnippetContext
LOW.opencode/skills/add-reward/SKILL.md20### Step 1: Create Reward FileCOMMENT
LOW.opencode/skills/add-reward/SKILL.md80### Step 2: Register in __init__.pyCOMMENT
LOW.opencode/skills/add-reward/SKILL.md99### Step 3: Handle Blocking OperationsCOMMENT
LOW.opencode/skills/add-reward/SKILL.md114### Step 4: Add TestsCOMMENT
LOW.opencode/skills/add-dataset/SKILL.md20### Step 1: Create Dataset FileCOMMENT
LOW.opencode/skills/add-dataset/SKILL.md107### Step 2: Register in __init__.pyCOMMENT
LOW.opencode/skills/add-dataset/SKILL.md129### Step 3: Add Config (Optional)COMMENT
LOW.opencode/skills/add-dataset/SKILL.md140### Step 4: Add TestsCOMMENT
LOW.opencode/skills/add-archon-model/SKILL.md29### Step 1: Analyze the Target Model ArchitectureCOMMENT
LOW.opencode/skills/add-archon-model/SKILL.md66### Step 2: Select the Reference ModelCOMMENT
LOW.opencode/skills/add-archon-model/SKILL.md90### Step 3: Implement `args.py`COMMENT
LOW.opencode/skills/add-archon-model/SKILL.md131### Step 4: Implement `model.py`COMMENT
LOW.opencode/skills/add-archon-model/SKILL.md178### Step 5: Implement `rope.py`COMMENT
LOW.opencode/skills/add-archon-model/SKILL.md200### Step 6: Implement `state_dict_adapter.py`COMMENT
LOW.opencode/skills/add-archon-model/SKILL.md243### Step 7: Implement `parallelize.py`COMMENT
LOW.opencode/skills/add-archon-model/SKILL.md282### Step 8: Create `spec.py` and RegisterCOMMENT
LOW.opencode/skills/add-archon-model/SKILL.md315### Step 9: Register in `__init__.py`COMMENT
LOW.opencode/skills/add-archon-model/SKILL.md325### Step 10: Verify and TestCOMMENT
LOW.opencode/skills/add-workflow/SKILL.md28### Step 1: Create Workflow FileCOMMENT
LOW.opencode/skills/add-workflow/SKILL.md105### Step 2: Register in __init__.pyCOMMENT
LOW.opencode/skills/add-workflow/SKILL.md118### Step 3: Update Entry ScriptCOMMENT
LOW.opencode/skills/add-workflow/SKILL.md129### Step 4: Add TestsCOMMENT
LOW.opencode/skills/add-unit-tests/SKILL.md21### Step 1: Understand Test TypesCOMMENT
LOW.opencode/skills/add-unit-tests/SKILL.md33### Step 2: Create Test File StructureCOMMENT
LOW.opencode/skills/add-unit-tests/SKILL.md47### Step 3: Write Test FunctionsCOMMENT
LOW.opencode/skills/add-unit-tests/SKILL.md65### Step 4: Add Pytest Markers and CI StrategyCOMMENT
LOW⚡.opencode/skills/add-unit-tests/SKILL.md108### Step 5: Mock Distributed EnvironmentCOMMENT
LOW⚡.opencode/skills/add-unit-tests/SKILL.md122### Step 6: Handle GPU DependenciesCOMMENT
LOW⚡tests/experimental/openai/test_proxy_gateway.py358 # Step 2: populate queue again for the post-refresh session.COMMENT
LOW⚡tests/experimental/openai/test_proxy_gateway.py368 # Step 3: refresh — same api_key triggers auto-end + new session.COMMENT
LOWtests/experimental/openai/test_proxy_gateway.py339 # Step 1: populate ready queue and start initial session.COMMENT
LOWtests/fp8/test_fp8_tensor.py409 # Step 1: View to 4DCOMMENT
LOWtests/fp8/test_fp8_tensor.py423 # Step 2: Split into Q, K, V along dim=1COMMENT
LOWtests/fp8/test_fp8_tensor.py451 # Step 3: Reshape to 2DCOMMENT
LOW⚡tests/fp8/model_hooks.py127 # Step 1: Prepare micro-batchesCOMMENT
LOW⚡tests/fp8/model_hooks.py130 # Step 2: Define loss functionsCOMMENT
LOW⚡tests/fp8/model_hooks.py157 # Step 3: Compute total loss weightCOMMENT
LOW⚡tests/fp8/model_hooks.py162 # Step 4: Forward-backward using Megatron's pipeline functionCOMMENT
LOWtests/fp8/model_hooks.py195 # Step 5: Collect gradients before optimizer.step()COMMENT
LOW⚡.agents/skills/translate-doc-zh/SKILL.md16### Step 1: Validate the source pathCOMMENT
LOW⚡.agents/skills/translate-doc-zh/SKILL.md23### Step 2: Resolve the target pathCOMMENT
LOW⚡.agents/skills/translate-doc-zh/SKILL.md28### Step 3: Choose translation modeCOMMENT
LOW.agents/skills/upgrade-deps/SKILL.md172### Step 0: Parse Input and Record BaselineCOMMENT
LOW.agents/skills/upgrade-deps/SKILL.md239### Step 1: Update Pyproject FilesCOMMENT
LOW.agents/skills/upgrade-deps/SKILL.md253### Step 2: Lock Dependencies (Variant-Aware)COMMENT
LOW.agents/skills/upgrade-deps/SKILL.md280### Step 3: Resolve Dependency ConflictsCOMMENT
LOW.agents/skills/upgrade-deps/SKILL.md312### Step 4: Update Dockerfile (If Required)COMMENT
LOW.agents/skills/upgrade-deps/SKILL.md354### Step 5: Identify Updated Focused PackagesCOMMENT
LOW.agents/skills/upgrade-deps/SKILL.md383### Step 6: API Compatibility AuditCOMMENT
LOW.agents/skills/upgrade-deps/SKILL.md466### Step 7: Run Pre-CommitCOMMENT
LOW.agents/skills/upgrade-deps/SKILL.md472### Step 8: Generate Upgrade SummaryCOMMENT
LOW.agents/skills/upgrade-deps/SKILL.md523### Step 9: Create PR and Trigger CI (Optional)COMMENT
LOW.agents/skills/add-reward/SKILL.md20### Step 1: Create Reward FileCOMMENT
LOW.agents/skills/add-reward/SKILL.md80### Step 2: Register in __init__.pyCOMMENT
LOW.agents/skills/add-reward/SKILL.md99### Step 3: Handle Blocking OperationsCOMMENT
LOW.agents/skills/add-reward/SKILL.md114### Step 4: Add TestsCOMMENT
LOW.agents/skills/add-dataset/SKILL.md20### Step 1: Create Dataset FileCOMMENT
LOW.agents/skills/add-dataset/SKILL.md107### Step 2: Register in __init__.pyCOMMENT
LOW.agents/skills/add-dataset/SKILL.md129### Step 3: Add Config (Optional)COMMENT
LOW.agents/skills/add-dataset/SKILL.md140### Step 4: Add TestsCOMMENT
185 more matches not shown…
Cross-File Repetition69 hits · 345 pts
SeverityFileLineSnippetContext
HIGH.opencode/skills/add-reward/SKILL.md0compute reward for a single completion. args: prompt: prompt string completions: completion string (model output) promptSTRING
HIGH.agents/skills/add-reward/SKILL.md0compute reward for a single completion. args: prompt: prompt string completions: completion string (model output) promptSTRING
HIGH.claude/skills/add-reward/SKILL.md0compute reward for a single completion. args: prompt: prompt string completions: completion string (model output) promptSTRING
HIGH.opencode/skills/add-reward/SKILL.md0extract the answer from a completion string. implement your extraction logic here.STRING
HIGH.agents/skills/add-reward/SKILL.md0extract the answer from a completion string. implement your extraction logic here.STRING
HIGH.claude/skills/add-reward/SKILL.md0extract the answer from a completion string. implement your extraction logic here.STRING
HIGH.opencode/skills/add-dataset/SKILL.md0load dataset for sft training. args: path: path to dataset (huggingface hub or local path) split: dataset split (train/vSTRING
HIGH.agents/skills/add-dataset/SKILL.md0load dataset for sft training. args: path: path to dataset (huggingface hub or local path) split: dataset split (train/vSTRING
HIGH.claude/skills/add-dataset/SKILL.md0load dataset for sft training. args: path: path to dataset (huggingface hub or local path) split: dataset split (train/vSTRING
HIGH.opencode/skills/add-dataset/SKILL.md0load dataset for rl training. args: path: path to dataset split: dataset split tokenizer: tokenizer for length filteringSTRING
HIGH.agents/skills/add-dataset/SKILL.md0load dataset for rl training. args: path: path to dataset split: dataset split tokenizer: tokenizer for length filteringSTRING
HIGH.claude/skills/add-dataset/SKILL.md0load dataset for rl training. args: path: path to dataset split: dataset split tokenizer: tokenizer for length filteringSTRING
HIGH.opencode/skills/add-workflow/SKILL.md0run a single episode. must be async and non-blocking.STRING
HIGH.agents/skills/add-workflow/SKILL.md0run a single episode. must be async and non-blocking.STRING
HIGH.claude/skills/add-workflow/SKILL.md0run a single episode. must be async and non-blocking.STRING
HIGH.opencode/skills/add-unit-tests/SKILL.md0test that function returns expected value under condition.STRING
HIGH.agents/skills/add-unit-tests/SKILL.md0test that function returns expected value under condition.STRING
HIGH.claude/skills/add-unit-tests/SKILL.md0test that function returns expected value under condition.STRING
HIGHtests/test_train_engine.py0create mock padded input data (same format for huggingface) for testing. returns a dict with input_ids, attention_mask, STRING
HIGHtests/test_megatron_engine.py0create mock padded input data (same format for huggingface) for testing. returns a dict with input_ids, attention_mask, STRING
HIGHtests/torchrun/run_megatron_engine_distributed.py0create mock padded input data (same format for huggingface) for testing. returns a dict with input_ids, attention_mask, STRING
HIGHtests/torchrun/run_fsdp_ulysses_forward.py0create mock padded input data (same format for huggingface) for testing. returns a dict with input_ids, attention_mask, STRING
HIGHtests/torchrun/run_fsdp_ulysses_train_batch.py0create 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.py0mock arealopenai client that returns a valid chatcompletion.STRING
HIGHtests/v2/inference_service/test_data_proxy_version.py0mock arealopenai client that returns a valid chatcompletion.STRING
HIGHtests/v2/inference_service/test_data_proxy_pause.py0mock arealopenai client that returns a valid chatcompletion.STRING
HIGHareal/experimental/engine/archon_engine.py0drain this worker's client-side rtensor fetch buffer. called via rpc by ``traincontroller.clear_batches`` at step end soSTRING
HIGHareal/engine/fsdp_engine.py0drain this worker's client-side rtensor fetch buffer. called via rpc by ``traincontroller.clear_batches`` at step end soSTRING
HIGHareal/engine/megatron_engine.py0drain this worker's client-side rtensor fetch buffer. called via rpc by ``traincontroller.clear_batches`` at step end soSTRING
HIGHareal/engine/sglang_remote.py0drain this worker's client-side rtensor fetch buffer. called via rpc by ``traincontroller.clear_batches`` at step end soSTRING
HIGHareal/engine/vllm_remote.py0drain this worker's client-side rtensor fetch buffer. called via rpc by ``traincontroller.clear_batches`` at step end soSTRING
HIGHareal/experimental/engine/archon_engine.py0expose local fetch-buffer stats for post-step drain verification.STRING
HIGHareal/engine/fsdp_engine.py0expose local fetch-buffer stats for post-step drain verification.STRING
HIGHareal/engine/megatron_engine.py0expose local fetch-buffer stats for post-step drain verification.STRING
HIGHareal/engine/sglang_remote.py0expose local fetch-buffer stats for post-step drain verification.STRING
HIGHareal/engine/vllm_remote.py0expose local fetch-buffer stats for post-step drain verification.STRING
HIGHareal/experimental/engine/archon_engine.py0temporarily onload parameters for offload-unsafe operations. reentrant: nested calls increment depth; only the outermostSTRING
HIGHareal/engine/fsdp_engine.py0temporarily onload parameters for offload-unsafe operations. reentrant: nested calls increment depth; only the outermostSTRING
HIGHareal/engine/megatron_engine.py0temporarily onload parameters for offload-unsafe operations. reentrant: nested calls increment depth; only the outermostSTRING
HIGHareal/experimental/openai/client.py0set reward for a specific completion/response by its id.STRING
HIGHareal/experimental/openai/cache.py0set reward for a specific completion/response by its id.STRING
HIGHareal/experimental/openai/proxy/client_session.py0set reward for a specific completion/response by its id.STRING
HIGHareal/experimental/openai/client.py0set reward for the most recent completion/response.STRING
HIGHareal/experimental/openai/cache.py0set reward for the most recent completion/response.STRING
HIGHareal/experimental/openai/proxy/client_session.py0set reward for the most recent completion/response.STRING
HIGHareal/infra/scheduler/slurm.py0fork a single worker asynchronously. parameters ---------- command : str, optional custom module path to run instead of STRING
HIGHareal/infra/scheduler/local.py0fork a single worker asynchronously. parameters ---------- command : str, optional custom module path to run instead of STRING
HIGHareal/infra/scheduler/ray.py0fork a single worker asynchronously. parameters ---------- command : str, optional custom module path to run instead of STRING
HIGHareal/infra/scheduler/slurm.py0kill a single forked worker via its parent's rpc server.STRING
HIGHareal/infra/scheduler/local.py0kill a single forked worker via its parent's rpc server.STRING
HIGHareal/infra/scheduler/ray.py0kill a single forked worker via its parent's rpc server.STRING
HIGHareal/infra/scheduler/slurm.py0cleanup forked workers by calling kill endpoint on parent workers.STRING
HIGHareal/infra/scheduler/local.py0cleanup forked workers by calling kill endpoint on parent workers.STRING
HIGHareal/infra/scheduler/ray.py0cleanup forked workers by calling kill endpoint on parent workers.STRING
HIGHareal/infra/scheduler/slurm.py0create forked workers concurrently using async requests. parameters ---------- command : str, optional custom module patSTRING
HIGHareal/infra/scheduler/local.py0create forked workers concurrently using async requests. parameters ---------- command : str, optional custom module patSTRING
HIGHareal/infra/scheduler/ray.py0create forked workers concurrently using async requests. parameters ---------- command : str, optional custom module patSTRING
HIGHareal/infra/scheduler/slurm.py0fork new worker processes from existing workers. creates new worker processes by forking from existing workers of the taSTRING
HIGHareal/infra/scheduler/local.py0fork new worker processes from existing workers. creates new worker processes by forking from existing workers of the taSTRING
HIGHareal/infra/scheduler/ray.py0fork new worker processes from existing workers. creates new worker processes by forking from existing workers of the taSTRING
9 more matches not shown…
Deep Nesting347 hits · 290 pts
SeverityFileLineSnippetContext
LOWtests/test_train_controller.py78CODE
LOWtests/test_tree_training.py108CODE
LOWtests/test_tree_training.py134CODE
LOWtests/test_vlm_sft_dataset.py19CODE
LOWtests/test_allocation_mode.py203CODE
LOWtests/test_training_diagnostics_distributed.py17CODE
LOWtests/test_broadcast_tensor_container.py58CODE
LOWtests/test_rollout_controller.py90CODE
LOWtests/test_rollout_controller.py678CODE
LOWtests/test_swe_arena_multi_stream.py1348CODE
LOWtests/test_local_scheduler.py2031CODE
LOWtests/test_local_scheduler.py2243CODE
LOWtests/test_local_scheduler.py2364CODE
LOWtests/test_local_scheduler.py2491CODE
LOWtests/test_packed_vs_padded_consistency.py132CODE
LOWtests/test_packed_vs_padded_consistency.py230CODE
LOWtests/test_sglang_pp_distributed.py77CODE
LOWtests/test_fsdp_transport.py59CODE
LOWtests/test_examples.py26CODE
LOWtests/test_examples.py935CODE
LOWtests/test_examples.py952CODE
LOWtests/test_eval_rtensor_cleanup.py195CODE
LOWtests/experimental/archon/test_weight_sync.py263CODE
LOWtests/experimental/archon/test_weight_sync.py440CODE
LOWtests/experimental/archon/test_forward.py300CODE
LOW…experimental/archon/torchrun/run_pp_gradient_verify.py308CODE
LOWtests/experimental/archon/torchrun/run_pp_tests.py251CODE
LOWtests/experimental/archon/torchrun/run_pp_tests.py277CODE
LOWtests/experimental/archon/torchrun/run_pp_tests.py321CODE
LOWtests/experimental/archon/torchrun/run_pp_tests.py569CODE
LOWtests/experimental/archon/torchrun/run_tp_forward.py110CODE
LOWtests/experimental/archon/torchrun/dist_utils.py155CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py620CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py810CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py1040CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py1233CODE
LOW…s/experimental/archon/torchrun/run_checkpoint_tests.py1405CODE
LOW…ts/experimental/archon/torchrun/run_pp_combinations.py465CODE
LOWtests/experimental/openai/test_vision_tensor_sharing.py45CODE
LOW…/experimental/openai/test_context_overflow_recovery.py572CODE
LOWtests/torchrun/run_fsdp_optimizer_dtype.py71CODE
LOWtests/torchrun/run_sglang_pp_weight_sync.py287CODE
LOWtests/torchrun/run_perf_tracer.py12CODE
LOWtests/torchrun/run_qwen_mtp_sft.py34CODE
LOWtests/torchrun/run_mopd_teacher_residency.py67CODE
LOWtests/torchrun/run_megatron_engine_distributed.py667CODE
LOWtests/torchrun/run_megatron_engine_vlm_distributed.py481CODE
LOW…/v2/weight_update/torchrun/run_nccl_weight_transfer.py123CODE
LOWtests/v2/inference_service/test_multimodal_processor.py102CODE
LOWtests/fp8/test_fp8_rmsnorm.py174CODE
LOWtests/fp8/test_fp8_rmsnorm.py281CODE
LOWtests/fp8/model_hooks.py102CODE
LOWtests/fp8/model_hooks.py216CODE
LOWtests/fp8/model_hooks.py266CODE
LOWtests/fp8/engine_utils.py35CODE
LOWtests/megatron/torchrun/run_grad_norm_tp.py56CODE
LOWdocs/generate_cli_docs.py38CODE
LOWdocs/generate_cli_docs.py143CODE
LOWdocs/generate_cli_docs.py186CODE
LOWexamples/tir/tools/python_tool.py120CODE
287 more matches not shown…
Verbosity Indicators103 hits · 190 pts
SeverityFileLineSnippetContext
LOW⚡tests/experimental/openai/test_proxy_gateway.py358 # Step 2: populate queue again for the post-refresh session.COMMENT
LOW⚡tests/experimental/openai/test_proxy_gateway.py368 # Step 3: refresh — same api_key triggers auto-end + new session.COMMENT
LOWtests/experimental/openai/test_proxy_gateway.py339 # Step 1: populate ready queue and start initial session.COMMENT
LOWtests/fp8/test_fp8_tensor.py409 # Step 1: View to 4DCOMMENT
LOWtests/fp8/test_fp8_tensor.py423 # Step 2: Split into Q, K, V along dim=1COMMENT
LOWtests/fp8/test_fp8_tensor.py451 # Step 3: Reshape to 2DCOMMENT
LOW⚡tests/fp8/model_hooks.py127 # Step 1: Prepare micro-batchesCOMMENT
LOW⚡tests/fp8/model_hooks.py130 # Step 2: Define loss functionsCOMMENT
LOW⚡tests/fp8/model_hooks.py157 # Step 3: Compute total loss weightCOMMENT
LOW⚡tests/fp8/model_hooks.py162 # Step 4: Forward-backward using Megatron's pipeline functionCOMMENT
LOWtests/fp8/model_hooks.py195 # Step 5: Collect gradients before optimizer.step()COMMENT
LOW⚡examples/countdown/countdown.py452 # Step 1: 1+2=3COMMENT
LOW⚡examples/countdown/countdown.py453 # Step 2: 3*3=9COMMENT
LOW⚡examples/countdown/countdown.py454 # Step 3: 9*3=27COMMENT
LOW⚡examples/countdown/countdown.py455 # Step 4: 27+3=30COMMENT
LOW⚡examples/countdown/countdown.py459 # Step 1: 24/2 = 12COMMENT
LOW⚡examples/countdown/countdown.py460 # Step 2: 12 + 2 = 14COMMENT
LOW⚡examples/scaffolding/controllers.py500 # Step 1: Run generation (yields task lists for worker execution)COMMENT
LOW⚡examples/scaffolding/controllers.py503 # Step 2: Create reward tasks and compute rewards locallyCOMMENT
LOW⚡…eal/experimental/models/archon/moe_weight_converter.py249 # Step 1: Store metadata for from_hf reconstructionCOMMENT
LOW⚡…eal/experimental/models/archon/moe_weight_converter.py255 # Step 2: Calculate local expert indices from placementsCOMMENT
LOW⚡…eal/experimental/models/archon/moe_weight_converter.py267 # Step 3: Store indices for from_hf reconstructionCOMMENT
LOW⚡…eal/experimental/models/archon/moe_weight_converter.py270 # Step 4: Create new placements for individual expert weights (2D)COMMENT
LOW…eal/experimental/models/archon/moe_weight_converter.py290 # Step 5: Extract local tensor and split into individual expertsCOMMENT
LOWareal/experimental/models/archon/expert_parallel.py129 # Step 1: Exchange token counts via all-to-allCOMMENT
LOW⚡areal/experimental/models/archon/expert_parallel.py162 # Step 2: All-to-all to dispatch tokensCOMMENT
LOW⚡areal/experimental/models/archon/expert_parallel.py170 # Step 3: Permute for grouped_mm alignmentCOMMENT
LOW⚡areal/experimental/models/archon/expert_parallel.py203 # Step 1: Unpermute to pre-permutation orderCOMMENT
LOW⚡areal/experimental/models/archon/expert_parallel.py206 # Step 2: All-to-all to combine (reverse direction)COMMENT
LOWareal/utils/save_load.py24 # Step 1: Identify if the input is a Hugging Face repo ID or local pathCOMMENT
LOW⚡areal/utils/save_load.py39 # Step 2: Download the repo if it's a Hugging Face repo IDCOMMENT
LOW⚡areal/utils/save_load.py47 # Step 3: Load all .safetensors and .bin filesCOMMENT
LOWareal/utils/data.py2199 # Step 1: Compute meanCOMMENT
LOWareal/utils/data.py2241 # Step 2: Compute stdCOMMENT
LOW⚡areal/utils/functional/vocab_parallel.py135 # Step 1: Numerical stability - subtract maxCOMMENT
LOW⚡areal/utils/functional/vocab_parallel.py142 # Step 2: Compute exp in-place and sum across all ranksCOMMENT
LOW⚡areal/utils/functional/vocab_parallel.py147 # Step 3: Get the logit value at labels positionCOMMENT
LOW⚡areal/utils/functional/vocab_parallel.py161 # Step 4: Compute log probabilityCOMMENT
LOW⚡areal/utils/functional/vocab_parallel.py165 # Step 5: Compute softmax in-place for backward (reuse exp_logits memory)COMMENT
LOW⚡areal/utils/functional/vocab_parallel.py265 # Step 1: Numerical stability - subtract max (shared)COMMENT
LOW⚡areal/utils/functional/vocab_parallel.py272 # Step 2: Compute exp and sum_exp (shared)COMMENT
LOW⚡areal/utils/functional/vocab_parallel.py278 # Step 3: Compute softmax in-place (shared)COMMENT
LOW⚡areal/utils/functional/vocab_parallel.py282 # Step 4: For logprobs - get labels logitCOMMENT
LOW⚡areal/utils/functional/vocab_parallel.py296 # Step 5: For entropy - compute sum(softmax * logits).COMMENT
LOW⚡areal/utils/functional/vocab_parallel.py304 # Step 6: Compute final resultsCOMMENT
LOWareal/utils/functional/vocab_parallel.py346 # Step 1: Compute entropy gradient contributionCOMMENT
LOWareal/utils/functional/vocab_parallel.py362 # Step 2: Add logprobs gradient contributionCOMMENT
LOWareal/utils/functional/functional.py212 # Step 0: Validate input shapes.COMMENT
LOW⚡areal/utils/functional/functional.py229 # Step 1: Compute log ratio = log(π_proximal / π_behave)COMMENT
LOW⚡areal/utils/functional/functional.py235 # Step 2: Compute metric value (reuse existing KLEstimator sign conventions)COMMENT
LOW⚡areal/utils/functional/functional.py262 # Step 3: Compute behave_imp_weight (needed for both modes)COMMENT
LOW⚡areal/utils/functional/functional.py267 # Step 4: Aggregate and filterCOMMENT
LOWareal/utils/functional/functional.py413 # Step 5: Update loss_mask or keep it based on action modeCOMMENT
LOWareal/models/transformers/vision_sp_shard.py291 # Step 1: Get image assignment based on patch countsCOMMENT
LOW⚡areal/models/transformers/vision_sp_shard.py310 # Step 2: Extract local inputs (use CPU grid_thw to avoid GPU→CPU syncsCOMMENT
LOW⚡areal/models/transformers/vision_sp_shard.py317 # Step 3: Process local imagesCOMMENT
LOW⚡areal/models/transformers/vision_sp_shard.py342 # Step 4: Unpack deepstack if present (Qwen3-VL returns (embeddings, list[Tensor]))COMMENT
LOW⚡areal/models/transformers/vision_sp_shard.py347 # Step 5: All-gather (contiguous assignment, no reordering needed)COMMENT
LOWareal/models/transformers/vision_sp_shard.py363 # Step 6: All-gather deepstack embeddings (all ranks must participate)COMMENT
LOW⚡areal/v2/training_service/controller/controller.py174 # Step 0: Create world_size guards via scheduler (one per GPU rank)COMMENT
43 more matches not shown…
Modern Structural Boilerplate166 hits · 162 pts
SeverityFileLineSnippetContext
LOWtests/test_staleness_manager.py24 def set_version(self, version: int) -> None:CODE
LOWtests/utils.py12__all__ = ["get_dataset_path", "get_model_path"]CODE
LOWtests/experimental/archon/utils.py34__all__ = [CODE
LOWtests/infra/data_service/test_trainer_compat.py16 def set_epoch(self, epoch: int) -> None:CODE
LOW⚡tests/torchrun/run_sglang_pp_weight_sync.py45logger = logging.getLogger(__name__)CODE
LOW⚡tests/v2/inference_service/test_data_proxy_pause.py142async def _set_paused(pause_state: PauseState, value: bool) -> None:CODE
LOWexamples/tir/tools/__init__.py18__all__ = [CODE
LOW…perimental/inference_service/human_in_the_loop_demo.py105def _set_reward(gateway_addr: str, api_key: str, reward: float) -> None:CODE
LOWexamples/scaffolding/__init__.py35__all__ = [CODE
LOWexamples/scaffolding/_compat.py36__all__ = [CODE
LOWexamples/scaffolding/core/controller.py16logger = logging.getLogger(__name__)CODE
LOWexamples/scaffolding/core/__init__.py36__all__ = [CODE
LOWexamples/terminal_bench/agent/__init__.py5__all__ = [CODE
LOWexamples/terminal_bench/workflow/__init__.py4__all__ = ["CamelRLVRWorkflow", "build_docker_image"]CODE
LOWareal/__init__.py32__all__ = [CODE
LOWareal/experimental/models/archon/model_spec.py131__all__ = [CODE
LOW…eal/experimental/models/archon/moe_weight_converter.py446__all__ = ["MoEConversionState", "MoEWeightConverter"]CODE
LOWareal/experimental/models/archon/ulysses.py18__all__ = [CODE
LOW…al/experimental/models/archon/activation_checkpoint.py310__all__ = [CODE
LOWareal/experimental/models/archon/__init__.py34__all__ = [CODE
LOWareal/experimental/models/archon/utils.py161__all__ = [CODE
LOWareal/experimental/models/archon/parallel_dims.py21__all__ = [CODE
LOWareal/experimental/models/archon/expert_parallel.py508__all__ = [CODE
LOWareal/experimental/models/archon/pipeline_parallel.py40__all__ = [CODE
LOWareal/experimental/models/archon/base.py168__all__ = [CODE
LOWareal/experimental/models/archon/attention/__init__.py7__all__ = [CODE
LOWareal/experimental/models/archon/attention/varlen.py13__all__ = ["varlen_attn", "VarlenAttentionWrapper"]CODE
LOWareal/experimental/models/archon/attention/varlen.py162def _setup_context(ctx: Any, inputs: tuple[Any, ...], output: Any) -> None:CODE
LOWareal/experimental/models/archon/attention/sdpa.py15__all__ = ["SDPAWrapper", "create_block_causal_mask_2d"]CODE
LOWareal/experimental/models/archon/qwen2/__init__.py12__all__ = [CODE
LOWareal/experimental/models/archon/qwen2/spec.py25__all__ = ["QWEN2_SPEC"]CODE
LOW…/experimental/models/archon/qwen2/infra/parallelize.py361__all__ = [CODE
LOWareal/experimental/models/archon/qwen2/model/model.py379__all__ = [CODE
LOWareal/experimental/models/archon/qwen2/model/rope.py155__all__ = [CODE
LOWareal/experimental/models/archon/qwen2/model/args.py70__all__ = ["Qwen2ModelArgs"]CODE
LOWareal/experimental/models/archon/qwen3/__init__.py12__all__ = [CODE
LOWareal/experimental/models/archon/qwen3/spec.py25__all__ = ["QWEN3_SPEC"]CODE
LOW…/experimental/models/archon/qwen3/infra/parallelize.py436def _setup_fsdp_prefetch(model: nn.Module) -> None:CODE
LOW…/experimental/models/archon/qwen3/infra/parallelize.py751__all__ = [CODE
LOWareal/experimental/models/archon/qwen3/model/model.py493__all__ = [CODE
LOWareal/experimental/models/archon/qwen3/model/rope.py12__all__ = [CODE
LOWareal/experimental/models/archon/qwen3/model/args.py111__all__ = ["Qwen3ModelArgs"]CODE
LOWareal/experimental/models/archon/qwen3_5/__init__.py12__all__ = [CODE
LOWareal/experimental/models/archon/qwen3_5/spec.py29__all__ = ["QWEN3_5_SPEC"]CODE
LOW…xperimental/models/archon/qwen3_5/infra/parallelize.py298__all__ = [CODE
LOWareal/experimental/models/archon/qwen3_5/model/model.py671__all__ = [CODE
LOWareal/experimental/models/archon/qwen3_5/model/rope.py149__all__ = [CODE
LOWareal/experimental/models/archon/qwen3_5/model/args.py182__all__ = ["Qwen3_5ModelArgs"]CODE
LOWareal/experimental/models/archon/moe/token_reorderer.py73__all__ = ["TokenReorderer"]CODE
LOWareal/experimental/models/archon/moe/__init__.py17__all__ = [CODE
LOWareal/experimental/models/archon/moe/grouped_experts.py288__all__ = ["GroupedExperts"]CODE
LOWareal/experimental/models/archon/moe/utils.py290__all__ = [CODE
LOWareal/experimental/models/archon/moe/kernels.py9__all__ = ["generate_permute_indices", "fill_indices_wrapper"]CODE
LOWareal/experimental/models/archon/moe/args.py109__all__ = ["MoEArgs"]CODE
LOWareal/experimental/models/archon/moe/router.py308__all__ = ["TokenChoiceTopKRouter"]CODE
LOWareal/experimental/models/archon/moe/moe.py269__all__ = ["MoE", "FeedForward"]CODE
LOWareal/experimental/engine/archon_weight_sync.py31logger = logging.getLogger(__name__)CODE
LOWareal/experimental/openai/client.py1903 def set_reward(self, id: str, reward: float) -> None:CODE
LOWareal/experimental/openai/client.py1909 def set_last_reward(self, reward: float) -> None:CODE
LOWareal/experimental/openai/cache.py89 def set_reward(self, interaction_id: str, reward: float) -> None:CODE
106 more matches not shown…
Docstring Block Structure19 hits · 95 pts
SeverityFileLineSnippetContext
HIGHareal/experimental/models/archon/fp8_checkpoint.py234Dequantize all FP8 weights in *hf_state_dict* to *target_dtype*. Detects FP8 weights by their ``float8_e4m3fn`` dtySTRING
HIGH…eal/experimental/models/archon/moe_weight_converter.py71Calculate start/end indices for [StridedShard(dim=i), Shard(dim=i)] placement. GPU Layout (strided_shard_rank, STRING
HIGHareal/experimental/models/archon/qwen3/model/model.py42Determine if a layer should use MoE instead of dense FFN. Args: layer_id: The layer index (0-based). STRING
HIGHareal/experimental/openai/client.py344Validate that ``value`` is a list of dictionaries or BaseModel objects. Args: name: Name of the argument beSTRING
HIGHareal/experimental/openai/client.py553Convert a Responses API input item into Chat Completions message dicts. Handles ``output_text``, ``input_text``, ``STRING
HIGHareal/infra/platforms/platform.py69Fallback attribute accessor for device-specific Torch modules. This method is called when the requested attributSTRING
HIGHareal/utils/seqpack.py168Return the allocation function for the given algorithm name. Args: algorithm: One of ``"ffd"`` or ``"kk"``.STRING
HIGHareal/utils/seqpack.py453Partition *values* into groups using the Karmarkar-Karp differencing method. This is a **drop-in replacement** for STRING
HIGHareal/utils/seqpack.py541 Splits `nums` into K groups such that the maximum difference between group sums is minimized. Returns indices STRING
HIGHareal/utils/name_resolve.py644Get the value for a key. Args: name: Key to retrieve Returns: The value as a sSTRING
HIGHareal/utils/name_resolve.py660Get a value with lock already acquired. Args: name: Key to retrieve Returns: TSTRING
HIGHareal/utils/name_resolve.py1057Get the value for a key. Args: name: Key to retrieve Returns: The value as a sSTRING
HIGHareal/utils/network.py13 Find the local IP address for outbound route to `probe_host:probe_port`. Args: probe_host: Remote addrSTRING
HIGHareal/utils/network.py140 Find multiple free ports within a specified range. Args: count: Number of free ports to find pSTRING
HIGHareal/api/alloc_mode.py1151Convert parsed result to _AllocationMode object. Args: result: Parsed result (list of ModelAllocatiSTRING
HIGHareal/engine/megatron_utils/fp8/config.py9Extract block size from quantization configuration. Args: quantization_config: Quantization configuration dSTRING
HIGHareal/engine/megatron_utils/fp8/tensor_helper.py313Convert Transformer Engine Float8BlockwiseQTensor to FP8BlockwiseTensorHelper. Args: tensor: TransfSTRING
HIGHareal/engine/fsdp_utils/optimizer.py20 Convert string to corresponding torch dtype, only supports bfloat16 and float32. Args: dtype_str: DataSTRING
HIGHareal/trainer/ppo/actor.py1462 Resolve the proximal policy log-probabilities based on the method. This function determines the final proximalSTRING
Redundant / Tautological Comments64 hits · 94 pts
SeverityFileLineSnippetContext
LOWtests/test_tree_training.py258 # Check if results match with detailed error reportingCOMMENT
LOWtests/test_tree_training.py456 # Check if gradients are close:COMMENT
LOW⚡tests/test_slurm_scheduler.py23# Check if 'srun' exists in the system PATHCOMMENT
LOWtests/test_fsdp_grad.py17# Check if CUDA is availableCOMMENT
LOWtests/test_local_scheduler.py2093 # Check if process diedCOMMENT
LOWtests/test_examples.py90 # Check if process has terminatedCOMMENT
LOWtests/experimental/archon/test_checkpoint_e2e.py391 # Check if weight tying is enabledCOMMENT
LOWtests/experimental/archon/test_qwen3_5.py891 # Set wq to output zeros for the gate half.COMMENT
LOWtests/experimental/openai/test_client_with_tool.py281 # Check if tool call was made (might depend on model capability)COMMENT
LOWtests/experimental/openai/test_client.py367 # Set rewards to leaf nodes only, which should be c_a1, c_a2, c_b1COMMENT
LOWtests/experimental/openai/test_client.py571 # Set rewards to leaf nodes only, which should be c_a1COMMENT
LOWtests/fp8/test_fp8_rmsnorm.py296 # Check if it's a combined file or individual fileCOMMENT
LOWtests/fp8/engine_utils.py69 # Check if this is a CUDA kernel eventCOMMENT
LOWtests/fp8/engine_utils.py81 # Check if this is a gemm-related kernelCOMMENT
LOWtests/fp8/engine_utils.py128 # Check if this is a gemm-related operation (may be at higher level)COMMENT
LOWtests/fp8/engine_utils.py130 # Check if we already have this in gemm_eventsCOMMENT
LOWtests/fp8/test_fp8_conversion.py81 # Check if tensor can be quantized (needs to satisfy block size requirements)COMMENT
LOW.claude/hooks/check-expert-update.sh5# Check if jq is availableCOMMENT
LOWdocs/generate_cli_docs.py147 # Check if it's a Union type (includes both Union[Type, None] and Type | None syntax)COMMENT
LOWdocs/generate_cli_docs.py150 # Check if it's a union with None (optional type)COMMENT
LOWexamples/tir/tir_workflow.py203 # Check if tool start marker is detectedCOMMENT
LOW⚡examples/countdown/reward_score.py31 # Check if all numbers in equation are availableCOMMENT
LOWexamples/terminal_bench/agent/chat_agent_trace.py94 # Check if we've reached max parse errorsSTRING
LOWexamples/terminal_bench/agent/chat_agent_trace.py217 # Check if this call is from a RegisteredAgentToolkit to prevent toolCOMMENT
LOWexamples/terminal_bench/agent/chat_agent_trace.py348 # Check if we've reached max parse errorsCOMMENT
LOW.github/workflows/build-docker-image.yml279 # Check if instance is runningCOMMENT
LOW.github/workflows/tag-release-image.yml217 # Check if instance is runningCOMMENT
LOWareal/experimental/models/archon/qwen3/model/args.py62 # Check if MoE is enabledCOMMENT
LOW…mental/models/archon/qwen3/model/state_dict_adapter.py465 # Check if all experts collectedCOMMENT
LOWareal/experimental/models/archon/qwen3_5/model/args.py118 # Check if MoE is enabledCOMMENT
LOWareal/experimental/openai/cache.py399 # Assign rewards to interactions in cache based on their creation orderCOMMENT
LOWareal/infra/async_task_runner.py522 # Check if thread is still aliveCOMMENT
LOWareal/infra/remote_inf_engine.py233 # Check if results are InteractionWithTokenLogpReward dictsCOMMENT
LOWareal/infra/remote_inf_engine.py904 # Check if it's a RolloutWorkflow classCOMMENT
LOWareal/infra/remote_inf_engine.py915 # Check if it's a RolloutWorkflow instanceCOMMENT
LOWareal/infra/workflow_executor.py169 # Check if all values are InteractionWithTokenLogpRewardCOMMENT
LOWareal/infra/scheduler/slurm.py1801 # Check if retryableCOMMENT
LOWareal/infra/scheduler/slurm.py1137 # Check if fork mode is enabledSTRING
LOWareal/infra/scheduler/local.py752 # Check if fork mode is enabledCOMMENT
LOWareal/infra/scheduler/local.py1743 # Check if worker died (forked workers have process=None)COMMENT
LOWareal/infra/scheduler/local.py1793 # Check if process has exited (forked workers have process=None)COMMENT
LOWareal/infra/scheduler/local.py1831 # Check if worker died (forked workers have process=None)COMMENT
LOWareal/infra/scheduler/ray.py1574 # Check if fork mode is enabledCOMMENT
LOWareal/infra/utils/concurrent.py71 # Check if we're already in an async contextCOMMENT
LOWareal/infra/utils/proc.py114 # Check if stdbuf is available (not present on macOS by default)COMMENT
LOWareal/tools/profile_fsdp.py383 # Print results - sorted by CUDA timeCOMMENT
LOWareal/tools/profile_archon.py341 # Print results - sorted by CUDA timeCOMMENT
LOWareal/dataset/swe_sft/messages.py396 # Check if current segment has any tool errorsCOMMENT
LOWareal/utils/fs.py80 # Check if path is on network filesystemCOMMENT
LOWareal/utils/name_resolve.py517 # Check if key exists when replace=FalseCOMMENT
LOWareal/utils/name_resolve.py764 # Check if this is a delete eventCOMMENT
LOWareal/utils/name_resolve.py821 # Check if key matches prefix (exact match or starts with prefix/)COMMENT
LOWareal/utils/name_resolve.py970 # Check if key exists when replace=FalseCOMMENT
LOWareal/utils/name_resolve.py1024 # Check if key existsCOMMENT
LOWareal/models/mcore/hf_load.py522 # Check if any HF weight is FP8 (has _scale_inv suffix)COMMENT
LOWareal/models/transformers/qwen3_vl.py109 # Check if hidden_states is a DTensor (TP is enabled)COMMENT
LOWareal/api/cli_args.py367 # Check if equal to the default valueCOMMENT
LOWareal/api/alloc_mode.py790 # Check if name is providedCOMMENT
LOWareal/engine/megatron_utils/megatron.py148 # Check if this param is truly NOT TP-sharded.COMMENT
LOWareal/engine/megatron_utils/fp8/tensor_helper.py171 # Check if dim 0 is one of the last two dimensionsCOMMENT
4 more matches not shown…
Self-Referential Comments26 hits · 74 pts
SeverityFileLineSnippetContext
MEDIUMtests/test_train_engine.py128 # Create the engine using from_pretrained method, without TrainEngineConfigCOMMENT
MEDIUMtests/test_rollout_controller.py36 # Create a mutable SchedulingSpec that can be modified by the controllerCOMMENT
MEDIUM⚡tests/experimental/archon/test_state_dict_adapter.py63 # Create a minimal HF state dictCOMMENT
MEDIUMtests/experimental/archon/test_weight_sync.py189 # Create a fake tensor with correct shape on CPUCOMMENT
MEDIUMtests/experimental/openai/test_proxy_integration.py234 # Create a sessionCOMMENT
MEDIUMtests/fp8/test_fp8_rmsnorm.py231 # Create a dummy loss (sum of output)COMMENT
MEDIUM⚡examples/countdown/reward_score.py44 # Define a regex pattern that only allows numbers, operators, parentheses, and whitespaceCOMMENT
MEDIUMexamples/scaffolding/worker.py201 # Create a workerSTRING
MEDIUMexamples/scaffolding/worker.py239 # Create an async OpenAI client pointing to the SGLang serverCOMMENT
MEDIUMexamples/terminal_bench/agent/chat_agent_trace.py131 # Create an error tool calling recordSTRING
MEDIUMexamples/terminal_bench/agent/chat_agent_trace.py144 # Create the error recordSTRING
MEDIUMareal/infra/remote_inf_engine.py1053 # Create a shallow copy of the input requestCOMMENT
MEDIUM⚡areal/infra/rpc/guard/engine_blueprint.py48# Define the constraintCOMMENT
MEDIUMareal/tools/plot_session_trace.py1020 # Create a separate figure for each rankCOMMENT
MEDIUMareal/tools/plot_session_trace.py1030 # Create a figure for this rankCOMMENT
MEDIUMareal/tools/validate_docker_installation.py202 # Create an FP8 recipeCOMMENT
MEDIUMareal/tools/validate_docker_installation.py223 # Create a simple model and optimizerCOMMENT
MEDIUMareal/utils/recover.py614 # This method is called by check_if_recover to check if the experiment shouldCOMMENT
MEDIUMareal/models/tree_attn/tree.py382 # Create an empty dummy trieCOMMENT
MEDIUMareal/models/tree_attn/tree.py773 # Create a minimal valid block mask for empty treesCOMMENT
MEDIUMareal/v2/inference_service/sglang/scheduler.py227 # Create a scheduler and run the event loopCOMMENT
MEDIUMareal/workflow/openai_agent/math_agent.py67 # Create the main orchestrator agent with handoffsCOMMENT
MEDIUMareal/api/reward_api.py47 """This function is a placeholder for the reward function that will be used in the RLVR pipeline.STRING
MEDIUMareal/engine/megatron_utils/fp8/__init__.py5# This module provides FP8 quantization and dequantization utilities forCOMMENT
MEDIUMareal/engine/megatron_utils/fp8/tensor_helper.py32 # Create a tensor subclass that wraps rowwise_dataCOMMENT
MEDIUMareal/trainer/rl_trainer.py1605 # Create a working copy of configCOMMENT
AI Structural Patterns66 hits · 57 pts
SeverityFileLineSnippetContext
LOWtests/test_rollout_controller.py987CODE
LOWtests/test_dte_topology_gating.py20CODE
LOWtests/experimental/archon/torchrun/dist_utils.py21CODE
LOWtests/experimental/archon/torchrun/dist_utils.py131CODE
LOWtests/experimental/openai/test_cache.py28CODE
LOWtests/v2/inference_service/test_inf_bridge.py63CODE
LOW.agents/skills/review-pr/sync_review_pr_refs.py48CODE
LOWexamples/tir/tir_workflow.py273CODE
LOWexamples/tir/tools/daytona_python_tool.py74CODE
LOWexamples/terminal_bench/agent/camel_terminal_agent.py38CODE
LOWexamples/terminal_bench/workflow/camel_rlvr_workflow.py25CODE
LOWexamples/swe/arena_preflight.py233CODE
LOWexamples/swe/arena_preflight.py266CODE
LOWareal/experimental/camel/openai_model.py194CODE
LOWareal/experimental/models/archon/expert_parallel.py214CODE
LOW…/experimental/models/archon/qwen3/infra/parallelize.py302CODE
LOWareal/experimental/models/archon/moe/utils.py248CODE
LOWareal/experimental/models/archon/moe/utils.py285CODE
LOWareal/experimental/engine/archon_engine.py733CODE
LOWareal/experimental/openai/client.py997CODE
LOWareal/experimental/openai/client.py1024CODE
LOWareal/experimental/openai/client.py1050CODE
LOWareal/experimental/openai/client.py1539CODE
LOWareal/experimental/openai/proxy/workflow.py110CODE
LOWareal/infra/dist_rollout.py324CODE
LOWareal/infra/remote_inf_engine.py1223CODE
LOWareal/infra/remote_inf_engine.py1362CODE
LOWareal/infra/remote_inf_engine.py1529CODE
LOWareal/infra/scheduler/slurm.py138CODE
LOWareal/infra/scheduler/local.py112CODE
LOWareal/infra/scheduler/ray.py588CODE
LOWareal/infra/controller/rollout_controller.py1161CODE
LOWareal/infra/controller/rollout_controller.py1260CODE
LOWareal/infra/sandbox/runner.py103CODE
LOWareal/dataset/__init__.py65CODE
LOWareal/dataset/swe_sft/pipeline.py506CODE
LOWareal/dataset/swe_sft/pipeline.py609CODE
LOWareal/dataset/swe_sft/pipeline.py673CODE
LOWareal/models/mcore/kda_attention.py366CODE
LOWareal/models/mcore/kda_attention.py679CODE
LOWareal/models/mcore/vocab_parallel_head.py390CODE
LOWareal/models/mcore/lightning_attention.py151CODE
LOWareal/models/mcore/lightning_attention.py174CODE
LOWareal/models/mcore/lightning_attention.py375CODE
LOWareal/models/transformers/vision_sp_shard.py196CODE
LOWareal/v2/weight_update/nccl_group.py18CODE
LOWareal/v2/weight_update/controller/controller.py106CODE
LOWareal/v2/inference_service/controller/controller.py1221CODE
LOWareal/v2/inference_service/controller/controller.py1351CODE
LOWareal/v2/inference_service/controller/workflow.py46CODE
LOWareal/api/engine_api.py240CODE
LOWareal/api/engine_api.py744CODE
LOWareal/api/engine_api.py907CODE
LOWareal/engine/fsdp_engine.py626CODE
LOWareal/engine/megatron_engine.py1171CODE
LOWareal/engine/sglang_remote.py665CODE
LOWareal/engine/sglang_remote.py742CODE
LOWareal/engine/vllm_remote.py431CODE
LOWareal/engine/vllm_remote.py508CODE
LOWareal/engine/core/distributed.py79CODE
6 more matches not shown…
Modern AI Meta-Vocabulary17 hits · 56 pts
SeverityFileLineSnippetContext
MEDIUMexamples/scaffolding/search_agent_controller.py152 # the SGLang context window.COMMENT
MEDIUM⚡examples/scaffolding/README.md63# Step 4: Create ScaffoldingLlm (orchestrates controllers with workers)COMMENT
MEDIUMexamples/scaffolding/core/worker.py2# Vendored from tensorrt_llm.scaffolding.workerCOMMENT
MEDIUMexamples/scaffolding/core/task.py2# Vendored from tensorrt_llm.scaffolding.taskCOMMENT
MEDIUM⚡examples/scaffolding/core/math_utils.py2# Vendored from tensorrt_llm.scaffolding.math_utilsCOMMENT
MEDIUMexamples/scaffolding/core/controller.py2# Vendored from tensorrt_llm.scaffolding.controllerCOMMENT
MEDIUMexamples/scaffolding/core/__init__.py2# Vendored from TensorRT-LLM scaffolding framework.COMMENT
MEDIUMexamples/scaffolding/core/__init__.py3# Core scaffolding primitives adapted for standalone use in AReaL.COMMENT
MEDIUMexamples/scaffolding/core/scaffolding_llm.py2# Vendored from tensorrt_llm.scaffolding.scaffolding_llmCOMMENT
MEDIUMexamples/scaffolding/core/result.py2# Vendored from tensorrt_llm.scaffolding.resultCOMMENT
MEDIUMexamples/scaffolding/core/task_collection.py2# Vendored from tensorrt_llm.scaffolding.task_collectionCOMMENT
MEDIUM⚡areal/experimental/openai/client.py632 # prompt + generation past the backend model's context window.COMMENT
MEDIUMareal/utils/logging.py34# - white: Controllers, RPC, Inference wrappers (orchestration)COMMENT
MEDIUMareal/utils/logging.py131 # Inference service - white (orchestration)COMMENT
MEDIUMareal/v2/weight_update/awex/delta_detect.py472 # orchestration offloads the optimizer to CPU; consumed (or discarded)COMMENT
MEDIUMareal/v2/cli/inference/client.py15# the scaffold names directly.COMMENT
MEDIUMareal/v2/inference_service/vllm/bridge.py37 # Compute effective max_new_tokens (cap by remaining context window)COMMENT
Cross-Language Confusion7 hits · 54 pts
SeverityFileLineSnippetContext
HIGH⚡tests/test_inference_targets.py87@pytest.mark.parametrize("contents", ["invalid JSON", "{}", '[null, {"labels": null}]'])CODE
HIGH⚡tests/test_adv_norm_config.py599 # With single element, unbiased std should return zero (undefined)COMMENT
HIGH⚡areal/infra/utils/slurm.py81 if kill -0 "$pid" 2>/dev/null; thenCODE
HIGH⚡areal/infra/utils/slurm.py83 kill "$pid" 2>/dev/null || trueCODE
HIGH⚡areal/infra/utils/slurm.py90 if kill -0 "$pid" 2>/dev/null; thenCODE
HIGH⚡areal/infra/utils/slurm.py91 kill -9 "$pid" 2>/dev/null || trueCODE
HIGHareal/infra/utils/slurm.py143 if ! kill -0 "$pid" 2>/dev/null; thenCODE
Over-Commented Block37 hits · 32 pts
SeverityFileLineSnippetContext
LOWpyproject.vllm.toml1# vLLM variant of the AReaL project configuration.COMMENT
LOWtests/test_megatron_engine_distributed.py301# bridge_type=megatron-bridge via the runner's override map; the padded BSHDCOMMENT
LOWtests/test_adv_norm_config.py1161COMMENT
LOWtests/experimental/archon/torchrun/run_cp_forward.py301 # Run with `torchrun --nproc_per_node=N` to test with multiple GPUsCOMMENT
LOWtests/torchrun/run_megatron_engine_distributed.py41# attention layers.COMMENT
LOWexamples/environ_ref.yaml21 NCCL_SET_THREAD_NAME: "1"COMMENT
LOWexamples/countdown/countdown.py441 type=str,COMMENT
LOW…/swe/qwen38_flash_next/sbatch_sft_qwen38_flash_next.sh1#!/usr/bin/env bashCOMMENT
LOW…lm/qwen3_5_2b_megatron_geometry3k_grpo_mtp_sglang.yaml1# Qwen3.5-2B GRPO on geometry3k with SGLang inference + MTP training.COMMENT
LOWexamples/search_agent/tongyi_deepresearch/prompt.py1# SYSTEM_PROMPT = """You are a deep research assistant. Your core function is to conduct thorough, multi-source investigCOMMENT
LOWexamples/search_agent/tongyi_deepresearch/prompt.py21# import numpy as npCOMMENT
LOWareal/infra/launcher/ray.py1001 # The 'force' is passed to ray.cancel(future, force=force).COMMENT
LOWareal/infra/launcher/ray.py1041 # usage: python -m areal.infra.launcher.ray \COMMENT
LOWareal/infra/platforms/platform.py41 # use "CPU" as a fallback for platforms not registered in PyTorchCOMMENT
LOWareal/infra/rpc/rtensor.py321 return _backendCOMMENT
LOWareal/infra/rpc/guard/engine_blueprint.py621 ),COMMENT
LOWareal/dataset/swe_sft/tokenization.py21COMMENT
LOWareal/dataset/swe_sft/messages.py221COMMENT
LOWareal/utils/logging.py21)COMMENT
LOWareal/utils/functional/vocab_parallel.py341 # Total gradient = grad_logprobs * (one_hot - softmax) + grad_entropy * softmax * (E[x] - x)COMMENT
LOWareal/models/mcore/bailing_moe.py101 qk_layernorm=True,COMMENT
LOWareal/models/mcore/hf_save.py281 # EP all-gather: stack local-merged on dim 0, all-gather, split.COMMENT
LOWareal/v2/inference_service/data_proxy/app.py1141 #COMMENT
LOWareal/api/cli_args.py2241 # values (True). Using no_enable_*=True correctly passes --no-enable-* flagsCOMMENT
LOWareal/engine/fsdp_engine.py541 self._per_layer_optim_wrapper = NoneCOMMENT
LOWareal/engine/megatron_engine.py661 self._apply_megatron_bridge_lora()COMMENT
LOWareal/engine/megatron_engine.py1201 # Colocate mode flow (mirrors the AWEX reference integration):COMMENT
LOWareal/engine/megatron_engine.py1701 )COMMENT
LOWareal/engine/megatron_engine.py2681 # NOTE: Processes launched with torchrun will set the following env var to True,COMMENT
LOWareal/engine/megatron_engine.py2761 else:COMMENT
LOWareal/engine/sglang_remote.py321 pp_size = gen_parallel.pp_sizeCOMMENT
LOWareal/engine/megatron_utils/checkpointer.py1# SPDX-License-Identifier: Apache-2.0COMMENT
LOWareal/engine/megatron_utils/checkpointer.py421 model = model.moduleCOMMENT
LOWareal/engine/megatron_utils/packed_context_parallel.py521 # `attention_mask`: dense torch.Tensor (flex attention with Megatron) or None.COMMENT
LOWareal/engine/megatron_utils/fp8/__init__.py1# SPDX-License-Identifier: Apache-2.0COMMENT
LOWareal/engine/awex/colocate_writer.py361 # peer mappings closed after our last collect (belt-and-braces with theCOMMENT
LOWareal/engine/awex/colocate_writer.py401 # convert_param returns the ORIGINAL tensor (shared storage)COMMENT
AI Slop Vocabulary9 hits · 21 pts
SeverityFileLineSnippetContext
MEDIUMtests/test_math_verify_reward.py523 """Advanced LaTeX formula tests for robust mathematical notation."""STRING
MEDIUMtests/experimental/archon/torchrun/run_cp_forward.py259 # Use cosine similarity for comparison (more robust to numerical errors)COMMENT
MEDIUMexamples/swe/qwen38_flash_next/train_rl.py191 # Training pauses can outlast the harness default. Evaluation keeps itsCOMMENT
MEDIUMexamples/search_agent/tongyi_deepresearch/prompt.py1# SYSTEM_PROMPT = """You are a deep research assistant. Your core function is to conduct thorough, multi-source investigCOMMENT
MEDIUMexamples/search_agent/tongyi_deepresearch/prompt.py1# SYSTEM_PROMPT = """You are a deep research assistant. Your core function is to conduct thorough, multi-source investigCOMMENT
MEDIUMexamples/search_agent/tongyi_deepresearch/prompt.py38SYSTEM_PROMPT = """You are a deep research assistant. Your core function is to conduct thorough, multi-source investigatCODE
LOWareal/tools/perf_trace_converter.py919 # Replace .jsonl extension with .json, or just add .jsonCOMMENT
MEDIUM⚡areal/utils/seqpack.py387 """Compute comprehensive packing quality metrics for a given partition.STRING
MEDIUMareal/v2/agent_service/worker/app.py127 # Validate outside the harness so caught emitter errors cannotCOMMENT
Magic Placeholder Names2 hits · 10 pts
SeverityFileLineSnippetContext
HIGHdocs/zh/best_practices/debugging.md72asyncio.run(MyAgent().run(data, base_url="https://api.openai.com/v1", api_key="YOUR_API_KEY"))CODE
HIGHdocs/en/best_practices/debugging.md79asyncio.run(MyAgent().run(data, base_url="https://api.openai.com/v1", api_key="YOUR_API_KEY"))CODE
Fake / Example Data13 hits · 8 pts
SeverityFileLineSnippetContext
LOWtests/v2/inference_service/test_inf_bridge.py605 "image_url": {"url": "placeholder"},CODE
LOWtests/v2/inference_service/test_image_input.py101 assert vllm_content[1]["image_url"]["url"] == "placeholder"CODE
LOWtests/v2/inference_service/test_image_input.py371 "image_url": {"url": "placeholder"},CODE
LOWtests/v2/inference_service/test_image_input.py408 {"type": "image_url", "image_url": {"url": "placeholder"}},CODE
LOWtests/v2/inference_service/test_image_input.py409 {"type": "image_url", "image_url": {"url": "placeholder"}},CODE
LOWtests/v2/inference_service/test_image_input.py446 {"type": "image_url", "image_url": {"url": "placeholder"}},CODE
LOWtests/v2/inference_service/test_image_input.py447 {"type": "image_url", "image_url": {"url": "placeholder"}},CODE
LOWtests/v2/inference_service/test_image_input.py479 {"type": "image_url", "image_url": {"url": "placeholder"}},CODE
LOWtests/v2/inference_service/test_image_input.py1086 {"type": "image_url", "image_url": {"url": "placeholder"}}CODE
LOW⚡tests/v2/inference_service/test_data_proxy_chat.py631 headers={"Authorization": "Bearer fake-key"},CODE
LOWexamples/profile/README.md79The fake-data generator in `train_sft_profile.py` follows three rules:CODE
LOWexamples/profile/train_sft_profile.py97 """SFT config extended with profile fake-data options."""STRING
LOWareal/experimental/openai/client.py480 "image_url": {"url": "placeholder"},CODE
Overly Generic Function Names5 hits · 4 pts
SeverityFileLineSnippetContext
LOWtests/test_swe_arena.py1340 async def run_task() -> float:CODE
LOWexamples/scaffolding/core/worker.py21 async def run_task(self, task: Task) -> TaskStatus:CODE
LOWareal/v2/agent_service/gateway/bridge.py34 async def handle_request(self, request: Request) -> Any: ...CODE
LOWareal/v2/agent_service/gateway/bridge.py48 async def handle_request(self, request: Request) -> Any:CODE
LOWareal/v2/agent_service/gateway/bridge.py336 async def handle_request(self, request: Request) -> Any:CODE
Example Usage Blocks3 hits · 4 pts
SeverityFileLineSnippetContext
LOWexamples/vlm/qwen3_6_27b_geometry3k_grpo.yaml3# Usage:COMMENT
LOWexamples/vlm/qwen3_6_35b_a3b_geometry3k_grpo.yaml3# Usage:COMMENT
LOWscripts/uv_sync.sh4# Usage:COMMENT
TODO Padding1 hit · 1 pts
SeverityFileLineSnippetContext
LOWareal/models/mcore/registry.py634 share_embeddings_and_output_weights=False, # TODO: implement share output weightsCODE