Repository Analysis

marin-community/marin

Open-source framework for the research and development of foundation models.

18.3 Moderate AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of marin-community/marin, a Python project with 2,968 GitHub stars. SynthScan v2.0 examined 868,231 lines of code across 3399 source files, recording 12095 pattern matches distributed across 25 syntactic categories. The overall adjusted score of 18.3 places this repository in the Moderate 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).

18.3
Adjusted Score
18.3
Raw Score
100%
Time Factor
2026-08-29
Last Push
3.0K
Stars
Python
Language
868.2K
Lines of Code
3.4K
Files
12.1K
Pattern Hits
2026-08-29
Scan Date
0.06
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

Longitudinal tracking requires multiple scan runs. Once this repository is re-scanned after new commits land, this chart will visualise how the synthetic code signal evolves over time — enabling you to detect whether AI authorship is growing, stabilising, or being actively corrected by human engineers.

No multi-scan history yet — run the scanner again to build trend data.

Severity Breakdown

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.

CRITICAL 3HIGH 195MEDIUM 1419LOW 10478

Directory Score Breakdown

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.

Pattern Findings

The scanner identified 12095 distinct pattern matches across 25 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.

Hyper-Verbose Identifiers7738 hits · 7330 pts
SeverityFileLineSnippetContext
LOWinfra/pre-commit.py471def check_trailing_whitespace(files: list[pathlib.Path], fix: bool) -> int:CODE
LOWinfra/pre-commit.py597def check_markdown_precommit_invocation(files: list[pathlib.Path], fix: bool) -> int:CODE
LOWinfra/pre-commit.py664def _should_skip_skill_reference(reference: str) -> bool:CODE
LOWinfra/mkdocs_hooks.py13def _lower_external_inventory_failure(record: logging.LogRecord) -> bool:CODE
LOWinfra/check_docs_source_links.py73def _iter_relative_check_files() -> list[Path]:CODE
LOWinfra/lint/prose.md53def reconcile_workers_via_reconcile(...): ... # stutter; just reconcile_workers.CODE
LOWinfra/lint/cruft.md143def reconcile_request_from_plan(plan): ... # new-wire builderCODE
LOWinfra/lint/cruft.md144def legacy_translator_request(plan): ... # old-wire builder from same plan.request.desiredCODE
LOWinfra/lint/cruft.md252def test_build_launch_command():CODE
LOWinfra/lint/cruft.md260def test_make_runner_returns_runner():CODE
LOWinfra/echo/hybrid_search.py114def full_text_score_expression(alias: str) -> str:STRING
LOWinfra/echo/hybrid_search.py142def repository_file_search_statement(targets: Sequence[RepositoryTarget]) -> sqlalchemy.TextClause:STRING
LOWinfra/echo/test_repository_identity.py11def test_same_path_references_are_distinct_and_round_trip():CODE
LOWinfra/echo/test_repository_identity.py34def test_file_identity_rejects_unqualified_or_unconfigured_targets(value):CODE
LOWinfra/echo/test_repository_files.py12def test_indexed_file_rejects_generated_vendored_secret_binary_and_oversized_content():CODE
LOWinfra/echo/test_repository_files.py40def test_text_chunks_cover_long_files_with_bounded_overlap():CODE
LOWinfra/echo/test_search_benchmark.py27def test_query_metrics_matches_github_comments_to_their_canonical_artifact():CODE
LOWinfra/echo/test_search_benchmark.py62def test_evaluation_measures_ranked_relevance_and_no_answer_suppression(tmp_path):CODE
LOWinfra/echo/test_search_benchmark.py132def test_load_benchmark_rejects_duplicate_ids(tmp_path):CODE
LOWinfra/echo/test_search_benchmark.py148def test_file_judgments_require_repository_qualified_targets():CODE
LOWinfra/echo/repository_identity.py26def repository_file_reference(CODE
LOWinfra/echo/repository_identity.py47def stored_repository_file_reference(value: str) -> RepositoryFileReference:CODE
LOWinfra/echo/repository_identity.py59def configured_repository_target(repository: str) -> search_config.RepositoryTarget:CODE
LOWinfra/echo/test_repository_sync.py91def _current_activity_manifest(_token):CODE
LOWinfra/echo/test_repository_sync.py95def test_activity_corpus_reader_accepts_marinmirror_schema(tmp_path):CODE
LOWinfra/echo/test_repository_sync.py168def test_incremental_repository_files_fetches_only_eligible_changed_blobs():CODE
LOWinfra/echo/test_repository_sync.py217def test_large_github_comparison_requests_full_rebuild():CODE
LOWinfra/echo/test_repository_sync.py229def test_archive_repository_files_uses_repository_relative_safety_filters():CODE
LOWinfra/echo/test_repository_sync.py247def test_selected_repository_checks_head_even_if_recently_checked(monkeypatch):CODE
LOWinfra/echo/test_repository_sync.py265def test_repository_resume_keeps_only_files_missing_from_durable_checkpoint():CODE
LOWinfra/echo/test_repository_sync.py277def test_repository_turn_is_durable_across_failure_and_process_restart(monkeypatch):CODE
LOWinfra/echo/test_repository_sync.py301def test_repository_lock_loser_does_activity_but_does_not_consume_turn(monkeypatch):CODE
LOWinfra/echo/test_repository_sync.py316def test_activity_failure_prevents_repository_lock_and_turn(monkeypatch):CODE
LOWinfra/echo/test_search_replay.py12def test_replay_resumes_completed_cases_and_persists_each_execution(monkeypatch, tmp_path):CODE
LOWinfra/echo/test_search_replay.py69def test_replay_manifest_rejects_duplicate_normalized_queries(tmp_path):CODE
LOWinfra/echo/test_search_replay.py80def test_replay_retries_rate_limited_normal_search(monkeypatch):CODE
LOWinfra/echo/test_search_replay.py105def test_reconcile_recovers_matching_query_and_domains_once(tmp_path):CODE
LOWinfra/echo/test_search_replay.py131def test_quality_manifest_groups_observed_queries_and_defaults_no_answer_domains(tmp_path):CODE
LOWinfra/echo/test_okf.py23def test_parse_wiki_extracts_fields():STRING
LOWinfra/echo/test_okf.py31def test_parse_wiki_ignores_body_leading_heading():STRING
LOWinfra/echo/test_okf.py36def test_parse_requires_frontmatter():STRING
LOWinfra/echo/test_okf.py46def test_parse_wiki_reports_missing_fields():STRING
LOWinfra/echo/test_okf.py51def test_parse_wiki_rejects_scalar_tags():STRING
LOWinfra/echo/test_okf.py56def test_round_trip_through_okf():STRING
LOWinfra/echo/cli.py226def current_configured_repository() -> str:CODE
LOWinfra/echo/test_cli.py24def test_search_sends_selected_domains_to_federated_endpoint(monkeypatch, capsys):CODE
LOWinfra/echo/test_cli.py94def test_search_defaults_to_curated_domains_without_discord(monkeypatch):CODE
LOWinfra/echo/test_cli.py121def test_search_infers_configured_repository_from_contributor_fork(monkeypatch, tmp_path, capsys):CODE
LOWinfra/echo/test_cli.py145def test_search_explicit_repository_bypasses_checkout_inference(monkeypatch, tmp_path, repository):CODE
LOWinfra/echo/test_cli.py160def test_unscoped_file_search_fails_before_request_outside_supported_checkout(monkeypatch, tmp_path):CODE
LOWinfra/echo/test_cli.py179def test_search_without_file_domain_works_outside_git(monkeypatch, tmp_path):CODE
LOWinfra/echo/test_cli.py194def test_bearer_token_quiets_only_the_known_missing_email_scope_warning(monkeypatch, caplog):CODE
LOWinfra/echo/test_cli.py213def test_get_fetches_full_detail_by_search_result_id(monkeypatch):CODE
LOWinfra/echo/test_cli.py234def test_get_rejects_legacy_path_only_file_id():CODE
LOWinfra/echo/test_cli.py239def test_feedback_submits_replayable_grades_and_stdin_note(monkeypatch, capsys):CODE
LOWinfra/echo/test_cli.py280def test_feedback_links_execution_when_provided(monkeypatch):CODE
LOWinfra/echo/test_cli.py306def test_history_export_pages_in_stable_id_order(monkeypatch, capsys):CODE
LOWinfra/echo/api/app.py714def representative_file_lines(text: str, query: str, start_line: int) -> list[tuple[int, str]]:CODE
LOWinfra/echo/api/app.py750def default_feedback_result_metadata(result_id: str, config: EchoConfig) -> FeedbackResultMetadata:CODE
LOWinfra/echo/api/app.py821def validate_feedback_execution(CODE
7678 more matches not shown…
Decorative Section Separators1245 hits · 4331 pts
SeverityFileLineSnippetContext
MEDIUMinfra/ci/select_tests.py179# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py181# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py246# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py248# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py297# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py299# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py382# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py384# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py552# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py554# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py830# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/ci/select_tests.py832# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/codehealth/review_quality.py96# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/codehealth/review_quality.py98# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/codehealth/review_quality.py365# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/codehealth/review_quality.py367# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/codehealth/review_quality.py588# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/codehealth/review_quality.py590# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/codehealth/review_quality.py741# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/codehealth/review_quality.py743# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/codehealth/review_quality.py1099# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/codehealth/review_quality.py1101# ---------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/server.py124# --------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/server.py126# --------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/server.py501# --------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/server.py503# --------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/server.py752# --------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/server.py754# --------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/server.py794# --------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/server.py796# --------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/samples.py161# --------------------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/samples.py163# --------------------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/samples.py211# --------------------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/samples.py213# --------------------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/samples.py248# --------------------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/samples.py250# --------------------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/fixtures.py135# --------------------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/fixtures.py137# --------------------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/fixtures.py306# --------------------------------------------------------------------------------------------------COMMENT
MEDIUMinfra/evaldash/src/fixtures.py308# --------------------------------------------------------------------------------------------------COMMENT
MEDIUMexperiments/ferries/daily.py41# ---------------------------COMMENT
MEDIUMexperiments/ferries/daily.py43# ---------------------------COMMENT
MEDIUMexperiments/grug/recovery/minimal_wedge_repro.py50# --------------------------------------------------------------------------COMMENT
MEDIUMexperiments/grug/recovery/minimal_wedge_repro.py57# --------------------------------------------------------------------------COMMENT
MEDIUMexperiments/grug/recovery/minimal_wedge_repro.py106# --------------------------------------------------------------------------COMMENT
MEDIUMexperiments/grug/recovery/minimal_wedge_repro.py108# --------------------------------------------------------------------------COMMENT
MEDIUMexperiments/grug/recovery/minimal_wedge_repro.py191# --------------------------------------------------------------------------COMMENT
MEDIUMexperiments/grug/recovery/minimal_wedge_repro.py196# --------------------------------------------------------------------------COMMENT
MEDIUMexperiments/grug/recovery/minimal_wedge_repro.py242# --------------------------------------------------------------------------COMMENT
MEDIUMexperiments/grug/recovery/minimal_wedge_repro.py244# --------------------------------------------------------------------------COMMENT
MEDIUMexperiments/grug/recovery/minimal_wedge_repro.py269# --------------------------------------------------------------------------COMMENT
MEDIUMexperiments/grug/recovery/minimal_wedge_repro.py273# --------------------------------------------------------------------------COMMENT
MEDIUMexperiments/datakit/scripts/sync_datakit.py128# ----------------------------------------------------------------------COMMENT
MEDIUMexperiments/datakit/scripts/sync_datakit.py130# ----------------------------------------------------------------------COMMENT
MEDIUMexperiments/datakit/scripts/sync_datakit.py174# ----------------------------------------------------------------------COMMENT
MEDIUMexperiments/datakit/scripts/sync_datakit.py176# ----------------------------------------------------------------------COMMENT
MEDIUMexperiments/datakit/scripts/sync_datakit.py279# ----------------------------------------------------------------------COMMENT
MEDIUMexperiments/datakit/scripts/sync_datakit.py281# ----------------------------------------------------------------------COMMENT
MEDIUMexperiments/datakit/scripts/sync_datakit.py509# ----------------------------------------------------------------------COMMENT
MEDIUMexperiments/datakit/scripts/sync_datakit.py511# ----------------------------------------------------------------------COMMENT
1185 more matches not shown…
Unused Imports690 hits · 618 pts
SeverityFileLineSnippetContext
LOWinfra/grafana/src/grafana_migrations/__init__.py6CODE
LOWinfra/grafana/src/grafana_migrations/__init__.py6CODE
LOWinfra/evaldash/dev/screenshots.py20CODE
LOWinfra/evaldash/src/metrics.py17CODE
LOWinfra/evaldash/src/server.py32CODE
LOWinfra/evaldash/src/discovery.py11CODE
LOWinfra/evaldash/src/review.py17CODE
LOWinfra/evaldash/src/results_db.py11CODE
LOWinfra/evaldash/src/cluster.py14CODE
LOWinfra/evaldash/src/record_reconciliation.py6CODE
LOWinfra/evaldash/src/samples.py18CODE
LOWinfra/evaldash/src/fixtures.py19CODE
LOWinfra/loom/infrastructure.py6CODE
LOWinfra/loom/tests/test_infrastructure.py4CODE
LOWexperiments/post_training/iceball_micro.py28CODE
LOWexperiments/grug/__init__.py4CODE
LOWexperiments/grug/__init__.py4CODE
LOWexperiments/grug/moe_hero_ep/harrier_mix_2026_08_18.py14CODE
LOW…periments/grug/moe_hero_ep/harrier_mix_2026_08_17_1.py6CODE
LOWexperiments/grug/recovery/run_ablations.py21CODE
LOWexperiments/grug/recovery/config.py11CODE
LOWexperiments/grug/recovery/launch_wedge_supervised.py6CODE
LOWexperiments/grug/recovery/wedge_entrypoint.py24CODE
LOWexperiments/grug/recovery/train.py20CODE
LOWexperiments/grug/recovery/ablation_catalog.py6CODE
LOWexperiments/grug/recovery/minimal_wedge_repro.py42CODE
LOWexperiments/june_tpu_67b_a2b/dispatch.py4CODE
LOWexperiments/june_tpu_67b_a2b/checkpointing.py4CODE
LOWexperiments/june_tpu_67b_a2b/moe/train.py4CODE
LOWexperiments/evaluation/models.py6CODE
LOWexperiments/evaluation/evals.py6CODE
LOWexperiments/evaluation/launch.py6CODE
LOWexperiments/evaluation/cli.py11CODE
LOWexperiments/evaluation/pipeline.py23CODE
LOWexperiments/sft/prepare_checkpoint.py33CODE
LOWexperiments/sft/launcher.py65CODE
LOWexperiments/datakit/testbed/variants.py21CODE
LOWtests/cluster/evals/test_served_evalchemy.py18CODE
LOWtests/cluster/vllm/grug_training_oracle.py6CODE
LOWtests/cluster/sft/test_smoke_sft_tpu.py20CODE
LOWtests/post_training/test_iceball_micro.py4CODE
LOWtests/vllm/test_grugmoe_real_checkpoint_e2e.py10CODE
LOWtests/vllm/grugmoe_real_checkpoint_backend.py10CODE
LOWtests/evaluation/test_samples_v4_migration.py6CODE
LOWtests/evaluation/test_eval_archive.py6CODE
LOWtests/sft/test_prepare_checkpoint.py5CODE
LOWtests/sft/test_hf_to_levanter.py12CODE
LOWtests/rl/test_skyrl.py4CODE
LOW.agents/skills/noslop/scripts/scan_diff.py7CODE
LOW.github/actions/pulumi-preview/assemble_comment.py4CODE
LOW.github/actions/pulumi-preview/format_preview.py11CODE
LOWlib/iris/tests/test_jax_init.py4CODE
LOWlib/iris/tests/test_multigpu.py7CODE
LOWlib/iris/tests/test_nsys.py7CODE
LOWlib/iris/scripts/benchmark_controller.py71CODE
LOWlib/iris/src/iris/cluster/config.py18CODE
LOWlib/iris/src/iris/cluster/composer.py15CODE
LOWlib/iris/src/iris/cluster/runtime/__init__.py11CODE
LOWlib/iris/src/iris/cluster/runtime/__init__.py11CODE
LOWlib/iris/src/iris/cluster/runtime/__init__.py12CODE
630 more matches not shown…
Modern Structural Boilerplate543 hits · 555 pts
SeverityFileLineSnippetContext
LOWinfra/echo/api/app.py80logger = logging.getLogger(__name__)CODE
LOWinfra/ci/run_status.py18logger = logging.getLogger(__name__)CODE
LOWinfra/grafana/src/finelog_source.py23logger = logging.getLogger(__name__)CODE
LOWinfra/grafana/src/server.py136logger = logging.getLogger(__name__)CODE
LOWinfra/grafana/src/github_app.py24logger = logging.getLogger(__name__)CODE
LOWinfra/grafana/src/github_source.py26logger = logging.getLogger(__name__)CODE
LOWinfra/grafana/src/k8s_source.py50logger = logging.getLogger(__name__)CODE
LOWinfra/grafana/src/iris_source.py25logger = logging.getLogger(__name__)CODE
LOWinfra/grafana/src/loom_alerts.py33logger = logging.getLogger(__name__)CODE
LOWinfra/grafana/src/grafana_migrations/__main__.py17logger = logging.getLogger(__name__)CODE
LOWinfra/pulumi/src/iac/iris/deploy.py41logger = logging.getLogger(__name__)CODE
LOWinfra/evaldash/src/server.py92logger = logging.getLogger(__name__)CODE
LOWinfra/evaldash/src/server.py201 def _set_snapshot(self, records: list[EvalRunRecord]) -> None:CODE
LOWinfra/evaldash/src/server.py234 def set_model_archived(self, model_name: str, archived: bool, updated_by: str | None) -> None:CODE
LOWinfra/evaldash/src/server.py425 def set_catalog_error(self, error: str | None) -> None:CODE
LOWinfra/evaldash/src/server.py466 def set_model_archived(self, model_name: str, archived: bool, updated_by: str | None) -> None:CODE
LOWinfra/evaldash/src/server.py611 def _set_cycle_error(self, error: str | None) -> None:CODE
LOWinfra/evaldash/src/server.py725 def _set_cycle_error(self, error: str | None) -> None:CODE
LOWinfra/evaldash/src/review.py28logger = logging.getLogger(__name__)CODE
LOWinfra/evaldash/src/results_db.py44logger = logging.getLogger(__name__)CODE
LOWinfra/evaldash/src/results_db.py343def set_model_archived(engine: Engine, model_name: str, archived: bool, updated_by: str | None) -> None:CODE
LOWinfra/evaldash/src/cluster.py33logger = logging.getLogger(__name__)CODE
LOWinfra/evaldash/src/samples.py44logger = logging.getLogger(__name__)CODE
LOWinfra/cron/nightshift_cleanup.py18logger = logging.getLogger(__name__)CODE
LOWinfra/cron/nightshift_ci_tests.py22logger = logging.getLogger(__name__)CODE
LOWinfra/xprof/gateway.py29logger = logging.getLogger(__name__)CODE
LOWinfra/xprof/gateway.py75 def set_size(self, size: int) -> None:CODE
LOWinfra/xprof/server.py21logger = logging.getLogger(__name__)CODE
LOWexperiments/evals/federated_inference_proxy_demo.py41logger = logging.getLogger(__name__)CODE
LOWexperiments/post_training/iceball_micro.py78logger = logging.getLogger(__name__)CODE
LOWexperiments/ferries/grug_multislice_smoke.py41logger = logging.getLogger(__name__)CODE
LOWexperiments/ferries/datakit_tier2_skewed_ferry.py58logger = logging.getLogger(__name__)CODE
LOWexperiments/ferries/datakit_nemotron_ferry.py53logger = logging.getLogger(__name__)CODE
LOWexperiments/ferries/datakit_ferry.py49logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/dispatch.py17logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/__init__.py6__all__ = ["base", "moe"]CODE
LOWexperiments/grug/checkpointing.py18logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/moe_hero_ep/adamh.py100__all__ = ["ScaleByAdamHState", "scale_by_adamh"]CODE
LOWexperiments/grug/moe_hero_ep/model.py1480__all__ = [CODE
LOWexperiments/grug/moe_hero_ep/train.py63logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/moe_hero_ep/train.py1186__all__ = [CODE
LOWexperiments/grug/moe_hero_ep/optimizer.py224__all__ = [CODE
LOWexperiments/grug/moe_hero_ep/restore_benchmark.py72logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/moe_hero_fsdp/adamh.py78__all__ = ["ScaleByAdamHState", "scale_by_adamh"]CODE
LOWexperiments/grug/moe_hero_fsdp/model.py1217__all__ = [CODE
LOWexperiments/grug/moe_hero_fsdp/train.py58logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/moe_hero_fsdp/train.py823__all__ = [CODE
LOWexperiments/grug/moe_hero_fsdp/optimizer.py221__all__ = [CODE
LOWexperiments/grug/recovery/run_ablations.py38logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/recovery/launch_wedge_supervised.py32logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/recovery/wedge_entrypoint.py29logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/recovery/train.py53logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/moe/adamh.py78__all__ = ["ScaleByAdamHState", "scale_by_adamh"]CODE
LOWexperiments/grug/moe/model.py906__all__ = [CODE
LOWexperiments/grug/moe/train.py51logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/moe/train.py597__all__ = [CODE
LOWexperiments/grug/moe/optimizer.py310__all__ = [CODE
LOWexperiments/grug/base/model.py267__all__ = [CODE
LOWexperiments/grug/base/train.py57logger = logging.getLogger(__name__)CODE
LOWexperiments/grug/base/train.py660__all__ = [CODE
483 more matches not shown…
Excessive Try-Catch Wrapping502 hits · 532 pts
SeverityFileLineSnippetContext
LOWinfra/pre-commit.py374 except Exception:CODE
LOWinfra/pre-commit.py409 except Exception as e:CODE
LOWinfra/pre-commit.py416 except Exception as e:CODE
LOWinfra/pre-commit.py482 except Exception:CODE
LOWinfra/pre-commit.py532 except Exception:CODE
LOWinfra/pre-commit.py562 except Exception as e:CODE
LOWinfra/pre-commit.py609 except Exception:CODE
LOWinfra/pre-commit.py682 except Exception as e:CODE
LOWinfra/pre-commit.py716 except Exception as e:CODE
LOWinfra/pre-commit.py1035 except Exception as e:CODE
LOWinfra/linter.py295 except Exception:CODE
LOWinfra/lint/robustness.md89except Exception:CODE
LOWinfra/grafana/src/cache.py91 except Exception as error:CODE
LOWinfra/grafana/src/grafana_migrations/engine.py111 except Exception:CODE
LOWinfra/tpu-ci/setup.py369 except Exception as e:CODE
LOWinfra/tpu-ci/setup.py384 except Exception as e:CODE
LOWinfra/tpu-ci/setup.py552 except Exception as e:CODE
LOWinfra/tpu-ci/vm_manager.py408 except Exception as e:CODE
LOWinfra/tpu-ci/vm_manager.py455 except Exception as e:CODE
LOWinfra/tpu-ci/vm_manager.py465 except Exception as e:CODE
LOWinfra/tpu-ci/vm_manager.py482 except Exception as e:CODE
LOWinfra/tpu-ci/vm_manager.py547 except Exception as e:CODE
LOWinfra/evaldash/dev/screenshots.py106 except Exception:CODE
LOWinfra/evaldash/src/server.py521 except Exception as exc:CODE
LOWinfra/evaldash/src/server.py587 except Exception as exc:CODE
LOWinfra/evaldash/src/server.py698 except Exception as exc:CODE
LOWinfra/evaldash/src/review.py247 except Exception as exc:CODE
LOWinfra/evaldash/src/results_db.py265 except Exception:CODE
LOWinfra/evaldash/src/cluster.py118 except Exception as exc:CODE
LOWinfra/evaldash/src/cluster.py153 except Exception as exc:CODE
LOWinfra/evaldash/src/record_reconciliation.py88 except Exception as exc:CODE
LOWinfra/evaldash/src/record_reconciliation.py97 except Exception as exc:CODE
LOWinfra/evaldash/src/record_reconciliation.py124 except Exception as exc:CODE
LOWinfra/evaldash/src/samples.py264 except Exception as exc:CODE
LOWinfra/evaldash/src/samples.py346 except Exception as exc:CODE
LOWinfra/evaldash/src/samples.py436 except Exception as exc:CODE
LOWinfra/evaldash/src/samples.py492 except Exception as exc:CODE
LOWinfra/cron/nightshift_cleanup.py315 except Exception:CODE
LOWinfra/xprof/gateway.py216 except Exception:CODE
LOWinfra/xprof/gateway.py306 except Exception as exc:CODE
LOWexperiments/grug/checkpointing.py88 except Exception:CODE
LOWexperiments/grug/moe_hero_fsdp/sweep.py490 except Exception as exc:CODE
LOWexperiments/grug/recovery/minimal_wedge_repro.py406 except Exception as exc: # pragma: no coverCODE
LOWexperiments/benchmarks/fa4/tile_sweep.py307 except Exception as exc:CODE
LOWexperiments/june_tpu_67b_a2b/checkpointing.py64 except Exception:CODE
LOWexperiments/evaluation/cli.py55 except Exception as exc:CODE
LOWexperiments/datakit/cluster/domain/v0/sample.py183 except Exception:CODE
LOWexperiments/datakit/embeddings/harrier/tei.py220 except Exception:CODE
LOWexperiments/datakit/scripts/validate_ferry_outputs.py317 except Exception as exc:CODE
LOWexperiments/datakit/decontam/lmh_loader.py83 except Exception as exc:CODE
LOWexperiments/datakit/decontam/lmh_loader.py93 except Exception as exc:CODE
LOWexperiments/datakit/decontam/lmh_loader.py135 except Exception:CODE
LOWexperiments/datakit/decontam/prepare_eval_corpus.py356 except Exception:CODE
LOWexperiments/datakit/decontam/prepare_eval_corpus.py362 except Exception:CODE
LOWexperiments/datakit/decontam/prepare_eval_corpus.py746 except Exception as exc:CODE
LOWexperiments/datakit/decontam/prepare_eval_corpus.py789 except Exception as exc:CODE
LOWtests/test_utils.py40 except Exception as e:CODE
LOWtests/integration_test.py323 except Exception:CODE
LOW…tion/deduplication/resources/parser_variants/_utils.py51 except Exception:CODE
LOW…tion/deduplication/resources/parser_variants/_utils.py109 except Exception as e:CODE
442 more matches not shown…
Cross-Language Confusion93 hits · 509 pts
SeverityFileLineSnippetContext
HIGHinfra/tpu-ci/vm_manager.py145systemctl stop unattended-upgrades.service || trueCODE
HIGHinfra/tpu-ci/vm_manager.py146systemctl disable unattended-upgrades.service || trueCODE
HIGHinfra/tpu-ci/vm_manager.py147systemctl mask unattended-upgrades.service || trueCODE
HIGHinfra/tpu-ci/vm_manager.py148pkill -9 -f unattended-upgrade || trueCODE
HIGHinfra/tpu-ci/vm_manager.py149killall -9 apt apt-get || trueCODE
HIGHinfra/tpu-ci/vm_manager.py270 ./svc.sh stop || trueCODE
HIGHinfra/tpu-ci/vm_manager.py271 ./svc.sh uninstall || trueCODE
HIGHinfra/tpu-ci/vm_manager.py276 sudo -u $RUNNER_USER ./config.sh remove --token $REGISTRATION_TOKEN || trueCODE
HIGHinfra/tpu-ci/vm_manager.py621sudo journalctl -u google-startup-scripts.service -n {lines} --no-pager || echo "No startup script logs found"CODE
HIGHinfra/tpu-ci/vm_manager.py625grep "startup-script exit status" /var/log/syslog | tail -5 || echo "No completion marker found in syslog"CODE
HIGHinfra/tpu-ci/vm_manager.py631 cat ~/.docker/config.json | jq -r '.auths | keys[]' 2>/dev/null || echo "Unable to parse Docker auth config"CODE
HIGHinfra/tpu-ci/vm_manager.py664 -exec echo "{{}} ---" \\; -exec tail -n 50 {{}} \\; 2>/dev/null || trueCODE
HIGHinfra/tpu-ci/vm_manager.py669ps aux | grep -E "(Runner.Listener|Runner.Worker)" | grep -v grep || echo "No runner processes found"CODE
HIGHinfra/tpu-ci/vm_manager.py673sudo docker ps -a || trueCODE
HIGHinfra/tpu-ci/vm_manager.py165if ! command -v docker &> /dev/null; thenCODE
HIGHinfra/tpu-ci/vm_manager.py649sudo systemctl status actions.runner.* --no-pager || trueCODE
HIGHinfra/tpu-ci/vm_manager.py653sudo journalctl -u actions.runner.* -n {lines} --no-pager || trueCODE
HIGHinfra/tpu-ci/vm_manager.py775sudo rm -f /tmp/libtpu_lockfile || trueCODE
HIGHinfra/tpu-ci/vm_manager.py776sudo lsof -t /dev/vfio/* 2>/dev/null | xargs -r sudo kill -9 || trueCODE
HIGHinfra/ducky/__main__.py29DASHBOARD_BUILD = "cd lib/ducky/dashboard && { test -d node_modules || npm ci; } && npm run build"CODE
HIGHexperiments/june_tpu_67b_a2b/moe/sft_67b_a2b_2stage.py44 cd ~/Documents/marin && source secrets.env # or "$DC_AGENT_SECRET_ENV"STRING
HIGHexperiments/sft/launcher.py514 # for a mixture, where epoch semantics are undefined) and keeps the ``auto_build_caches`` path.COMMENT
HIGHexperiments/datakit/decontam/viewer/report.py53 var vals=[],idxs=[];parts.forEach(function(p,i){if(isTok[i]){vals.push(p);idxs.push(i)}});CODE
HIGHtests/execution/test_artifact.py243 '{"name": "datasets/x", "version": "v1", "fingerprint": "abc", "result": null}'CODE
HIGHscripts/iris/dev_tpu.py507uv sync --all-packages --extra=tpu --python=3.12 || trueCODE
HIGHscripts/ci/wait_for.py238_RECORD_JQ = '.[]|{id:.id,author:(.user.login//""),body:(.body//""),url:(.html_url//""),state:(.state//null)}'CODE
HIGHlib/iris/tests/cluster/backends/k8s/test_coreweave.py641 deleting them on stop would break a plain `iris cluster stop && iris cluster start`.STRING
HIGHlib/iris/tests/cluster/node_agent/test_kubernetes.py371 assert metrics["n1"] == NodeMetrics() # present but all-null, not droppedCODE
HIGHlib/iris/tests/e2e/gpu_gang_smoke.py527 "patch", "pod", pod, "-n", self.namespace, "--type=merge", "-p", '{"metadata":{"finalizers":null}}'CODE
HIGHlib/iris/tests/e2e/test_smoke.py900 return routeReady && loaded;CODE
HIGHlib/iris/src/iris/cluster/setup_scripts.py107 "if grep -q 'editable = true' pyproject.toml 2>/dev/null; then"CODE
HIGHlib/iris/src/iris/cluster/setup_scripts.py199 'cd "$IRIS_WORKDIR" 2>/dev/null || true\n'STRING
HIGHlib/iris/src/iris/cluster/platforms/vm_lifecycle.py137 f"sudo docker inspect --format='{{{{.State.Status}}}}' {container_name} 2>/dev/null || echo 'not_found'",CODE
HIGHlib/iris/src/iris/cluster/platforms/k8s/controller.py807 + f". Run: cd infra/pulumi && pulumi stack select {config.name} && pulumi up"CODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py39 sudo apt-get update -qq || trueCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py40 sudo apt-get install -y -qq sysstat || trueCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py43 sudo sed -i 's/^ENABLED="false"/ENABLED="true"/' /etc/default/sysstat || trueCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py44 sudo systemctl enable --now sysstat || trueCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py54if ! command -v docker &> /dev/null; thenCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py65sudo systemctl start docker || trueCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py76if command -v snap &> /dev/null; thenCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py77 timeout 300 snap wait system seed.loaded || echo "[iris-controller] Warning: snap seed wait timed out"CODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py104 if command -v gcloud &> /dev/null; thenCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py105 sudo gcloud auth configure-docker "$AR_HOST" -q || trueCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py133 sudo docker kill {{ container_name }} 2>/dev/null || trueCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py134 sudo docker rm {{ container_name }} 2>/dev/null || trueCODE
HIGH…src/iris/cluster/platforms/gcp/controller_bootstrap.py169 STATUS=$(sudo docker inspect --format='{{.State.Status}}' {{ container_name }} 2>/dev/null || echo 'unknown')CODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py199 --zone="$IRIS_TPU_ZONE" --format='value(state)' 2>/dev/null || true)CODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py218if ! command -v docker &> /dev/null; thenCODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py229sudo systemctl start docker || trueCODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py235if ! command -v runsc &> /dev/null; thenCODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py241 && (cd /usr/local/bin && sudo sha512sum -c /tmp/runsc.sha512); thenCODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py252if command -v runsc &> /dev/null && ! grep -q '"runsc"' /etc/docker/daemon.json 2>/dev/null; thenCODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py277if command -v snap &> /dev/null; thenCODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py278 timeout 300 snap wait system seed.loaded || echo "[iris-init] Warning: snap seed wait timed out"CODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py328 if command -v gcloud &> /dev/null; thenCODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py329 sudo gcloud auth configure-docker "$AR_HOST" -q || trueCODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py360sudo docker rm -f iris-worker 2>/dev/null || trueCODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py361sudo docker rm -f iris-node-agent 2>/dev/null || trueCODE
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py368if command -v nvidia-smi &> /dev/null && sudo docker info --format '{{json .Runtimes}}' | grep -q nvidia; thenCODE
33 more matches not shown…
Deep Nesting448 hits · 416 pts
SeverityFileLineSnippetContext
LOWinfra/pre-commit.py239CODE
LOWinfra/pre-commit.py358CODE
LOWinfra/pre-commit.py385CODE
LOWinfra/pre-commit.py471CODE
LOWinfra/pre-commit.py512CODE
LOWinfra/pre-commit.py544CODE
LOWinfra/pre-commit.py597CODE
LOWinfra/pre-commit.py670CODE
LOWinfra/linter.py447CODE
LOWinfra/check_docs_source_links.py48CODE
LOWinfra/echo/search_replay.py123CODE
LOWinfra/echo/api/app.py698CODE
LOWinfra/ci/select_tests.py218CODE
LOWinfra/ci/select_tests.py418CODE
LOWinfra/ci/select_tests.py507CODE
LOWinfra/ci/select_tests.py649CODE
LOWinfra/ci/analyze_import_graph.py218CODE
LOWinfra/grafana/tests/test_provisioning.py649CODE
LOWinfra/grafana/tests/test_provisioning.py797CODE
LOWinfra/grafana/src/github_source.py118CODE
LOWinfra/grafana/src/training_stalls.py152CODE
LOWinfra/grafana/src/nightly.py184CODE
LOWinfra/codehealth/complexity.py86CODE
LOWinfra/pulumi/iam_principal.py132CODE
LOWinfra/pulumi/src/iac/github/audit.py181CODE
LOWinfra/pulumi/src/iac/github/resources.py104CODE
LOWinfra/evaldash/dev/screenshots.py70CODE
LOWinfra/evaldash/src/server.py661CODE
LOWinfra/evaldash/src/review.py139CODE
LOWinfra/cron/nightshift_ci_tests.py186CODE
LOWinfra/cron/nightshift_ci_tests.py464CODE
LOWexperiments/marin_tokenizer.py200CODE
LOWexperiments/grug/moe_hero_ep/train.py815CODE
LOWexperiments/grug/moe_hero_fsdp/train.py486CODE
LOWexperiments/grug/recovery/launch_wedge_supervised.py58CODE
LOWexperiments/grug/recovery/train.py77CODE
LOWexperiments/grug/moe/train.py378CODE
LOWexperiments/grug/base/train.py420CODE
LOW…periments/references/reference_hyperparameter_sweep.py302CODE
LOWexperiments/june_tpu_67b_a2b/moe/train.py487CODE
LOWexperiments/tokenize/smoke_test_decon_filter_store.py67CODE
LOW…ents/datakit/cluster/quality/fast_transformer/train.py86CODE
LOWexperiments/datakit/testbed/sampler.py112CODE
LOW…periments/datakit/scripts/verify_fuzzy_dups_testbed.py144CODE
LOW…periments/datakit/scripts/verify_fuzzy_dups_testbed.py211CODE
LOW…periments/datakit/scripts/verify_fuzzy_dups_testbed.py296CODE
LOWexperiments/datakit/scripts/generate_tier2_skewed.py86CODE
LOWexperiments/datakit/scripts/sync_datakit.py211CODE
LOWexperiments/datakit/decontam/prepare_eval_corpus.py375CODE
LOWexperiments/datakit/decontam/prepare_eval_corpus.py407CODE
LOWexperiments/datakit/decontam/prepare_eval_corpus.py487CODE
LOWexperiments/datakit/decontam/prepare_eval_corpus.py698CODE
LOWexperiments/datakit/decontam/viewer/export_run.py68CODE
LOWexperiments/datakit/decontam/viewer/export_run.py142CODE
LOWexperiments/datakit/decontam/viewer/export_run.py171CODE
LOWexperiments/datakit/decontam/viewer/export_run.py202CODE
LOWexperiments/datakit/reports/common.py53CODE
LOWexperiments/datakit/store/datakit_store.py292CODE
LOWexperiments/datakit/store/datakit_store.py473CODE
LOWtests/test_integration_test.py59CODE
388 more matches not shown…
Over-Commented Block364 hits · 352 pts
SeverityFileLineSnippetContext
LOWpyproject.toml21 "marin-rigging[secrets]",COMMENT
LOWpyproject.toml41 # as marin-dupekit's runtime dependency. `scripts/rust_mode.py dev` swapsCOMMENT
LOWpyproject.toml201[tool.ruff.lint]COMMENT
LOWpyproject.toml401# pyrefly cannot prove safe.COMMENT
LOWinfra/echo/migrate.py1#!/usr/bin/env -S uv run --scriptCOMMENT
LOWinfra/ci/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWinfra/deploy/src/marin_deploy/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWinfra/grafana/Pulumi.marin-grafana.yaml1config:COMMENT
LOWinfra/grafana/entrypoint.sh1#!/bin/bashCOMMENT
LOWinfra/grafana/__main__.py41# The cloudsql stack (infra/cloudsql) publishes the marin-metadata connection name that backsCOMMENT
LOWinfra/grafana/tests/test_sources.py401 return httpx.Response(200, json={"data": {"project": {"run": run}}})COMMENT
LOWinfra/grafana/provisioning/datasources/finelog.yaml1# Copyright The Marin AuthorsCOMMENT
LOWinfra/grafana/provisioning/datasources/k8s.yaml1# Copyright The Marin AuthorsCOMMENT
LOWinfra/grafana/provisioning/alerting/rules.yaml1# Copyright The Marin AuthorsCOMMENT
LOWinfra/grafana/provisioning/alerting/contact-points.yaml1# Copyright The Marin AuthorsCOMMENT
LOWinfra/grafana/src/k8s_source.py101COMMENT
LOWinfra/grafana/src/k8s_source.py121# otherwise falls back to the runtime signature of exit 255, reason Error, and aCOMMENT
LOWinfra/tpu-ci/vm_manager.py1#!/usr/bin/env python3COMMENT
LOWinfra/tpu-ci/vm_manager.py421 logging.info(f"[{zone}] Found {len(vms)} TPU VMs")COMMENT
LOWinfra/pulumi/src/iac/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWinfra/pulumi/src/iac/iris/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWinfra/pulumi/src/iac/coreweave/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWinfra/pulumi/src/iac/gcp/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWinfra/pulumi/src/iac/gcp/iam_data.yaml1# Copyright The Marin AuthorsCOMMENT
LOWinfra/pulumi/src/iac/gcp/cloud_run.py81 # Direct VPC egress: the service dials cluster-internal IPs, so it needs an interfaceCOMMENT
LOWinfra/pulumi/src/iac/gcp/iam_config.py41 "serviceAccount:",COMMENT
LOWinfra/pulumi/src/iac/github/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWinfra/pulumi/src/iac/kubernetes/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWinfra/evaldash/src/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWconfig/external/migration.toml1# Fork migration descriptors.COMMENT
LOWconfig/external/migration.toml21# fork with more than one pin has one section per pin (the vllm fork has `vllm` and `vllm-gpu`).COMMENT
LOWexperiments/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/coral/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/evals/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/post_training/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/grug/moe_hero_ep/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/grug/moe_hero_ep/small_scale_abl_launch.py101# Kernel availability follows the accelerator, in two places. `gpu_fa4_cute` is Blackwell-only: itsCOMMENT
LOWexperiments/grug/moe_hero_ep/model.py61# h*v weight tile at ~99KB and cannot take v=4096.COMMENT
LOWexperiments/grug/moe_hero_ep/model.py501 # Both branches must agree on sharding, not just shape: `lax.cond` compares full typesCOMMENT
LOWexperiments/grug/moe_hero_ep/train.py81DEFAULT_COLLECTIVE_OVERLAP_LIMIT = 4COMMENT
LOWexperiments/grug/moe_hero_fsdp/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/grug/moe/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/grug/base/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/rollout_data/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/benchmarks/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/benchmarks/fa4/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/june_tpu_67b_a2b/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/june_tpu_67b_a2b/moe/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/june_tpu_67b_a2b/moe/sft_67b_a2b_2stage.py81# --- GPU mesh geometry (compute pivot 2026-07-16: CoreWeave cw-us-east-02a H100x8 nodes) ----------COMMENT
LOW…_d2560_cooldown_step39k_seq64k_bs1024_rep8_muon_10T.py81_SLICE: str = "v4-2048"COMMENT
LOWexperiments/datakit/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/datakit/cluster/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/datakit/cluster/quality/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOW…s/datakit/cluster/quality/fast_transformer/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/datakit/cluster/domain/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/datakit/cluster/domain/v0/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/datakit/embeddings/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/datakit/embeddings/harrier/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/datakit/embeddings/luxical/__init__.py1# Copyright The Marin AuthorsCOMMENT
LOWexperiments/datakit/embeddings/luxical/pipeline.py61# Immutable HF commit for the weights. Passed to ``hf_hub_download`` so every regionCOMMENT
304 more matches not shown…
Cross-File Repetition53 hits · 265 pts
SeverityFileLineSnippetContext
HIGHexperiments/grug/moe_hero_ep/model.py0moe grug variant model. architecture: qb-routed moe with gatednorm, xsa, sigmoid combine weights. no load-balancing lossSTRING
HIGHexperiments/grug/moe_hero_fsdp/model.py0moe grug variant model. architecture: qb-routed moe with gatednorm, xsa, sigmoid combine weights. no load-balancing lossSTRING
HIGHexperiments/grug/moe/model.py0moe grug variant model. architecture: qb-routed moe with gatednorm, xsa, sigmoid combine weights. no load-balancing lossSTRING
HIGHexperiments/june_tpu_67b_a2b/moe/model.py0moe grug variant model. architecture: qb-routed moe with gatednorm, xsa, sigmoid combine weights. no load-balancing lossSTRING
HIGHexperiments/grug/moe_hero_ep/model.py0per-block gradient checkpointing. "recompute_all" reruns the whole block in backward (lowest memory); "save_moe" keeps tSTRING
HIGHexperiments/grug/moe/model.py0per-block gradient checkpointing. "recompute_all" reruns the whole block in backward (lowest memory); "save_moe" keeps tSTRING
HIGHexperiments/june_tpu_67b_a2b/moe/model.py0per-block gradient checkpointing. "recompute_all" reruns the whole block in backward (lowest memory); "save_moe" keeps tSTRING
HIGHexperiments/grug/moe_hero_ep/model.py0learnable per-dimension gating. compensates for adamh's bounded activation norms. see https://arxiv.org/abs/2601.22966v1STRING
HIGHexperiments/grug/moe_hero_fsdp/model.py0learnable per-dimension gating. compensates for adamh's bounded activation norms. see https://arxiv.org/abs/2601.22966v1STRING
HIGHexperiments/grug/moe/model.py0learnable per-dimension gating. compensates for adamh's bounded activation norms. see https://arxiv.org/abs/2601.22966v1STRING
HIGHexperiments/june_tpu_67b_a2b/moe/model.py0learnable per-dimension gating. compensates for adamh's bounded activation norms. see https://arxiv.org/abs/2601.22966v1STRING
HIGHexperiments/grug/moe_hero_ep/model.py0return a small abstract mesh and token sharding for lowering contract tests.STRING
HIGHexperiments/grug/moe_hero_fsdp/model.py0return a small abstract mesh and token sharding for lowering contract tests.STRING
HIGHexperiments/grug/moe/model.py0return a small abstract mesh and token sharding for lowering contract tests.STRING
HIGHexperiments/grug/base/model.py0return a small abstract mesh and token sharding for lowering contract tests.STRING
HIGHexperiments/june_tpu_67b_a2b/moe/model.py0return a small abstract mesh and token sharding for lowering contract tests.STRING
HIGHexperiments/grug/moe_hero_ep/train.py0set router biases from qb betas (computed on previous step).STRING
HIGHexperiments/grug/moe_hero_fsdp/train.py0set router biases from qb betas (computed on previous step).STRING
HIGHexperiments/grug/moe/train.py0set router biases from qb betas (computed on previous step).STRING
HIGHexperiments/june_tpu_67b_a2b/moe/train.py0set router biases from qb betas (computed on previous step).STRING
HIGHexperiments/grug/moe_hero_ep/optimizer.py0restore named mesh sharding without touching single-device arrays.STRING
HIGHexperiments/grug/moe_hero_fsdp/optimizer.py0restore named mesh sharding without touching single-device arrays.STRING
HIGHexperiments/grug/moe/optimizer.py0restore named mesh sharding without touching single-device arrays.STRING
HIGHexperiments/june_tpu_67b_a2b/moe/optimizer.py0restore named mesh sharding without touching single-device arrays.STRING
HIGHexperiments/datasets/dolmino.py0dolma 1.7 dataset as lazy ``dataset`` handles (the flat dataset catalog). one handle per quality split, tokenizing each STRING
HIGHexperiments/datasets/nemotron.py0dolma 1.7 dataset as lazy ``dataset`` handles (the flat dataset catalog). one handle per quality split, tokenizing each STRING
HIGHexperiments/datasets/dolma.py0dolma 1.7 dataset as lazy ``dataset`` handles (the flat dataset catalog). one handle per quality split, tokenizing each STRING
HIGHtests/conftest.py0set marin_prefix to a temp directory for tests that rely on it.STRING
HIGHlib/levanter/tests/conftest.py0set marin_prefix to a temp directory for tests that rely on it.STRING
HIGHlib/zephyr/tests/conftest.py0set marin_prefix to a temp directory for tests that rely on it.STRING
HIGHlib/iris/src/iris/cluster/runtime/types.py0check container status (running, exit code, error).STRING
HIGHlib/iris/src/iris/cluster/runtime/docker.py0check container status (running, exit code, error).STRING
HIGHlib/iris/src/iris/cluster/runtime/process.py0check container status (running, exit code, error).STRING
HIGHlib/iris/src/iris/cluster/runtime/types.py0create an incremental log reader for this container.STRING
HIGHlib/iris/src/iris/cluster/runtime/docker.py0create an incremental log reader for this container.STRING
HIGHlib/iris/src/iris/cluster/runtime/process.py0create an incremental log reader for this container.STRING
HIGHlib/iris/src/iris/cluster/runtime/types.py0create a container handle from config. the handle is not started - call handle.build() then handle.run() to execute the STRING
HIGHlib/iris/src/iris/cluster/runtime/docker.py0create a container handle from config. the handle is not started - call handle.build() then handle.run() to execute the STRING
HIGHlib/iris/src/iris/cluster/runtime/process.py0create a container handle from config. the handle is not started - call handle.build() then handle.run() to execute the STRING
HIGHlib/iris/src/iris/rpc/controller_connect.py0returns the url path to mount the application to when serving multiple applications.STRING
HIGHlib/iris/src/iris/rpc/worker_connect.py0returns the url path to mount the application to when serving multiple applications.STRING
HIGHlib/iris/src/iris/rpc/actor_connect.py0returns the url path to mount the application to when serving multiple applications.STRING
HIGHlib/iris/src/iris/rpc/resource_connect.py0returns the url path to mount the application to when serving multiple applications.STRING
HIGHlib/finelog/src/finelog/rpc/logging_connect.py0returns the url path to mount the application to when serving multiple applications.STRING
HIGHlib/finelog/src/finelog/rpc/finelog_stats_connect.py0returns the url path to mount the application to when serving multiple applications.STRING
HIGHlib/levanter/src/levanter/models/mistral.py0args: input_ids (namedarray): [batch, position] indices of input sequence tokens in the vocabulary. attn_mask (union[namSTRING
HIGHlib/levanter/src/levanter/models/gemma.py0args: input_ids (namedarray): [batch, position] indices of input sequence tokens in the vocabulary. attn_mask (union[namSTRING
HIGHlib/levanter/src/levanter/models/mixtral.py0args: input_ids (namedarray): [batch, position] indices of input sequence tokens in the vocabulary. attn_mask (union[namSTRING
HIGHlib/levanter/src/levanter/models/llama.py0compute the activations for the next token in a sequence. args: input_ids: token ids with shape {pos} attn_mask: attentiSTRING
HIGHlib/levanter/src/levanter/models/qwen.py0compute the activations for the next token in a sequence. args: input_ids: token ids with shape {pos} attn_mask: attentiSTRING
HIGHlib/levanter/src/levanter/models/olmo.py0compute the activations for the next token in a sequence. args: input_ids: token ids with shape {pos} attn_mask: attentiSTRING
HIGHlib/levanter/src/levanter/models/lm_model.py0compute the activations for the next token in a sequence. args: input_ids: token ids with shape {pos} attn_mask: attentiSTRING
HIGHlib/levanter/src/levanter/models/mixtral.py0compute the activations for the next token in a sequence. args: input_ids: token ids with shape {pos} attn_mask: attentiSTRING
Docstring Block Structure46 hits · 230 pts
SeverityFileLineSnippetContext
HIGHexperiments/coral/batch_calibration.py49Estimate parameter and activation bytes for a dense transformer. Args: parameter_count: Number of trainableSTRING
HIGHexperiments/coral/batch_calibration.py93Return total HBM bytes for a global batch. Args: parameter_bytes: Model parameter memory. optimizerSTRING
HIGHexperiments/coral/batch_calibration.py123Select Levanter parallelism settings that fit a global batch on TPUs. Args: tpu: TPU topology name acceptedSTRING
HIGHexperiments/datakit/testbed/sampler.py170Sample ``source``'s normalized shards to a target row count. Probes a single shard for rows-per-file, then computesSTRING
HIGH.agents/projects/iris_pypi_mirror/spec.md52Build uv env vars that point dependency resolution at AR remote PyPI repos. Caller responsibilities (not enforced hSTRING
HIGH.agents/projects/executor_in_training_job/spec.md48Run any ExecutorSteps embedded in `config`, then return a copy of `config` with all InputName / OutputName / VersionSTRING
HIGHlib/iris/src/iris/cluster/types.py587Create a DeviceConfig for a GPU device. Args: variant: GPU variant string (e.g., "H100", "A100"). cSTRING
HIGHlib/iris/src/iris/cluster/types.py610Parse human-readable memory string to bytes. Supports various formats: - "8G", "8GB", "8 GB", "8 gigabytes" STRING
HIGHlib/iris/src/iris/cluster/types.py824Derive namespace from hierarchical job ID. The namespace is the first component of the job ID hierarchy. STRING
HIGH…ris/src/iris/cluster/platforms/gcp/worker_bootstrap.py120Render a template string with {{ variable }} placeholders. Uses ``{{ variable }}`` syntax (double braces with exactSTRING
HIGHlib/iris/src/iris/cluster/runtime/types.py196Run setup_commands (uv sync, pip install, etc). Blocks until setup completes. If there are no setup_commands, STRING
HIGHlib/iris/src/iris/cluster/runtime/types.py251Profile the running process using py-spy (CPU), memray (memory), or thread dump. Args: duration_secSTRING
HIGHlib/iris/src/iris/cluster/runtime/docker.py446Run setup_commands (uv sync, pip install, etc) in a temporary container. Creates a temporary container that runSTRING
HIGH…iris/src/iris/cluster/controller/autoscaler/factory.py43Create autoscaler from WorkerInfraProvider and explicit config. Args: platform: WorkerInfraProvider instancSTRING
HIGHlib/iris/src/iris/cluster/worker/task_attempt.py469Profile the running container process. Args: duration_seconds: How long to sample profiSTRING
HIGHlib/iris/src/iris/cluster/client/remote_client.py260Wait for job to complete with exponential backoff polling. If the controller becomes unavailable, retries with STRING
HIGHlib/iris/src/iris/runtime/jax_init.py258Poll the endpoint registry until the coordinator address appears. Args: resolver: Namespaced resolver for tSTRING
HIGHlib/iris/src/iris/rpc/errors.py166Execute an RPC call with exponential backoff retry. Retries stop when either ``max_attempts`` is exhausted **or** STRING
HIGHlib/iris/src/iris/rpc/errors.py220Poll an RPC endpoint, tolerating transient unavailability. Calls ``poll_fn`` in a loop. On retryable errors the fuSTRING
HIGHlib/iris/src/iris/client/worker_pool.py117Execute a pickled callable and return the result. Args: serialized_callable: cloudpickle-serializedSTRING
HIGHlib/iris/src/iris/client/worker_pool.py323Block until result is available. Args: timeout: Maximum time to wait in seconds Returns: STRING
HIGHlib/iris/src/iris/client/client.py554Wait for job to complete. Args: timeout: Maximum wait time in seconds poll_interval: UpSTRING
HIGHlib/iris/src/iris/client/client.py935Submit a job with automatic job_id hierarchy. Args: entrypoint: Job entrypoint (callable + args/kwaSTRING
HIGHlib/iris/src/iris/client/client.py1408Get an allocated port by name. Args: name: Port name (e.g., "actor") Returns: STRING
HIGHlib/levanter/src/levanter/eval_harness.py106 Call a function with retry logic and exponential backoff. Handles HuggingFace rate limit errors (HTTP 429) by STRING
HIGHlib/levanter/src/levanter/compat/hf_checkpoints.py129Build a validated generation_config dict from explicit EOS token IDs. The returned dict is suitable for writing as STRING
HIGHlib/levanter/src/levanter/recovery/faults.py79Parse a fault assignment from the environment. Args: env: Mapping to read from; defaults to ``os.enSTRING
HIGHlib/levanter/src/levanter/tracker/tracker_fns.py244 Get or set the global tracker. Note that setting the global tracker is not thread-safe, and using a tracker froSTRING
HIGHlib/levanter/src/levanter/tracker/tracker_fns.py288 Lookup a tracker in the current global tracker with the provided name. Args: name: Name of the trackerSTRING
HIGHlib/levanter/src/levanter/models/llama.py135Convert to HuggingFace's LlamaConfig Args: vocab_size (int, optional): Vocabulary size of the tokenSTRING
HIGHlib/marin/tools/get_hf_dataset_schema.py126 Get the schema of a Hugging Face dataset. Args: dataset_name: Name of the dataset (e.g., 'wikitext', 'STRING
HIGH…/processing/classification/deduplication/fuzzy_dups.py233Mark fuzzy-duplicate cluster membership across one or more ``MinHashAttrData`` inputs. All inputs must share identiSTRING
HIGHlib/marin/src/marin/scaling_laws/tpu_utils.py46Select the smallest TPU slice that fits the estimated memory. Args: estimated_memory_bytes: Estimated memorSTRING
HIGH…rin/src/marin/transform/huggingface/dataset_to_eval.py342 Transform a single HuggingFace dataset example to QA format. Args: example: Raw example from HuggingFaSTRING
HIGH…rin/src/marin/transform/huggingface/dataset_to_eval.py474 Converts HuggingFace datasets to JSONL files for evaluation or decontamination. This function processes dataseSTRING
HIGHlib/haliax/src/haliax/debug.py58 Checks for common issues in a module, such as reused arrays and static arrays. Equinox modules (and therefore HSTRING
HIGHlib/haliax/src/haliax/_src/einsum.py32Compute the tensor contraction of the input arrays according to Haliax's named variant of the Einstein summation conSTRING
HIGHlib/haliax/src/haliax/nn/conv.py168 Args: inputs (NamedArray): Input array key (PRNGKeyArray: Not used, compat with other mSTRING
HIGHlib/haliax/src/haliax/nn/conv.py324 Args: inputs (NamedArray): Input array key (PRNGKeyArray: Not used, compat with other mSTRING
HIGHlib/haliax/src/haliax/nn/pool.py35 General function for pooling. Broadly based on the Flax implementation. Pooling functions are implemented usinSTRING
HIGHlib/rigging/src/rigging/config_discovery.py112Resolve a cluster name (or path) to an existing YAML config file. If ``name`` is already an existing file path, it STRING
HIGHlib/zephyr/src/zephyr/readers.py444Load records from file as JSONL, Parquet, or Vortex. The spec's ``format`` selects the reader; ``auto`` (the defaulSTRING
HIGHlib/zephyr/src/zephyr/readers.py503Load a Parquet file and yield ``pa.RecordBatch`` objects. Only Parquet files are supported. Raises ``RuntimeError``STRING
HIGHlib/zephyr/src/zephyr/dataset.py93Format output path with shard information. Args: pattern: Path pattern with {shard}, {total}, {basename} plSTRING
HIGHlib/zephyr/src/zephyr/dataset.py414Create dataset from file glob pattern. This method finds all files matching the glob pattern and returns a STRING
HIGHlib/zephyr/src/zephyr/dataset.py1030Streaming merge join for already-sorted, co-partitioned datasets. Preconditions: - Both datasets have tSTRING
Modern AI Meta-Vocabulary46 hits · 132 pts
SeverityFileLineSnippetContext
MEDIUMAGENTS.md80# Lint review — agentic pass over the branch diff against the infra/lint/ catalogCOMMENT
MEDIUMinfra/README.md42 # Your processing logic here - no manual worker orchestration neededCOMMENT
MEDIUMinfra/lint/cruft.md25### `ml-rollout-scaffolding` — Knob added "just for the rollout"COMMENT
MEDIUMinfra/lint/cruft.md126def _run_ping_loop(self): ... # same scaffold, only the wrapped call differsCODE
MEDIUMinfra/ci/select_tests.py73# orchestration itself. Locally, their import-dependent tests are sufficient;COMMENT
MEDIUMinfra/codehealth/review_quality.py133# Pluggable so the backend can change without touching batching orchestration.COMMENT
MEDIUMinfra/evaldash/dashboard/src/types/api.ts360// samples, and `trajectory_uri` for `agentic` samples. The one unbounded payload, the agenticCOMMENT
MEDIUMinfra/evaldash/dashboard/src/types/api.ts394// Agent Trajectory Interchange Format (ATIF): one agentic run's steps. A step is either a userCOMMENT
MEDIUMinfra/evaldash/src/fixtures.py68# A representative vLLM serving profile shared by the lm-eval runs; agentic and legacy runs override itCOMMENT
MEDIUMinfra/evaldash/src/fixtures.py461 # An agentic run that lost one of its ten trials to a timeout: the aggregate is over theCOMMENT
MEDIUMinfra/evaldash/src/fixtures.py466 runtime_minutes=42.0, # agentic sandbox rollouts run far longer than the lm-eval tasksCODE
MEDIUMexperiments/evaluation/models.py126 # tokens, so skip_special_tokens=false keeps the chain-of-thought from being stripped before scoringCOMMENT
MEDIUMexperiments/evaluation/evals.py251 # --- Harbor (agentic registry benchmarks) ---COMMENT
MEDIUMexperiments/evaluation/README.md209# A capped agentic validation run (2 tasks).COMMENT
MEDIUMexperiments/evaluation/configs/harbor/aime-smoke.yaml18 # This is an integration smoke, not the production agentic AIME benchmark. One bounded modelCOMMENT
MEDIUMexperiments/evaluation/serve/models/README.md58agent: # AgentConfig -> the Harbor/agentic agentCODE
MEDIUM…e/models/marin-community/grug-agentic-s3-step1903.yaml2location: s3://marin-us-east-02a/marin/exports/grug/june-67b-a2b-sft-s3-agentic/step-1903/hf-bf16-vllm/CODE
MEDIUMtests/evals/test_evalchemy_config.py197 # lm-eval assumes a 2048-token window unless told otherwise, silently left-truncating few-shotCOMMENT
MEDIUMtests/snapshots/web/expected/resiliparse/dbrx.md76## Quality on Long-Context Tasks and RAGCOMMENT
MEDIUMtests/snapshots/web/inputs/dbrx.html163</script><script type="text/javascript" defer="">(function(){function b(){!1===c&&(c=!0,Munchkin.init("094-YMS-629"))}vaCODE
MEDIUMtests/snapshots/web/inputs/dbrx.html164</style><p><span class="b2">Today, we are excited to introduce DBRX, an open, general-purpose LLM created by Databricks.CODE
MEDIUMtests/snapshots/web/inputs/dbrx.html164</style><p><span class="b2">Today, we are excited to introduce DBRX, an open, general-purpose LLM created by Databricks.CODE
MEDIUMtests/evaluation/test_eval_archive.py533 # A legacy Harbor run: one agentic sample referencing a trajectory by an in-place path.COMMENT
MEDIUMtests/evaluation/test_eval_archive.py557 # The migrated agentic sample points at a finestore:// trajectory the archive resolves.COMMENT
MEDIUM.agents/projects/20260130_fray_lite_research.md78#### Job orchestration (`rl_job.py`)COMMENT
MEDIUM.agents/projects/eval-rollup-design.md175 kind: SampleKind # multiple_choice | generation | agenticCODE
MEDIUM.agents/projects/eval-rollup-design.md184 # agenticCOMMENT
MEDIUM.agents/projects/20260130_fray_lite_design.md590### Job orchestration (`rl_job.py`)COMMENT
MEDIUM.agents/projects/20260130_fray_lite_design.md870│ ├── tpu.py # TPU orchestration (copied from v1 ray.tpu.execution)CODE
MEDIUM…gents/projects/20260430-zephyr-performance/research.md208#### RAG with Codebase ContextCOMMENT
MEDIUMdocs/debug-log-agentic-daytona.md1# Debugging log for agentic Daytona validationCOMMENT
MEDIUMdocs/debug-log-agentic-daytona.md27- Register the [#7246](https://github.com/marin-community/marin/pull/7246) agentic presets asCODE
MEDIUMdocs/debug-log-agentic-daytona.md27- Register the [#7246](https://github.com/marin-community/marin/pull/7246) agentic presets asCODE
MEDIUMdocs/reports/marin-8b-retro.md632For code generation, we use [HumanEval](https://github.com/openai/human-eval) - which continues to be the standard benchCODE
MEDIUMscripts/ci/wait_for.py372# the structure: strip the scaffolding and a placeholder has no prose left.COMMENT
MEDIUMscripts/ci/wait_for.py389# multi-agent correctness review…"), while the shortest real review leaves 121. Nothing landsCOMMENT
MEDIUMscripts/ci/wait_for.py446 # Drop the verdict itself ("no issues") and the checklist scaffolding ("- [x] ValidateCOMMENT
MEDIUM.github/workflows/marin-release-libs-wheels.yaml29 # package-owned source_patterns; orchestration-only changes do not publish.COMMENT
MEDIUMlib/iris/src/iris/cluster/controller/auth.py130# agentic datagen/eval job can hold one capability URL for its whole run insteadCOMMENT
MEDIUMlib/levanter/.agents/projects/inference.md63### 2. HTTP server scaffoldCOMMENT
MEDIUM…kernels/pallas/fused_cross_entropy_loss/batched_xla.py18# Empirical launch guardrails from Triton shared-memory launch failures.COMMENT
MEDIUMlib/marin/src/marin/evaluation/archive.py211# ``steps`` table (agentic trajectories flattened for column projection), and finestore's reservedCOMMENT
MEDIUMlib/marin/src/marin/evaluation/harbor/runner.py59# The fraction of attempted trials a verifier must grade for a run to be accepted. An agentic runCOMMENT
MEDIUMlib/marin/src/marin/evaluation/evalchemy/client.py30# vLLM returns HTTP 400 when prompt_tokens + max_tokens exceeds the served context window. ReserveCOMMENT
MEDIUMlib/marin/src/marin/evaluation/evalchemy/client.py35# tokens against its context window (a loglikelihood request adds one output token to aCOMMENT
MEDIUMlib/marin/src/marin/evaluation/evalchemy/runtime.py22# Keep CPU-only PyTorch as a compatibility floor for benchmark orchestration and grading code.COMMENT
AI Slop Vocabulary45 hits · 128 pts
SeverityFileLineSnippetContext
MEDIUMinfra/linter.py141# The meta lane is holistic: it reasons over the whole change, may read beyond the diff,COMMENT
MEDIUMinfra/linter.py162# The holistic meta lane only runs on larger diffs — its rules need the whole change, and on aCOMMENT
MEDIUMinfra/linter.py174 # Instruction block appended after the lane catalog; the holistic meta lane overrides theCOMMENT
MEDIUMinfra/linter.py301# review harness supplies the real identity through the environment. ACOMMENT
MEDIUMinfra/linter.py826 # Drop lanes whose diff-size floor the change doesn't clear (only the holistic meta laneCOMMENT
MEDIUMinfra/tpu-ci/vm_manager.py710 # For static mode, get comprehensive diagnosticsCOMMENT
MEDIUMinfra/evaldash/dashboard/package-lock.json2113 "resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.3.tgz",CODE
MEDIUMinfra/cron/nightshift_doc_drift.py13# the harness default — this setting does.COMMENT
MEDIUMinfra/cron/nightshift_cleanup.py25# the harness default — this setting does.COMMENT
MEDIUMinfra/cron/nightshift_ci_tests.py42# the harness default — this setting does.COMMENT
MEDIUMexperiments/evals/task_configs.py10# TODO: add more once supported in lm-eval-harness and/or tested on our endCOMMENT
MEDIUMexperiments/references/reference_training_pipeline.py83# A nano model: this harness measures path-liveness and delta-vs-baseline, not absoluteCOMMENT
MEDIUMexperiments/evaluation/evals.py274# The comprehensive per-model benchmark set: every model x task pair runs (and is recorded) as itsCOMMENT
MEDIUMexperiments/evaluation/evals.py290# The baseline lm-eval-harness NLP suite: 14 deterministic loglikelihood/greedy tasks, runnable onCOMMENT
MEDIUMexperiments/datakit/decontam/viewer/report.py48// Works at the token level so highlighting is robust to newlines/indentation:COMMENT
MEDIUMtests/snapshots/stackexchange/inputs/chemistry_3.json3 "text": "# Flammability (NFPA) - how is it defined?\n\nI was reading up on a wonderful little chemical compound knowCODE
MEDIUMtests/snapshots/web/inputs/dbrx.html164</style><p><span class="b2">Today, we are excited to introduce DBRX, an open, general-purpose LLM created by Databricks.CODE
MEDIUMtests/snapshots/web/inputs/dbrx.html164</style><p><span class="b2">Today, we are excited to introduce DBRX, an open, general-purpose LLM created by Databricks.CODE
MEDIUMtests/snapshots/dclm_hq/inputs/hq_1.html231<li id="cite_note-7"><span class="mw-cite-backlink"><b><a href="#cite_ref-7">^</a></b></span> <span class="reference-texCODE
MEDIUMtests/snapshots/dclm_hq/inputs/hq_1.html682<li id="cite_note-7"><span class="mw-cite-backlink"><b><a href="#cite_ref-7">^</a></b></span> <span class="reference-texCODE
MEDIUMtests/evaluation/test_evaldash_metrics.py199 # Two benchmarks under the same names are not the same benchmarks if different harness versionsCOMMENT
MEDIUMtests/datakit/decontam/test_prepare_eval_corpus.py32# A rendered prompt embeds the passage (as lm-eval-harness doc_to_text does).COMMENT
MEDIUMlib/iris/scripts/install_kueue.py217# Install core (importable; the click command and the smoke harness both call it).COMMENT
MEDIUMlib/iris/scripts/benchmark_controller.py151# RPC harness: real Controller(dry_run=True) + Connect sync clientCOMMENT
MEDIUMlib/iris/scripts/benchmark_controller.py387# Bench harnessCOMMENT
MEDIUMlib/iris/scripts/benchmark_controller.py278 # exercise the endpoint registry set this to ``harness.make_endpoint_client``.COMMENT
MEDIUMlib/iris/src/iris/testing/cluster.py58# ServiceTestHarness — parameterized GCP / K8s controller service harnessCOMMENT
MEDIUMlib/iris/src/iris/testing/cluster.py150 # Share the harness tracker so the service registers into and reads livenessCOMMENT
MEDIUMlib/iris/src/iris/testing/cluster.py151 # through the same object this harness's ControllerTestState exposes.COMMENT
MEDIUMlib/levanter/tests/test_eval_harness.py23 # Create chat-like requests with contexts formatted via the chat template, matching harness usageCOMMENT
MEDIUMlib/levanter/src/levanter/eval_harness.py1524 # remove the ",none" suffix, which eval-harness adds by default for some reasonCOMMENT
LOWlib/levanter/src/levanter/trainer.py198 # we can't just use `lambda: model` because JAX jit can't see captures, but it can see jax partialsCOMMENT
MEDIUM…evanter/kernels/pallas/fused_cross_entropy_loss/api.py171 # Keep TPU default stable and robust unless Pallas is explicitly requested.COMMENT
MEDIUMlib/levanter/src/levanter/callbacks/_metrics.py122 # Accumulate MFU samples over a trailing window for robust distribution stats.COMMENT
MEDIUMlib/levanter/src/levanter/recovery/faults.py38# Environment variables the harness sets on each trainer subprocess.COMMENT
MEDIUMlib/levanter/src/levanter/utils/logging.py65 # this isn't robust to quotesCOMMENT
LOWlib/levanter/src/levanter/utils/logging.py70 # XLA_FLAGS has to be set before the first jax call, so we can't just set it in the middle of the runCOMMENT
LOWlib/levanter/src/levanter/tracker/tracker_fns.py102 # and we just return the metrics dictionaryCOMMENT
MEDIUMlib/levanter/src/levanter/data/sharded_datasource.py389 # (1) is cheating a bit, but it's fast and works in most cases we care about. (2) is more robust, but slower.COMMENT
MEDIUMlib/marin/src/marin/scaling_laws/isoflop_analysis.py237 """Fit a robust quadratic in log10(x) space using Huber loss.STRING
MEDIUMlib/marin/src/marin/execution/step_runner.py220 # inherit it explicitly. More robust than contextvars.copy_context()COMMENT
MEDIUMlib/marin/src/marin/evaluation/evalchemy/result.py69 # A retried evaluation leaves a second complete tree under the harness's scratch directory,COMMENT
LOWlib/haliax/src/haliax/core.py1173 # scalar case: just add one axis so it doesn't get too madCOMMENT
LOWlib/haliax/src/haliax/core.py1657 # maybe just add a context manager to allow it?COMMENT
MEDIUMlib/rigging/src/rigging/log_setup.py192 # faulthandler writes to a raw fd; a harness that captures sys.stderrCOMMENT
Self-Referential Comments44 hits · 126 pts
SeverityFileLineSnippetContext
MEDIUMexperiments/marin_tokenizer.py218 # Create a temporary directory that may be RAM-basedSTRING
MEDIUMtests/test_evaluator_utils.py12 # Create a temporary directoryCOMMENT
MEDIUM…cluster/backends/gcp/test_cloud_service_integration.py514 # Create a VM firstCOMMENT
MEDIUMlib/iris/tests/cluster/backends/gcp/test_platform.py1119 # Create a VM but set it to non-READY stateCOMMENT
MEDIUMlib/iris/tests/cluster/controller/test_autoscaler.py538 # Create a slice with 4 VMsCOMMENT
MEDIUMlib/iris/tests/cluster/worker/test_worker.py442 # Create a handle that stays running until killedCOMMENT
MEDIUMlib/iris/tests/cluster/worker/test_worker.py466 # Create a handle that stays running until killedCOMMENT
MEDIUMlib/iris/tests/cluster/worker/test_worker.py500 # Create a handle that stays running until killedCOMMENT
MEDIUMlib/iris/src/iris/cluster/worker/worker.py366 # Create a handle wrapping the existing containerCOMMENT
MEDIUMlib/iris/src/iris/cluster/worker/worker.py738 # Create a minimal TaskAttemptConfig. Expensive setup (port allocation,COMMENT
MEDIUMlib/fray/src/fray/local_backend.py215 # Create a synthetic job handle that is immediately succeededCOMMENT
MEDIUMlib/fray/src/fray/iris_backend.py779 # Create a single job with N replicasCOMMENT
MEDIUMlib/levanter/infra/cluster/job-cluster.yaml38 # Create a Persistent Disk w/ 100 GBsCOMMENT
MEDIUMlib/levanter/tests/test_hyena.py18 # Create a test config that matches the PyTorch exampleCOMMENT
MEDIUMlib/levanter/tests/test_hyena.py33 # Create a random input tensor with shape matching the PyTorch exampleCOMMENT
MEDIUMlib/levanter/tests/test_hyena.py38 # Define a function to compute the sum of a specific position's outputCOMMENT
MEDIUMlib/levanter/tests/test_background_iterable.py28 # Create a BackgroundIterable instance with an empty producer functionCOMMENT
MEDIUMlib/levanter/tests/test_background_iterable.py40 # Create a producer function that raises an exceptionCOMMENT
MEDIUMlib/levanter/tests/test_background_iterable.py44 # Create a BackgroundIterable instance with the producer function that raises an exceptionCOMMENT
MEDIUMlib/levanter/tests/test_sharded_dataset.py50 # Create a simple datasetCOMMENT
MEDIUMlib/levanter/tests/test_skip_step.py362 # Create a SkipStepState instanceCOMMENT
MEDIUMlib/levanter/tests/test_sft.py36 # Create a simple model with random embeddingsCOMMENT
MEDIUMlib/levanter/tests/test_sft.py42 # Create a mock model with LlamaEmbeddingCOMMENT
MEDIUMlib/levanter/tests/test_packing.py219 # Create a packed exampleCOMMENT
MEDIUMlib/levanter/tests/test_packing.py244 # Create a single JaggedArrayStore with four documents.COMMENT
MEDIUMlib/levanter/tests/test_packing.py553 # Create a single-leaf dataset of 4 documents (as in test 1) with offsets [0,100,300,450,600].COMMENT
MEDIUMlib/levanter/tests/test_packing.py674 # Create a dataset with a single document that's too longCOMMENT
MEDIUMlib/levanter/tests/test_jax_utils.py194 # Create a module and a target treeCOMMENT
MEDIUMlib/levanter/scripts/gcs_bulk_delete.py29 # Define the transfer jobCOMMENT
MEDIUMlib/levanter/scripts/gcs_bulk_delete.py41 # Create the transfer jobCOMMENT
MEDIUMlib/levanter/src/levanter/compat/hf_checkpoints.py1641 # Create a temporary directory that persists through the context managerCOMMENT
MEDIUMlib/levanter/src/levanter/optim/skipstep.py18# Define the state structure for the optimizerCOMMENT
MEDIUMlib/levanter/src/levanter/utils/thread_utils.py10# Create a ThreadPoolExecutorCOMMENT
MEDIUMlib/levanter/src/levanter/models/hyena.py468 # Create a new axis with the same dimensions to avoid naming collisionCOMMENT
MEDIUMlib/levanter/src/levanter/data/packing.py293 # Create the LmExampleCOMMENT
MEDIUMlib/levanter/src/levanter/data/audio.py149 """This class represents a dataset source with URLs or hf name/id."""STRING
MEDIUMlib/levanter/src/levanter/data/audio.py426 """This class represents a mixture of datasets with their associated weights."""STRING
MEDIUMlib/levanter/src/levanter/data/text/datasets.py246 """This class represents a dataset source with URLs or hf name/id."""STRING
MEDIUMlib/marin/src/marin/export/hf_upload.py48 # Create the repo if it doesn't existCOMMENT
MEDIUM…n/src/marin/transform/wikipedia/transform_wikipedia.py157 # Create a new <p> tag and insert the br tags plus the display mathCOMMENT
MEDIUM…marin/transform/conversation/transform_conversation.py139 # Create a unique ID for the row based on the textCOMMENT
MEDIUMlib/haliax/src/haliax/__init__.py208 # Create a NamedArray along a single axisSTRING
MEDIUMlib/haliax/src/haliax/nn/scan.py669 # Create a function that captures the additional argumentsCOMMENT
MEDIUMlib/dupekit/tests/test_bloom.py116 # Create a large bloom filter to ensure chunking happensCOMMENT
AI Structural Patterns115 hits · 106 pts
SeverityFileLineSnippetContext
LOWinfra/grafana/tests/conftest.py74CODE
LOWinfra/grafana/tests/test_k8s_source.py729CODE
LOWexperiments/grug/moe_hero_ep/memory_soak.py120CODE
LOWexperiments/grug/moe_hero_ep/small_scale_abl_launch.py264CODE
LOWexperiments/grug/moe_hero_ep/launch_diagnostics.py61CODE
LOWexperiments/grug/moe_hero_fsdp/launch.py264CODE
LOWexperiments/datasets/instruction.py135CODE
LOWexperiments/datakit/embeddings/luxical/pipeline.py306CODE
LOWexperiments/datakit/testbed/train.py125CODE
LOWtests/evaluation/test_eval_stats.py43CODE
LOWscripts/training/time_to_train/parse_wandb_runs.py111CODE
LOWlib/iris/tests/cluster/runtime/test_env_parity.py26CODE
LOWlib/iris/tests/cluster/worker/test_worker.py1176CODE
LOWlib/iris/scripts/install_kueue.py219CODE
LOWlib/iris/scripts/benchmark_controller.py1656CODE
LOWlib/iris/src/iris/cluster/platforms/gcp/fake.py68CODE
LOWlib/iris/src/iris/cluster/controller/dashboard.py191CODE
LOWlib/iris/src/iris/cluster/worker/worker.py140CODE
LOWlib/iris/src/iris/cluster/client/protocol.py22CODE
LOWlib/iris/src/iris/cluster/client/remote_client.py150CODE
LOWlib/iris/src/iris/cli/job.py563CODE
LOWlib/iris/src/iris/cli/job.py715CODE
LOWlib/iris/src/iris/testing/controller.py764CODE
LOWlib/iris/src/iris/testing/controller.py964CODE
LOWlib/iris/src/iris/testing/e2e.py102CODE
LOWlib/iris/src/iris/testing/journeys/world.py176CODE
LOWlib/iris/src/iris/client/client.py912CODE
LOWlib/levanter/tests/test_new_loader.py93CODE
LOWlib/levanter/tests/test_new_loader.py139CODE
LOWlib/levanter/tests/test_attention.py699CODE
LOWlib/levanter/src/levanter/config.py144CODE
LOWlib/levanter/src/levanter/eval_harness.py1696CODE
LOWlib/levanter/src/levanter/eval_harness.py366CODE
LOWlib/levanter/src/levanter/eval_harness.py377CODE
LOWlib/levanter/src/levanter/eval_harness.py381CODE
LOWlib/levanter/src/levanter/checkpoint.py948CODE
LOWlib/levanter/src/levanter/eval.py281CODE
LOW…evanter/kernels/pallas/fused_cross_entropy_loss/api.py592CODE
LOW…evanter/kernels/pallas/fused_cross_entropy_loss/api.py611CODE
LOW…evanter/kernels/pallas/fused_cross_entropy_loss/api.py629CODE
LOW…evanter/kernels/pallas/fused_cross_entropy_loss/xla.py678CODE
LOWlib/levanter/src/levanter/kernels/pallas/mamba3/api.py524CODE
LOWlib/levanter/src/levanter/kernels/pallas/mamba3/api.py652CODE
LOWlib/levanter/src/levanter/kernels/pallas/mamba3/api.py693CODE
LOWlib/levanter/src/levanter/kernels/pallas/mamba3/api.py860CODE
LOWlib/levanter/src/levanter/compat/hf_checkpoints.py1531CODE
LOWlib/levanter/src/levanter/compat/hf_checkpoints.py1055CODE
LOWlib/levanter/src/levanter/analysis/visualization.py80CODE
LOWlib/levanter/src/levanter/analysis/backward_flow.py415CODE
LOWlib/levanter/src/levanter/layers/attention.py93CODE
LOWlib/levanter/src/levanter/layers/attention.py363CODE
LOWlib/levanter/src/levanter/layers/attention.py415CODE
LOWlib/levanter/src/levanter/layers/attention.py509CODE
LOWlib/levanter/src/levanter/layers/attention.py831CODE
LOWlib/levanter/src/levanter/layers/attention.py904CODE
LOWlib/levanter/src/levanter/layers/attention.py1916CODE
LOWlib/levanter/src/levanter/layers/rotary.py22CODE
LOWlib/levanter/src/levanter/grug/grug_moe.py146CODE
LOWlib/levanter/src/levanter/grug/grug_moe.py78CODE
LOW…src/levanter/grug/attention/_fa4_cute_segmented_bwd.py76CODE
55 more matches not shown…
Structural Annotation Overuse44 hits · 79 pts
SeverityFileLineSnippetContext
LOWexperiments/tutorials/hello_world.py73# Step 1: generate the data. build_config resolves ctx.output_path to the artifact's output dir.COMMENT
LOWexperiments/tutorials/hello_world.py82# Step 2: compute statistics over the generated data. ctx.artifact_path(_data) gives the pathCOMMENT
LOWtests/execution/test_step_runner.py119 # Step 1: downloadCOMMENT
LOWtests/execution/test_step_runner.py123 # Step 2: tokenize — load upstream artifact, run, saveCOMMENT
LOW.agents/projects/20260303_iris_autoscaler_design.md729### Step 1: COOLDOWN State + AT_CAPACITY Rename (No Capacity Math Changes)COMMENT
LOW.agents/projects/20260303_iris_autoscaler_design.md739### Step 2: Additive Resource PackingCOMMENT
LOW.agents/docs/smoke-test-dry-run.md640### Step 1: Extract `local_platform.py` from `demo_cluster.py`COMMENT
LOW.agents/docs/smoke-test-dry-run.md650### Step 2: Proto + `LocalController` + config wiringCOMMENT
LOW.agents/docs/smoke-test-dry-run.md671### Step 4: Smoke test integrationCOMMENT
LOW.agents/docs/smoke-test-dry-run.md679### Step 5: Simplify `demo_cluster.py`COMMENT
LOW.agents/docs/smoke-test-dry-run.md686### Step 6: CLI integration (optional)COMMENT
LOW.agents/docs/cluster-logging.md166### Step 1: Extract `stream_docker_logs()` into debug.pyCOMMENT
LOW.agents/docs/cluster-logging.md178### Step 2: Add `LogStreamHandle` and `start_log_streaming()` to ClusterManagerCOMMENT
LOW.agents/docs/cluster-logging.md191### Step 3: Add `log_dir` parameter to `connect()`COMMENT
LOW.agents/docs/cluster-logging.md204### Step 4: Simplify smoke-test.pyCOMMENT
LOWdocs/tutorials/first-experiment.md32## Step 1: Tokenize the datasetCOMMENT
LOWdocs/tutorials/first-experiment.md55## Step 2: Choose a model configurationCOMMENT
LOWdocs/tutorials/first-experiment.md78## Step 3: Assemble the training runCOMMENT
LOWdocs/tutorials/first-experiment.md120## Step 4: Wire the main blockCOMMENT
LOWdocs/tutorials/storage-bucket.md17## Step 1: Choose a Region and NameCOMMENT
LOWdocs/tutorials/storage-bucket.md31## Step 2: Create the BucketCOMMENT
LOWdocs/tutorials/storage-bucket.md53## Step 3: Disable Soft DeleteCOMMENT
LOWdocs/tutorials/storage-bucket.md73## Step 4: TTL Scratch Prefixes (`tmp/ttl=Nd/`)COMMENT
LOWdocs/tutorials/storage-bucket.md119## Step 5: Wire It Into Marin / LevanterCOMMENT
LOWlib/levanter/.agents/projects/gcs_serialization.md115 # Step 1: collective gather so every device sees every host's chunk.COMMENT
LOWlib/levanter/docs/recipes/port-models.md14## Step 1: Write the ConfigCOMMENT
LOWlib/levanter/docs/recipes/port-models.md20## Step 2: Implement the ModelCOMMENT
LOWlib/levanter/docs/recipes/port-models.md26## Step 3: Add Serialization Support (if needed)COMMENT
LOWlib/levanter/docs/recipes/port-models.md32## Step 4: Write TestsCOMMENT
LOWlib/levanter/docs/recipes/port-models.md45## Step 5: Create a "nano" configCOMMENT
LOWlib/levanter/docs/guides/Training-Data-Guide.md7## Step 1: Identify the Format for Each DatasetCOMMENT
LOWlib/levanter/docs/guides/Training-Data-Guide.md19## Step 2: Prepare Your DataCOMMENT
LOWlib/levanter/docs/guides/Training-Data-Guide.md47## Step 3: Write Your ConfigCOMMENT
LOWlib/levanter/docs/guides/Training-Data-Guide.md189## Step 4: Launch TrainingCOMMENT
LOW…evanter/docs/tutorials/Fine-Tuning-Semantic-Parsing.md69### Step 1: Prepare the DatasetCOMMENT
LOW…evanter/docs/tutorials/Fine-Tuning-Semantic-Parsing.md108### Step 2: Fine-tune the ModelCOMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py196 # Step 1: Divide Q into 𝑇𝑟 = \ceil(𝑁/Br) blocks of size Br x d each,COMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py199 # Step 2: init O_i = 0, sumexp_i = 0, max_i = -infCOMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py221 # Step 1: Divide Q into 𝑇𝑟 = \ceil(𝑁/Br) blocks of size Br x d each,COMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py227 # Step 8: compute Sij = QiKj^TCOMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py263 # Step 9: Compute m_i^j = max(m_i^{j-1}, rowmax(S_i^j)), P_i^j = exp(S_i^j - m_i^j),COMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py272 # Step 10: Compute O_i = diag(exp(m_i^{j-1} - m_i^j) O_i + P_i^j V_jCOMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py287 # Step 12: compute O_i = diag(\ell_i^{Tc})^{-1} O_i^{Tc}COMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py289 # Step 13: compute L_i = m_i^{Tc} + log(\ell_i^{Tc})COMMENT
Redundant / Tautological Comments25 hits · 38 pts
SeverityFileLineSnippetContext
LOWinfra/pre-commit.py780 # Check if any pb2 file exists alreadyCOMMENT
LOWinfra/tpu-ci/setup.py163 # Check if user is authenticated to ghcr.ioCOMMENT
LOWinfra/tpu-ci/vm_manager.py264# Check if runner is configured by looking for config files OR .runner fileCOMMENT
LOWscripts/pm/itemize_experiment_issues.py116 # Check if any of the URLs are already in the contentCOMMENT
LOWscripts/pm/itemize_experiment_issues.py153 # Check if any of the URLs are already in existing_reportsCOMMENT
LOWscripts/debug/decode_tokens.py83 # Check if it looks like a token listCOMMENT
LOWscripts/speedrun/onboarding_setup.sh47 # Check if a 'marin' directory exists in the current pathCOMMENT
LOWscripts/speedrun/onboarding_setup.sh137# Check if uv is installedCOMMENT
LOWscripts/speedrun/onboarding_setup.sh219# Check if branch exists, if not create itCOMMENT
LOWscripts/speedrun/onboarding_setup.sh280# Check if origin points to the main community repo (indicating it's not a personal fork)COMMENT
LOWlib/iris/tests/cluster/backends/gcp/test_platform.py1129 # Set VM to STAGING so it never reaches READYCOMMENT
LOW…is/src/iris/cluster/controller/scheduling/scheduler.py846 # Assign tasks to workers in orderCOMMENT
LOWlib/iris/src/iris/cluster/worker/task_attempt.py888 # Check if we should stopCOMMENT
LOWlib/levanter/tests/test_prp.py51 # Check if all elements are unique, which is a necessary condition for a bijective functionCOMMENT
LOWlib/levanter/tests/test_skip_step.py280 # Check if it has init and update attributesCOMMENT
LOWlib/levanter/tests/test_skip_step.py375 # Check if the unflattened state matches the originalCOMMENT
LOWlib/levanter/scripts/clean_old_checkpoints.py43 # Check if this checkpoint is the largest complete checkpointCOMMENT
LOWlib/levanter/scripts/clean_old_checkpoints.py48 # Check if this checkpoint ends in '000' and is the largest of suchCOMMENT
LOWlib/levanter/scripts/preproc/split-pile-shards.py60 # Check if compressor exists for this category, if not create itCOMMENT
LOWlib/levanter/src/levanter/eval_harness.py137 # Check if this is a rate limit error from HuggingFaceCOMMENT
LOW…src/levanter/grug/attention/_fa4_cute_segmented_bwd.py187 # Check if block size setting is out of shared memory capacityCOMMENT
LOWlib/marin/src/marin/markdown/markdown.py935 # Check if base is an operator usually taking limitsCOMMENT
LOWlib/marin/src/marin/export/hf_upload.py43 # Check if the repo existsCOMMENT
LOW…n/src/marin/transform/wikipedia/transform_wikipedia.py137 # Check if this is display math by looking for <dd> inside <dl>COMMENT
LOWlib/haliax/tests/test_axis.py144 # Check if the element is in the correct orderCOMMENT
Verbosity Indicators15 hits · 33 pts
SeverityFileLineSnippetContext
LOWexperiments/tutorials/hello_world.py73# Step 1: generate the data. build_config resolves ctx.output_path to the artifact's output dir.COMMENT
LOWexperiments/tutorials/hello_world.py82# Step 2: compute statistics over the generated data. ctx.artifact_path(_data) gives the pathCOMMENT
LOWtests/execution/test_step_runner.py119 # Step 1: downloadCOMMENT
LOWtests/execution/test_step_runner.py123 # Step 2: tokenize — load upstream artifact, run, saveCOMMENT
LOW…src/levanter/grug/attention/_fa4_cute_segmented_bwd.py321 # Do we need to check if we overshot kBlockM when we load Q?COMMENT
LOW…src/levanter/grug/attention/_fa4_cute_segmented_bwd.py323 # Do we need to check if we overshot kBlockN when we load K?COMMENT
LOW…src/levanter/grug/attention/_fa4_cute_segmented_bwd.py331 # Do we need to check if we overshot kBlockN when we load V?COMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py196 # Step 1: Divide Q into 𝑇𝑟 = \ceil(𝑁/Br) blocks of size Br x d each,COMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py199 # Step 2: init O_i = 0, sumexp_i = 0, max_i = -infCOMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py221 # Step 1: Divide Q into 𝑇𝑟 = \ceil(𝑁/Br) blocks of size Br x d each,COMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py227 # Step 8: compute Sij = QiKj^TCOMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py263 # Step 9: Compute m_i^j = max(m_i^{j-1}, rowmax(S_i^j)), P_i^j = exp(S_i^j - m_i^j),COMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py272 # Step 10: Compute O_i = diag(exp(m_i^{j-1} - m_i^j) O_i + P_i^j V_jCOMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py287 # Step 12: compute O_i = diag(\ell_i^{Tc})^{-1} O_i^{Tc}COMMENT
LOWlib/levanter/src/levanter/models/flash_attention.py289 # Step 13: compute L_i = m_i^{Tc} + log(\ell_i^{Tc})COMMENT
Fake / Example Data27 hits · 31 pts
SeverityFileLineSnippetContext
LOWtests/datakit/test_decon.py679 {"id": "eval", "text": "lorem ipsum dolor sit amet consectetur"},CODE
LOWtests/datakit/test_decon.py679 {"id": "eval", "text": "lorem ipsum dolor sit amet consectetur"},CODE
LOWtests/datakit/test_decon.py685 "text": "LOREM IPSUM DOLOR SIT AMET CONSECTETUR",CODE
LOWtests/datakit/test_decon.py685 "text": "LOREM IPSUM DOLOR SIT AMET CONSECTETUR",CODE
LOWlib/iris/tests/cluster/backends/gcp/test_gcp_service.py438 svc._token = "fake-token"CODE
LOWlib/iris/tests/cluster/backends/gcp/test_gcp_service.py529 svc._token = "fake-token"CODE
LOW…cluster/backends/gcp/test_cloud_service_integration.py292 s._token = "fake-token"CODE
LOWlib/iris/tests/cluster/controller/test_auth.py758 admin_users=["admin@example.com"],CODE
LOWlib/iris/tests/cluster/controller/test_auth.py764 assert auth.role_policy.role_for("admin@example.com") == "admin"CODE
LOWlib/iris/tests/cluster/controller/test_auth.py690 return VerifiedIdentity(user_id="admin@example.com", role=self._role)CODE
LOWlib/iris/tests/cluster/controller/test_auth.py707 assert seen == [VerifiedIdentity(user_id="admin@example.com", role="admin")]CODE
LOWlib/iris/src/iris/testing/config.py26 "placeholder": ScaleGroupConfig(CODE
LOWlib/iris/src/iris/testing/config.py27 name="placeholder",CODE
LOWlib/levanter/tests/test_tokenizers.py250 # Lorem ipsumCOMMENT
LOWlib/levanter/tests/test_tokenizers.py251 "Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt.",CODE
LOWlib/levanter/tests/test_tokenizers.py251 "Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt.",CODE
LOWlib/levanter/tests/test_tokenizers.py208 "user@example.com",CODE
LOWlib/levanter/tests/test_text.py155 lorem = """Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et doCODE
LOWlib/levanter/tests/test_text.py155 lorem = """Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et doCODE
LOWlib/levanter/tests/test_text.py177 text = "lorem ipsum dolor sit amet " * 12_000 # ~324k charsCODE
LOWlib/levanter/tests/test_text.py177 text = "lorem ipsum dolor sit amet " * 12_000 # ~324k charsCODE
LOWlib/levanter/tests/test_text.py305 "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et "CODE
LOWlib/levanter/tests/test_text.py305 "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et "CODE
LOWlib/marin/src/marin/inference/serve_dashboard.html21(()=>{"use strict";let e,t,n,r,l,i,s,o,a,c,u,p;var h,f,d,m={};function g(e){let t=Object.create(null);for(let n of e.splCODE
LOWlib/rigging/tests/test_server_auth.py163 roles = {"admin@example.com": "admin"}CODE
LOWlib/rigging/tests/test_server_auth.py168 payload = {"aud": "/projects/1/global/backendServices/2", "email": "admin@example.com"}CODE
LOWlib/rigging/tests/test_server_auth.py171 assert identity == VerifiedIdentity(user_id="admin@example.com", role="admin")CODE
Hallucination Indicators3 hits · 30 pts
SeverityFileLineSnippetContext
CRITICALlib/levanter/tests/test_apertus.py250 lev_alpha_p = float(layer.mlp.act_fn.alpha_p.array.item())CODE
CRITICALlib/levanter/tests/test_apertus.py251 lev_alpha_n = float(layer.mlp.act_fn.alpha_n.array.item())CODE
CRITICALlib/marin/src/marin/inference/serve_dashboard.html65`+l.text,this.inlineQueue.pop(),this.inlineQueue.at(-1).src=n.text):t.push(l);continue}if(e){this.infiniteLoopError(e.chCODE
Synthetic Comment Markers3 hits · 18 pts
SeverityFileLineSnippetContext
HIGHtests/snapshots/dclm_hq/inputs/hq_2.html87<p>Each locomotive is equipped with a mobile <a href="http://www.dccwiki.com/Decoder" class="extiw" title="dcc:Decoder">CODE
HIGHtests/snapshots/dclm_hq/inputs/hq_2.html426<p>Each locomotive is equipped with a mobile <a href="http://www.dccwiki.com/Decoder" class="extiw" title="dcc:Decoder">CODE
HIGHdocs/dev-guide/contributing.md9## AI-generated contributionsCOMMENT
Example Usage Blocks2 hits · 3 pts
SeverityFileLineSnippetContext
LOWscripts/iris/run_smoke_cw.sh8# Usage:COMMENT
LOWlib/levanter/scripts/clean_old_checkpoints.py78# Usage example:COMMENT
Slop Phrases1 hit · 2 pts
SeverityFileLineSnippetContext
MEDIUMtests/snapshots/stackexchange/inputs/chemistry_2.json3 "text": "# Hierarchy of electronic wavefunctions\n\n*The previous question contained too much unnecessary informatioCODE
Dead Code1 hit · 2 pts
SeverityFileLineSnippetContext
MEDIUMlib/levanter/tests/test_background_iterable.py116CODE
Overly Generic Function Names1 hit · 2 pts
SeverityFileLineSnippetContext
LOWtests/infra/ci/test_select_tests.py174 write(tmp_path, "lib/iris/tests/test_utils.py", "def helper():\n pass\n")CODE
TODO Padding1 hit · 2 pts
SeverityFileLineSnippetContext
LOWlib/levanter/src/levanter/models/gpt2_hyena.py69 # TODO: implementCOMMENT