Repository Analysis

datahub-project/datahub

The Context Platform for your Data and AI Stack

11.3 Low AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of datahub-project/datahub, a Python project with 12,424 GitHub stars. SynthScan v2.0 examined 3,607,764 lines of code across 15978 source files, recording 29883 pattern matches distributed across 27 syntactic categories. The overall adjusted score of 11.3 places this repository in the Low 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).

11.3
Adjusted Score
11.3
Raw Score
100%
Time Factor
2026-08-01
Last Push
12.4K
Stars
Python
Language
3.6M
Lines of Code
16.0K
Files
29.9K
Pattern Hits
2026-08-02
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

This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.

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 474HIGH 442MEDIUM 2612LOW 26355

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 29883 distinct pattern matches across 27 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 Identifiers19213 hits · 17350 pts
SeverityFileLineSnippetContext
LOW…cker/snippets/ingestion/build_bundled_venvs_unified.py35def _print_subprocess_failure(proc: subprocess.CompletedProcess[str]) -> None:CODE
LOW…cker/snippets/ingestion/build_bundled_venvs_unified.py42def _verify_installed_acryl_datahub_version(CODE
LOWdocker/snippets/ingestion/bundled_venv_config.py65def bundled_venv_symlink_names(group_plan: BundledVenvGroupPlan) -> Tuple[str, ...]:CODE
LOWdocker/snippets/ingestion/bundled_venv_config.py73def _default_plugin_extras_for_plugin(plugin: str, slim_mode: bool) -> List[str]:CODE
LOWdocker/snippets/ingestion/bundled_venv_config.py117def groups_config_from_plugin_group_env(CODE
LOW…icsearch/query/request/AutocompleteRequestHandler.java51public class AutocompleteRequestHandler extends BaseRequestHandler {CODE
LOW…ch/elasticsearch/query/request/BaseRequestHandler.java12public abstract class BaseRequestHandler {CODE
LOW…/elasticsearch/query/request/SearchRequestHandler.java78public class SearchRequestHandler extends BaseRequestHandler {CODE
LOWperf-test/authz-perf/compare.py15def _row_effective_expectation(row: dict) -> int:CODE
LOWperf-test/authz-perf/compare.py114def _unmatched_metric_warnings(CODE
LOWperf-test/authz-perf/executor.py45def _maybe_jitter_search_variables(CODE
LOWperf-test/authz-perf/tests/test_run_multi.py10def test_output_dir_writes_manifest(mock_run, mock_gms, tmp_path: Path) -> None:CODE
LOWperf-test/authz-perf/tests/test_run_multi.py57def test_fail_fast_stops_on_error(mock_run, mock_gms, tmp_path: Path) -> None:CODE
LOWperf-test/authz-perf/tests/test_graphql_adapt_loader.py6def test_resolve_operation_document_delegates_to_registry() -> None:CODE
LOWperf-test/authz-perf/tests/test_targets.py28def test_parse_target_requires_name() -> None:CODE
LOWperf-test/authz-perf/tests/test_targets.py59def test_env_file_hidden_name() -> None:CODE
LOWperf-test/authz-perf/tests/test_targets.py65def test_env_file_name_override(tmp_path: Path) -> None:CODE
LOWperf-test/authz-perf/tests/test_targets.py81def test_gms_url_creates_local_target() -> None:CODE
LOWperf-test/authz-perf/tests/test_results.py7def test_jsonl_append_and_summary(tmp_path: Path) -> None:CODE
LOWperf-test/authz-perf/tests/test_stats.py10def test_compute_stats_max_not_trimmed() -> None:CODE
LOWperf-test/authz-perf/tests/test_output_paths.py12def test_build_slug_prefers_run_label() -> None:CODE
LOWperf-test/authz-perf/tests/test_output_paths.py18def test_build_slug_git_commit() -> None:CODE
LOWperf-test/authz-perf/tests/test_output_paths.py24def test_result_paths_single_local_bisect() -> None:CODE
LOWperf-test/authz-perf/tests/test_output_paths.py36def test_result_paths_multi_cell() -> None:CODE
LOWperf-test/authz-perf/tests/test_run_graphql_setup.py12def test_run_single_target_generates_queries(CODE
LOWperf-test/authz-perf/tests/test_query_build.py23def test_build_operation_document_minimal() -> None:CODE
LOWperf-test/authz-perf/tests/test_query_build.py41def test_build_omits_missing_paths() -> None:CODE
LOWperf-test/authz-perf/tests/test_query_build.py57def test_resolve_operation_document_with_registry() -> None:CODE
LOWperf-test/authz-perf/tests/test_benchmarks.py10def test_all_personas_have_core_ops() -> None:CODE
LOWperf-test/authz-perf/tests/test_benchmarks.py31def test_query_specs_cover_all_scenarios() -> None:CODE
LOWperf-test/authz-perf/tests/test_benchmarks.py44def test_get_me_uses_privilege_expand() -> None:CODE
LOWperf-test/authz-perf/tests/test_gms_config.py34def test_fetch_gms_config_failure(mock_get: MagicMock) -> None:CODE
LOWperf-test/authz-perf/tests/test_session.py8def test_persona_session_reuses_same_session() -> None:CODE
LOWperf-test/authz-perf/tests/test_graphql_adapt.py12def test_create_graphql_query_registry(mock_cls: MagicMock) -> None:CODE
LOWperf-test/authz-perf/tests/test_graphql_adapt.py24def test_setup_graphql_queries(mock_create: MagicMock) -> None:CODE
LOW…rf-test/authz-perf/tests/test_persona_password_seed.py16def test_local_password_unchanged() -> None:CODE
LOW…rf-test/authz-perf/tests/test_persona_password_seed.py22def test_derive_persona_password_deterministic(CODE
LOW…rf-test/authz-perf/tests/test_persona_password_seed.py35def test_derive_persona_password_varies_by_host(CODE
LOW…rf-test/authz-perf/tests/test_persona_password_seed.py47def test_load_or_create_seed_from_env(tmp_path, monkeypatch) -> None:CODE
LOWperf-test/authz-perf/tests/test_personas.py9def test_personas_oracle_has_seventeen_entries() -> None:CODE
LOWperf-test/authz-perf/tests/test_variants.py4def test_parse_variants_default() -> None:CODE
LOWperf-test/authz-perf/tests/test_variants.py8def test_parse_variants_run_labels() -> None:CODE
LOWperf-test/authz-perf/tests/test_variants.py14def test_parse_variants_docker_tags() -> None:CODE
LOWperf-test/authz-perf/tests/test_metadata.py7def test_capture_git_metadata() -> None:CODE
LOWperf-test/authz-perf/tests/test_metadata.py12def test_capture_deployment_metadata() -> None:CODE
LOWperf-test/authz-perf/tests/test_metadata.py25def test_deployment_docker_tag() -> None:CODE
LOWperf-test/authz-perf/tests/test_credentials.py8def test_uses_datahubenv_token() -> None:CODE
LOWperf-test/authz-perf/tests/test_credentials.py21def test_gms_url_cli_overrides_config() -> None:CODE
LOWperf-test/authz-perf/tests/test_credentials.py34def test_mints_token_from_username_password() -> None:CODE
LOWperf-test/authz-perf/tests/test_credentials.py58def test_no_credentials_non_interactive_exits() -> None:CODE
LOWperf-test/authz-perf/tests/test_credentials.py67def test_merges_datahubenv_token_when_env_url_only(CODE
LOWperf-test/authz-perf/tests/test_expectations.py19def test_view_authorization_from_properties_prefers_dot_key() -> None:CODE
LOWperf-test/authz-perf/tests/test_expectations.py31def test_adapt_benchmarks_keeps_fixture_when_view_auth_enabled() -> None:CODE
LOWperf-test/authz-perf/tests/test_expectations.py51def test_adapt_benchmarks_relaxes_deny_when_view_auth_disabled() -> None:CODE
LOWperf-test/authz-perf/tests/test_expectations.py71def test_metric_key_and_profile_for_adapted_deny() -> None:CODE
LOWperf-test/authz-perf/tests/test_expectations.py86def test_metric_key_for_authz_deny() -> None:CODE
LOWperf-test/authz-perf/tests/test_expectations.py100def test_warn_authorization_settings_drift() -> None:CODE
LOWperf-test/authz-perf/tests/test_graphql_health.py25def test_execute_graphql_success() -> None:CODE
LOWperf-test/authz-perf/tests/test_graphql_health.py51def test_execute_graphql_http_error() -> None:CODE
LOWperf-test/authz-perf/tests/test_graphql_health.py79def test_request_health_tracker_status_mismatch() -> None:CODE
19153 more matches not shown…
Decorative Section Separators1987 hits · 7014 pts
SeverityFileLineSnippetContext
MEDIUM…/metadata/aspect/hooks/AspectMigrationMutatorTest.java85 // ── Read mutation ──────────────────────────────────────────────────────────COMMENT
MEDIUM…/metadata/aspect/hooks/AspectMigrationMutatorTest.java169 // ── Write mutation ─────────────────────────────────────────────────────────COMMENT
MEDIUM…/metadata/aspect/hooks/AspectMigrationMutatorTest.java230 // ── Helpers ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…data/aspect/hooks/AspectMigrationMutatorChainTest.java57 // ── Empty chain ────────────────────────────────────────────────────────────COMMENT
MEDIUM…data/aspect/hooks/AspectMigrationMutatorChainTest.java93 // ── Single-hop chain ───────────────────────────────────────────────────────COMMENT
MEDIUM…data/aspect/hooks/AspectMigrationMutatorChainTest.java163 // ── Multi-hop chain ────────────────────────────────────────────────────────COMMENT
MEDIUM…data/aspect/hooks/AspectMigrationMutatorChainTest.java185 // ── Gap bridging ──────────────────────────────────────────────────────────COMMENT
MEDIUM…data/aspect/hooks/AspectMigrationMutatorChainTest.java401 // ── Self-disable ───────────────────────────────────────────────────────────COMMENT
MEDIUM…data/aspect/hooks/AspectMigrationMutatorChainTest.java431 // ── Priority ───────────────────────────────────────────────────────────────COMMENT
MEDIUM…data/aspect/hooks/AspectMigrationMutatorChainTest.java439 // ── Helpers ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…metadata/aspect/hooks/AspectMigrationMutatorChain.java111 // ── Read path ──────────────────────────────────────────────────────────────COMMENT
MEDIUM…metadata/aspect/hooks/AspectMigrationMutatorChain.java164 // ── Write path ─────────────────────────────────────────────────────────────COMMENT
MEDIUM…edin/metadata/aspect/hooks/AspectMigrationMutator.java67 // ── Read path ──────────────────────────────────────────────────────────────COMMENT
MEDIUM…edin/metadata/aspect/hooks/AspectMigrationMutator.java109 // ── Write path ─────────────────────────────────────────────────────────────COMMENT
MEDIUM…edin/metadata/aspect/hooks/AspectMigrationMutator.java145 // ── Helpers ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…raphql/resolvers/timeline/GetTimelineResolverTest.java107 // ── includeVersionSet tests ───────────────────────────────────────────────COMMENT
MEDIUM…raphql/resolvers/timeline/GetTimelineResolverTest.java378 // ── Helpers ───────────────────────────────────────────────────────────────COMMENT
MEDIUM…edin/metadata/entity/EbeanAspectMigrationsDaoTest.java83 // ── streamAspectBatchesForMigration ───────────────────────────────────────COMMENT
MEDIUM…data/search/utils/ESUtilsLifecycleStageFilterTest.java129 // ── Helpers ─────────────────────────────────────────────────────────────────COMMENT
MEDIUM…/queue/postgres/EbeanPostgresMetadataQueueStoreIT.java762 // ── Priority queue integration tests ──────────────────────────────────────COMMENT
MEDIUM…metadata/aspect/hooks/DomainsSyncMutationHookTest.java59 // ── Legacy path: only domains provided ─────────────────────────────────────COMMENT
MEDIUM…metadata/aspect/hooks/DomainsSyncMutationHookTest.java131 // ── New path: domainAssociations provided ──────────────────────────────────COMMENT
MEDIUM…metadata/aspect/hooks/DomainsSyncMutationHookTest.java202 // ── Conflict detection ─────────────────────────────────────────────────────COMMENT
MEDIUM…metadata/aspect/hooks/DomainsSyncMutationHookTest.java279 // ── Read-modify-write scenarios ───────────────────────────────────────────COMMENT
MEDIUM…metadata/aspect/hooks/DomainsSyncMutationHookTest.java334 // ── Edge cases ─────────────────────────────────────────────────────────────COMMENT
MEDIUM…metadata/aspect/hooks/DomainsSyncMutationHookTest.java388 // ── Ordering: manual before propagated ───────────────────────────────────COMMENT
MEDIUM…metadata/aspect/hooks/DomainsSyncMutationHookTest.java509 // ── Helpers ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ata/aspect/hooks/LifecycleStageTransitionHookTest.java268 // ── Helpers ─────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ntgenerator/VersionPropertiesChangeEventGenerator.java86 // ── getChangeEvents (preferred path) ──────────────────────────────────────COMMENT
MEDIUM…ntgenerator/VersionPropertiesChangeEventGenerator.java99 // ── Core diff logic ───────────────────────────────────────────────────────COMMENT
MEDIUM…nt-context/tests/unit/google_adk_tools/test_builder.py144# ---------------------------------------------------------------------------COMMENT
MEDIUM…nt-context/tests/unit/google_adk_tools/test_builder.py146# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py42# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py44# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py54# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py56# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py76# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py78# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py185# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py187# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py224# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py226# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py247# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py249# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py8# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/google_adk_registration/test_plugin.py10# ---------------------------------------------------------------------------COMMENT
MEDIUM…ent-context/tests/unit/langchain_tools/test_builder.py162# ---------------------------------------------------------------------------COMMENT
MEDIUM…ent-context/tests/unit/langchain_tools/test_builder.py164# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/langchain_registration/test_handler.py63# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/langchain_registration/test_handler.py65# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/langchain_registration/test_handler.py161# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/langchain_registration/test_handler.py163# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/langchain_registration/test_handler.py290# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/langchain_registration/test_handler.py292# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/langchain_registration/test_handler.py360# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/langchain_registration/test_handler.py362# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/langchain_registration/test_handler.py19# ---------------------------------------------------------------------------COMMENT
MEDIUM…text/tests/unit/langchain_registration/test_handler.py21# ---------------------------------------------------------------------------COMMENT
MEDIUM…agent-context/tests/unit/mcp_tools/test_ask_datahub.py75# ---------------------------------------------------------------------------COMMENT
MEDIUM…agent-context/tests/unit/mcp_tools/test_ask_datahub.py77# ---------------------------------------------------------------------------COMMENT
1927 more matches not shown…
Hallucination Indicators474 hits · 5075 pts
SeverityFileLineSnippetContext
CRITICALdatahub-frontend/app/auth/AuthModule.java427 com.linkedin.metadata.utils.BasePathUtils.resolveBasePath(CODE
CRITICALdatahub-frontend/app/auth/AuthModule.java490 return com.linkedin.metadata.utils.BasePathUtils.resolveBasePath(basePathEnabled, basePath);CODE
CRITICALdatahub-frontend/app/controllers/Application.java280 org.apache.pekko.stream.javadsl.StreamConverters.fromInputStream(CODE
CRITICALdatahub-frontend/test/oidc/OidcCallbackLogicTest.java32 org.junit.jupiter.api.Assertions.assertDoesNotThrow(CODE
CRITICALdatahub-frontend/test/oidc/OidcCallbackLogicTest.java47 org.junit.jupiter.api.Assertions.assertThrows(CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java239 .when(() -> com.linkedin.metadata.utils.BasePathUtils.normalizeBasePath(""))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java269 .when(() -> com.linkedin.metadata.utils.BasePathUtils.normalizeBasePath("/datahub"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java299 .when(() -> com.linkedin.metadata.utils.BasePathUtils.normalizeBasePath("/api/v2"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java302 .when(() -> com.linkedin.metadata.utils.BasePathUtils.addBasePath("/login", "/api/v2"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java332 .when(() -> com.linkedin.metadata.utils.BasePathUtils.normalizeBasePath(""))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java335 .when(() -> com.linkedin.metadata.utils.BasePathUtils.addBasePath("/login", ""))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java377 .when(() -> com.linkedin.metadata.utils.BasePathUtils.normalizeBasePath("/datahub"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java381 () -> com.linkedin.metadata.utils.BasePathUtils.addBasePath(anyString(), anyString()))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java432 .when(() -> com.linkedin.metadata.utils.BasePathUtils.normalizeBasePath("/datahub"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java435 .when(() -> com.linkedin.metadata.utils.BasePathUtils.addBasePath("/logOut", "/datahub"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java439 () -> com.linkedin.metadata.utils.BasePathUtils.addBasePath(anyString(), anyString()))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java487 .when(() -> com.linkedin.metadata.utils.BasePathUtils.normalizeBasePath("/api/v2"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java491 () -> com.linkedin.metadata.utils.BasePathUtils.addBasePath(anyString(), anyString()))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java538 .when(() -> com.linkedin.metadata.utils.BasePathUtils.normalizeBasePath("/datahub"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java542 () -> com.linkedin.metadata.utils.BasePathUtils.addBasePath(anyString(), anyString()))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java588 .when(() -> com.linkedin.metadata.utils.BasePathUtils.normalizeBasePath("/api/v2"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java592 () -> com.linkedin.metadata.utils.BasePathUtils.addBasePath("/dashboard", "/api/v2"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java595 .when(() -> com.linkedin.metadata.utils.BasePathUtils.addBasePath("/", "/api/v2"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java643 .when(() -> com.linkedin.metadata.utils.BasePathUtils.normalizeBasePath("/datahub"))CODE
CRITICAL…end/test/controllers/AuthenticationControllerTest.java647 () -> com.linkedin.metadata.utils.BasePathUtils.addBasePath(anyString(), anyString()))CODE
CRITICAL…data/models/EntitySpecBuilderSearchIndexGroupTest.java124 new com.linkedin.metadata.models.annotation.AspectAnnotation(name, false, false, null, 1L),CODE
CRITICAL…com/linkedin/metadata/models/ConfigEntitySpecTest.java126 new com.linkedin.metadata.models.annotation.AspectAnnotation(name, false, false, null, 1L),CODE
CRITICAL…va/com/linkedin/metadata/aspect/models/graph/Edge.java151 com.linkedin.metadata.query.filter.SortOrder.valueOf(CODE
CRITICAL…b/graphql/types/dataset/mappers/DatasetMapperTest.java69 new com.linkedin.datahub.graphql.generated.AuditStamp(CODE
CRITICAL…b/graphql/types/dataset/mappers/DatasetMapperTest.java119 new com.linkedin.datahub.graphql.generated.AuditStamp(0L, null));CODE
CRITICAL…b/graphql/types/dataset/mappers/DatasetMapperTest.java174 new com.linkedin.datahub.graphql.generated.AuditStamp(20L, null));CODE
CRITICAL…ql/types/dataset/mappers/DatasetProfileMapperTest.java86 new com.linkedin.datahub.graphql.generated.DatasetFieldProfile(CODE
CRITICAL…ql/types/dataset/mappers/DatasetProfileMapperTest.java100 new com.linkedin.datahub.graphql.generated.Quantile("0.25", "1"),CODE
CRITICAL…ql/types/dataset/mappers/DatasetProfileMapperTest.java101 new com.linkedin.datahub.graphql.generated.Quantile("0.75", "5"))),CODE
CRITICAL…ql/types/dataset/mappers/DatasetProfileMapperTest.java104 new com.linkedin.datahub.graphql.generated.ValueFrequency("2", 10L)))),CODE
CRITICAL…ql/types/dataset/mappers/DatasetProfileMapperTest.java105 new com.linkedin.datahub.graphql.generated.DatasetFieldProfile(CODE
CRITICAL…ql/types/dataset/mappers/DatasetProfileMapperTest.java119 new com.linkedin.datahub.graphql.generated.Quantile("0.25", "1"),CODE
CRITICAL…ql/types/dataset/mappers/DatasetProfileMapperTest.java120 new com.linkedin.datahub.graphql.generated.Quantile("0.75", "5"))),CODE
CRITICAL…ql/types/dataset/mappers/DatasetProfileMapperTest.java123 new com.linkedin.datahub.graphql.generated.ValueFrequency(CODE
CRITICAL…ql/types/dataset/mappers/DatasetProfileMapperTest.java255 new com.linkedin.datahub.graphql.generated.DatasetFieldProfile(CODE
CRITICAL…ql/types/dataset/mappers/DatasetProfileMapperTest.java258 new com.linkedin.datahub.graphql.generated.DatasetFieldProfile(CODE
CRITICAL…pes/dataplatforminstance/DataPlatformInstanceTest.java203 new com.linkedin.datahub.graphql.types.dataplatforminstance.DataPlatformInstanceType(CODE
CRITICAL…datahub/graphql/types/assertion/AssertionTypeTest.java106 new com.linkedin.datahub.graphql.types.assertion.AssertionType(client);CODE
CRITICAL…datahub/graphql/types/assertion/AssertionTypeTest.java151 new com.linkedin.datahub.graphql.types.assertion.AssertionType(mockClient);CODE
CRITICAL…atahub/graphql/types/knowledge/DocumentMapperTest.java868 com.google.common.collect.ImmutableList.of(CODE
CRITICAL…in/datahub/graphql/types/view/DataHubViewTypeTest.java180 new com.linkedin.datahub.graphql.types.view.DataHubViewType(client);CODE
CRITICAL…in/datahub/graphql/types/view/DataHubViewTypeTest.java249 new com.linkedin.datahub.graphql.types.view.DataHubViewType(client);CODE
CRITICAL…in/datahub/graphql/types/view/DataHubViewTypeTest.java289 new com.linkedin.datahub.graphql.types.view.DataHubViewType(mockClient);CODE
CRITICAL…in/datahub/graphql/types/view/DataHubViewTypeTest.java336 new com.linkedin.datahub.graphql.types.view.DataHubViewType(client);CODE
CRITICAL…in/datahub/graphql/types/view/DataHubViewTypeTest.java381 new com.linkedin.datahub.graphql.types.view.DataHubViewType(client);CODE
CRITICAL…in/datahub/graphql/types/view/DataHubViewTypeTest.java448 new com.linkedin.datahub.graphql.types.view.DataHubViewType(client);CODE
CRITICAL…datahub/graphql/types/incident/IncidentMapperTest.java120 com.linkedin.datahub.graphql.generated.IncidentType.FIELD.toString());CODE
CRITICAL…datahub/graphql/types/incident/IncidentMapperTest.java127 com.linkedin.datahub.graphql.generated.IncidentSourceType.ASSERTION_FAILURE.toString());CODE
CRITICAL…datahub/graphql/types/incident/IncidentMapperTest.java131 com.linkedin.datahub.graphql.generated.IncidentState.ACTIVE.toString());CODE
CRITICAL…datahub/graphql/types/incident/IncidentMapperTest.java134 com.linkedin.datahub.graphql.generated.IncidentState.ACTIVE.toString());CODE
CRITICAL…datahub/graphql/types/incident/IncidentMapperTest.java137 com.linkedin.datahub.graphql.generated.IncidentStage.INVESTIGATION.toString());CODE
CRITICAL…n/datahub/graphql/types/incident/IncidentTypeTest.java108 new com.linkedin.datahub.graphql.types.incident.IncidentType(client);CODE
CRITICAL…n/datahub/graphql/types/incident/IncidentTypeTest.java167 new com.linkedin.datahub.graphql.types.incident.IncidentType(mockClient);CODE
CRITICAL…b/graphql/types/mappers/UnsafeEnumValueOfLintTest.java54 "com.linkedin.datahub.graphql.generated.DataHubConnectionDetailsType.valueOf( gmsDetails.getType().toSCODE
CRITICAL…b/graphql/types/mappers/UnsafeEnumValueOfLintTest.java288 "com.linkedin.datahub.graphql.generated.OriginType.valueOf( groupOrigin.getType().toString())"),CODE
414 more matches not shown…
Excessive Try-Catch Wrapping2002 hits · 1923 pts
SeverityFileLineSnippetContext
LOW…cker/snippets/ingestion/build_bundled_venvs_unified.py71except Exception:CODE
LOW…cker/snippets/ingestion/build_bundled_venvs_unified.py287 except Exception as e:CODE
LOWperf-test/authz-perf/run.py456 except Exception as exc:CODE
LOWperf-test/authz-perf/executor.py268 except Exception as exc:CODE
LOWperf-test/authz-perf/lib/credentials.py76 except Exception:CODE
LOWdatahub-agent-context/examples/langchain/basic_agent.py239 except Exception as e:CODE
LOW…tahub-agent-context/examples/google_adk/basic_agent.py238 except Exception as e:CODE
LOW…ontext/src/datahub_agent_context/_registration_core.py216 except Exception as exc:CODE
LOW…ontext/src/datahub_agent_context/_registration_core.py298 except Exception as exc:CODE
LOW…ontext/src/datahub_agent_context/_registration_core.py377 except Exception as exc:CODE
LOW…hub_agent_context/google_adk_registration/decorator.py35 except Exception:CODE
LOW…hub_agent_context/google_adk_registration/decorator.py54 except Exception:CODE
LOW…hub_agent_context/google_adk_registration/decorator.py60 except Exception:CODE
LOW…atahub_agent_context/google_adk_registration/plugin.py66 except Exception:CODE
LOW…atahub_agent_context/google_adk_registration/plugin.py89 except Exception:CODE
LOW…atahub_agent_context/google_adk_registration/plugin.py175 except Exception as exc:CODE
LOW…atahub_agent_context/google_adk_registration/plugin.py193 except Exception as exc:CODE
LOW…atahub_agent_context/google_adk_registration/plugin.py198 except Exception as exc:CODE
LOW…ntext/src/datahub_agent_context/snowflake/snowflake.py286 except Exception as e:CODE
LOW…ntext/src/datahub_agent_context/snowflake/snowflake.py295 except Exception as e:CODE
LOW…ntext/src/datahub_agent_context/snowflake/snowflake.py659 except Exception as e:CODE
LOW…hub_agent_context/snowflake/udfs/add_glossary_terms.py44except Exception as e:CODE
LOW…agent_context/snowflake/udfs/get_dataset_assertions.py56except Exception as e:CODE
LOW…_agent_context/snowflake/udfs/remove_glossary_terms.py40except Exception as e:CODE
LOW…c/datahub_agent_context/snowflake/udfs/get_entities.py34except Exception as e:CODE
LOW…t/src/datahub_agent_context/snowflake/udfs/add_tags.py44except Exception as e:CODE
LOW…context/snowflake/udfs/remove_structured_properties.py40except Exception as e:CODE
LOW…rc/datahub_agent_context/snowflake/udfs/remove_tags.py40except Exception as e:CODE
LOW…nt_context/snowflake/udfs/get_lineage_paths_between.py49except Exception as e:CODE
LOW…rc/datahub_agent_context/snowflake/udfs/get_lineage.py41except Exception as e:CODE
LOW…nt_context/snowflake/udfs/add_structured_properties.py41except Exception as e:CODE
LOW…datahub_agent_context/snowflake/udfs/search_datahub.py56except Exception as e:CODE
LOW…hub_agent_context/snowflake/udfs/update_description.py42except Exception as e:CODE
LOW…tahub_agent_context/snowflake/udfs/get_datahub_chat.py41except Exception as e:CODE
LOW…tahub_agent_context/snowflake/udfs/ask_datahub_chat.py38except Exception as e:CODE
LOW…rc/datahub_agent_context/snowflake/udfs/set_domains.py39except Exception as e:CODE
LOW…src/datahub_agent_context/snowflake/udfs/add_owners.py42except Exception as e:CODE
LOW…datahub_agent_context/snowflake/udfs/remove_domains.py32except Exception as e:CODE
LOW…/datahub_agent_context/snowflake/udfs/remove_owners.py39except Exception as e:CODE
LOW…ub_agent_context/snowflake/udfs/get_dataset_queries.py49except Exception as e:CODE
LOW…datahub_agent_context/snowflake/udfs/grep_documents.py50except Exception as e:CODE
LOW…tahub_agent_context/snowflake/udfs/search_documents.py50except Exception as e:CODE
LOW…hub_agent_context/snowflake/udfs/list_schema_fields.py62except Exception as e:CODE
LOW…ext/src/datahub_agent_context/snowflake/udfs/get_me.py38except Exception as e:CODE
LOW…atahub_agent_context/langchain_registration/handler.py34 except Exception:CODE
LOW…atahub_agent_context/langchain_registration/handler.py37 except Exception:CODE
LOW…atahub_agent_context/langchain_registration/handler.py126 except Exception as exc:CODE
LOW…ahub_agent_context/langchain_registration/decorator.py43 except Exception:CODE
LOW…ahub_agent_context/langchain_registration/decorator.py60 except Exception:CODE
LOW…ahub_agent_context/langchain_registration/decorator.py67 except Exception:CODE
LOW…t-context/src/datahub_agent_context/mcp_tools/terms.py67 except Exception as e:STRING
LOW…t-context/src/datahub_agent_context/mcp_tools/terms.py156 except Exception as e:STRING
LOW…nt-context/src/datahub_agent_context/mcp_tools/tags.py68 except Exception as e:STRING
LOW…nt-context/src/datahub_agent_context/mcp_tools/tags.py157 except Exception as e:STRING
LOW…ext/src/datahub_agent_context/mcp_tools/ask_datahub.py180 except Exception as e:CODE
LOW…ext/src/datahub_agent_context/mcp_tools/ask_datahub.py309 except Exception as e:CODE
LOW…tahub_agent_context/mcp_tools/structured_properties.py77 except Exception as e:STRING
LOW…tahub_agent_context/mcp_tools/structured_properties.py143 except Exception as e:STRING
LOW…tahub_agent_context/mcp_tools/structured_properties.py320 except Exception as e:STRING
LOW…tahub_agent_context/mcp_tools/structured_properties.py432 except Exception as e:STRING
1942 more matches not shown…
Self-Referential Comments458 hits · 1464 pts
SeverityFileLineSnippetContext
MEDIUMdocker/quickstart/docker-compose.quickstart-profile.yml1# This file is generated as part of build process. If any build changes cause this file to be modified, please check in COMMENT
MEDIUMdocker/quickstart/quickstart_version_mapping.yaml1# This file is used by the CLI to map quickstart version "labels" to docker tags and git refs.COMMENT
MEDIUM…ent-context/tests/unit/mcp_tools/test_save_document.py286 # Create a mock document that is NOT in the agent hierarchyCOMMENT
MEDIUM…t/src/datahub_agent_context/mcp_tools/save_document.py279 # Create the documentCOMMENT
MEDIUM…t/src/datahub_agent_context/mcp_tools/save_document.py576 # Create the documentCOMMENT
MEDIUM…ceberg-catalog/src/integrationTest/integration_test.py59 # Create a Spark sessionSTRING
MEDIUM…gin/source/acryl/test_datahub_cloud_events_consumer.py204 dummy_response = Response() # Create a dummy Response objectCODE
MEDIUM…plugin/source/acryl/test_datahub_cloud_event_source.py422 # Create a realistic MCL event based on the documented formatCOMMENT
MEDIUM…plugin/source/acryl/test_datahub_cloud_event_source.py508 # Create a realistic MCL event based on documented formatCOMMENT
MEDIUM…yl/test_datahub_cloud_events_consumer_offsets_store.py116 # Create a mock PlatformResourceInfoClass that includes our serialized stateCOMMENT
MEDIUMdatahub-actions/tests/unit/utils/test_kafka_msk_iam.py23 # Create a minimal fake module matching the direct import pathCOMMENT
MEDIUM…in/action/metadata_change_sync/metadata_change_sync.py171 # Create an emitter to DataHub over RESTCOMMENT
MEDIUMsmoke-test/test_system_info.py288 # Create a limited-privilege user (no special privileges by default)COMMENT
MEDIUMsmoke-test/test_authentication_e2e.py355 # Create a limited-privilege user for testingCOMMENT
MEDIUMsmoke-test/test_e2e.py1122 # Creating the same user again failsCOMMENT
MEDIUM…e-test/tests/service_accounts/test_service_accounts.py590 # Create a service account with a unique display nameCOMMENT
MEDIUM…e-test/tests/service_accounts/test_service_accounts.py593 # Create the service accountCOMMENT
MEDIUM…oke-test/tests/cli/dataset_cmd/test_dataset_command.py98 # Create a dataset YAML fileCOMMENT
MEDIUM…oke-test/tests/cli/dataset_cmd/test_dataset_command.py152 # Create a minimal dataset YAML as a starting pointCOMMENT
MEDIUMsmoke-test/tests/openapi/v1/test_tracking.py57 # Create a test event with a unique identifierCOMMENT
MEDIUMsmoke-test/tests/openapi/v1/test_tracking.py236 # Create a Kafka consumer for DUE events BEFORE sending the eventCOMMENT
MEDIUMsmoke-test/tests/openapi/v1/test_tracking.py372 # Create a test event with a unique identifierCOMMENT
MEDIUMsmoke-test/tests/openapi/v1/test_tracking.py377 # Create a test event that mimics a real PageViewEventCOMMENT
MEDIUMsmoke-test/tests/openapi/v1/test_tracking.py422 # Create a query to find our test event by the unique browserId and customFieldCOMMENT
MEDIUMsmoke-test/tests/privileges/test_privileges.py65 # Create a new userCOMMENT
MEDIUMsmoke-test/tests/privileges/test_privileges.py225 # Create a secretCOMMENT
MEDIUMsmoke-test/tests/privileges/test_privileges.py389 # Create a access tokenCOMMENT
MEDIUMsmoke-test/tests/privileges/test_privileges.py501 # Create a policyCOMMENT
MEDIUMsmoke-test/tests/privileges/test_privileges.py590 # Create a secretCOMMENT
MEDIUMsmoke-test/tests/privileges/utils.py292 # Create a new user using the invite tokenCOMMENT
MEDIUM…ts/structured_properties/test_structured_properties.py635 # Create a test structured propertyCOMMENT
MEDIUMsmoke-test/tests/patch/test_datajob_patches.py172 # Create the data jobCOMMENT
MEDIUM…st/tests/knowledge/test_document_hierarchy_settings.py394 # Create a documentSTRING
MEDIUM…e-test/tests/knowledge/document_change_history_test.py40 # Create a documentCOMMENT
MEDIUM…e-test/tests/knowledge/document_change_history_test.py158 # Create a documentCOMMENT
MEDIUM…e-test/tests/knowledge/document_change_history_test.py228 # Create a documentCOMMENT
MEDIUMsmoke-test/tests/lineage/test_lineage.py831 # Create an emitter to the GMS REST API.COMMENT
MEDIUMsmoke-test/tests/semantic/test_event_mode_fallback.py541 # Create a new document to trigger an eventCOMMENT
MEDIUM…test/tests/managed_ingestion/managed_ingestion_test.py577 # Create a request to execute the ingestion sourceCOMMENT
MEDIUM…esources/analytics_backfill/generate_glossary_terms.py93 # Create a URL-friendly term IDCOMMENT
MEDIUM…st_resources/actions/datasets_for_cycles_template.yaml1# This file is used to define a dataset and provide metadata for itCOMMENT
MEDIUM…oke-test/test_resources/actions/datasets_template.yaml1# This file is used to define a dataset and provide metadata for itCOMMENT
MEDIUM…irflow-plugin/tests/unit/test_airflow_asset_adapter.py57 # Create a real Asset-named class with uriCOMMENT
MEDIUM…irflow-plugin/tests/unit/test_airflow_asset_adapter.py66 # Create a real Dataset-named class with uriCOMMENT
MEDIUM…n/java/acryl-spark-lineage/scripts/generate-patches.sh58 # Create a note file indicating this is a DataHub-specific additionCOMMENT
MEDIUMscripts/dev/tests/test_datahub_dev.py148 # Create a stale env file + sentinel for a branch that doesn't existCOMMENT
MEDIUM.github/workflows/metadata-ingestion.yml362 # Create a fresh venv for this pluginCOMMENT
MEDIUM.github/scripts/dep-analyzer.py305 # Create a fake module contextCOMMENT
MEDIUMmetadata-ingestion/pyproject.toml3# This file is generated from setup.py by:COMMENT
MEDIUM…tadata-ingestion/tests/unit/test_thoughtspot_source.py2517 # Create a visualization with full metadataCOMMENT
MEDIUM…tadata-ingestion/tests/unit/test_thoughtspot_source.py2642 # Create a liveboard with visualizationsCOMMENT
MEDIUM…tadata-ingestion/tests/unit/test_thoughtspot_source.py4432 # Create a worksheet/table modelSTRING
MEDIUMmetadata-ingestion/tests/unit/test_gc.py213 # Create a reportCOMMENT
MEDIUMmetadata-ingestion/tests/unit/test_gc.py216 # Create the test instanceCOMMENT
MEDIUMmetadata-ingestion/tests/unit/test_gc.py224 # Create a sample URNCOMMENT
MEDIUMmetadata-ingestion/tests/unit/test_gc.py200 # Create a default configCOMMENT
MEDIUMmetadata-ingestion/tests/unit/test_gc.py620 # Create a default configCOMMENT
MEDIUMmetadata-ingestion/tests/unit/test_gc.py631 # Create a reportCOMMENT
MEDIUMmetadata-ingestion/tests/unit/test_gc.py634 # Create the test instanceCOMMENT
MEDIUMmetadata-ingestion/tests/unit/test_gc.py754 # Define a side effect function that simulates the behavior of _process_futuresCOMMENT
398 more matches not shown…
Modern Structural Boilerplate973 hits · 1005 pts
SeverityFileLineSnippetContext
LOW…ontext/src/datahub_agent_context/_registration_core.py33logger = logging.getLogger(__name__)CODE
LOW…ub-agent-context/src/datahub_agent_context/__init__.py27__all__ = [CODE
LOWdatahub-agent-context/src/datahub_agent_context/cli.py7logger = logging.getLogger(__name__)CODE
LOW…src/datahub_agent_context/google_adk_tools/__init__.py11__all__ = ["build_google_adk_tools", "build_google_adk_cloud_tools"]CODE
LOW…hub_agent_context/google_adk_registration/decorator.py13logger = logging.getLogger(__name__)CODE
LOW…hub_agent_context/google_adk_registration/decorator.py15__all__ = ["datahub_tool", "register_google_adk_agent"]CODE
LOW…ahub_agent_context/google_adk_registration/__init__.py11__all__ = ["DataHubBeforeModelCallback", "datahub_tool", "register_google_adk_agent"]CODE
LOW…atahub_agent_context/google_adk_registration/plugin.py13logger = logging.getLogger(__name__)CODE
LOW…/src/datahub_agent_context/langchain_tools/__init__.py11__all__ = ["build_langchain_tools", "build_langchain_cloud_tools"]CODE
LOW…t/src/datahub_agent_context/snowflake/generate_udfs.py71logger = logging.getLogger(__name__)CODE
LOW…ntext/src/datahub_agent_context/snowflake/snowflake.py18logger = logging.getLogger(__name__)CODE
LOW…datahub_agent_context/snowflake/generators/__init__.py16__all__ = [CODE
LOW…atahub_agent_context/langchain_registration/handler.py20logger = logging.getLogger(__name__)CODE
LOW…ahub_agent_context/langchain_registration/decorator.py13logger = logging.getLogger(__name__)CODE
LOW…ahub_agent_context/langchain_registration/decorator.py15__all__ = ["datahub_tool", "register_langchain_agent"]CODE
LOW…tahub_agent_context/langchain_registration/__init__.py9__all__ = ["DataHubCallbackHandler", "datahub_tool", "register_langchain_agent"]CODE
LOW…rc/datahub_agent_context/mcp_tools/_token_estimator.py6logger = logging.getLogger(__name__)CODE
LOW…t-context/src/datahub_agent_context/mcp_tools/terms.py9logger = logging.getLogger(__name__)CODE
LOW…nt-context/src/datahub_agent_context/mcp_tools/tags.py9logger = logging.getLogger(__name__)CODE
LOW…ext/src/datahub_agent_context/mcp_tools/ask_datahub.py17logger = logging.getLogger(__name__)CODE
LOW…tahub_agent_context/mcp_tools/structured_properties.py11logger = logging.getLogger(__name__)CODE
LOW…-context/src/datahub_agent_context/mcp_tools/owners.py10logger = logging.getLogger(__name__)CODE
LOW…ntext/src/datahub_agent_context/mcp_tools/documents.py35logger = logging.getLogger(__name__)CODE
LOW…context/src/datahub_agent_context/mcp_tools/domains.py9logger = logging.getLogger(__name__)CODE
LOW…ontext/src/datahub_agent_context/mcp_tools/__init__.py31__all__ = [CODE
LOW…text/src/datahub_agent_context/mcp_tools/assertions.py13logger = logging.getLogger(__name__)CODE
LOW…context/src/datahub_agent_context/mcp_tools/queries.py18logger = logging.getLogger(__name__)CODE
LOW…-context/src/datahub_agent_context/mcp_tools/search.py20logger = logging.getLogger(__name__)CODE
LOW…ontext/src/datahub_agent_context/mcp_tools/entities.py17logger = logging.getLogger(__name__)CODE
LOW…context/src/datahub_agent_context/mcp_tools/lineage.py28logger = logging.getLogger(__name__)CODE
LOW…context/src/datahub_agent_context/mcp_tools/helpers.py16logger = logging.getLogger(__name__)CODE
LOW…nt-context/src/datahub_agent_context/mcp_tools/base.py10logger = logging.getLogger(__name__)CODE
LOW…xt/src/datahub_agent_context/mcp_tools/descriptions.py9logger = logging.getLogger(__name__)CODE
LOW…-context/src/datahub_agent_context/mcp_tools/get_me.py9logger = logging.getLogger(__name__)CODE
LOW…t/src/datahub_agent_context/mcp_tools/save_document.py26logger = logging.getLogger(__name__)CODE
LOWdatahub-actions/src/datahub_actions/entrypoints.py27logger = logging.getLogger(__name__)CODE
LOW…-actions/src/datahub_actions/pipeline/pipeline_util.py42logger = logging.getLogger(__name__)CODE
LOW…tahub-actions/src/datahub_actions/pipeline/pipeline.py37logger = logging.getLogger(__name__)CODE
LOW…tions/src/datahub_actions/pipeline/pipeline_manager.py23logger = logging.getLogger(__name__)CODE
LOW…hub-actions/src/datahub_actions/source/event_source.py60 def set_filters(self, filters: List["Filter"]) -> None:CODE
LOW…actions/plugin/source/pgqueue/pg_queue_event_source.py56logger = logging.getLogger(__name__)CODE
LOW…ahub_actions/plugin/source/kafka/kafka_event_source.py52logger = logging.getLogger(__name__)CODE
LOW…ahub_actions/plugin/source/kafka/kafka_event_source.py249 def set_filters(self, filters: List[Filter]) -> None:CODE
LOW…tions/src/datahub_actions/plugin/source/kafka/utils.py5logger = logging.getLogger(__name__)CODE
LOW…s/plugin/source/acryl/datahub_cloud_events_consumer.py25logger = logging.getLogger(__name__)CODE
LOW…ions/plugin/source/acryl/datahub_cloud_event_source.py44logger = logging.getLogger(__name__)CODE
LOW…lugin/source/acryl/datahub_cloud_events_ack_manager.py4logger = logging.getLogger(__name__)CODE
LOW…e/acryl/datahub_cloud_events_consumer_offsets_store.py18logger = logging.getLogger(__name__)CODE
LOW…tahub_actions/plugin/action/hello_world/hello_world.py24logger = logging.getLogger(__name__)CODE
LOW…_actions/plugin/action/term/term_propagation_action.py27logger = logging.getLogger(__name__)CODE
LOW…c/datahub_actions/plugin/action/utils/term_resolver.py20logger = logging.getLogger(__name__)CODE
LOW…ahub_actions/plugin/action/snowflake/tag_propagator.py36logger = logging.getLogger(__name__)CODE
LOW…hub_actions/plugin/action/execution/executor_action.py38logger = logging.getLogger(__name__)CODE
LOW…s/plugin/action/propagation/docs/propagation_action.py54logger = logging.getLogger(__name__)CODE
LOW…tions/src/datahub_actions/plugin/action/teams/teams.py34logger = logging.getLogger(__name__)CODE
LOW…tions/src/datahub_actions/plugin/action/slack/slack.py38logger = logging.getLogger(__name__)CODE
LOW…in/action/metadata_change_sync/metadata_change_sync.py22logger = logging.getLogger(__name__)CODE
LOW…ub_actions/plugin/action/tag/tag_propagation_action.py27logger = logging.getLogger(__name__)CODE
LOW…src/datahub_actions/plugin/filter/event_type_filter.py27logger = logging.getLogger(__name__)CODE
LOW…_actions/plugin/transform/filter/filter_transformer.py27logger = logging.getLogger(__name__)CODE
913 more matches not shown…
Deep Nesting1141 hits · 944 pts
SeverityFileLineSnippetContext
LOW…cker/snippets/ingestion/build_bundled_venvs_unified.py93CODE
LOWperf-test/authz-perf/run.py347CODE
LOWperf-test/authz-perf/executor.py233CODE
LOW…gent-context/tests/unit/snowflake/test_udf_coverage.py367CODE
LOW…tahub-agent-context/examples/google_adk/basic_agent.py115CODE
LOW…atahub_agent_context/google_adk_registration/plugin.py166CODE
LOW…ntext/src/datahub_agent_context/snowflake/snowflake.py248CODE
LOW…atahub_agent_context/langchain_registration/handler.py23CODE
LOW…rc/datahub_agent_context/mcp_tools/_token_estimator.py17CODE
LOW…rc/datahub_agent_context/mcp_tools/_token_estimator.py35CODE
LOW…ext/src/datahub_agent_context/mcp_tools/ask_datahub.py220CODE
LOW…tahub_agent_context/mcp_tools/structured_properties.py83CODE
LOW…ntext/src/datahub_agent_context/mcp_tools/documents.py515CODE
LOW…text/src/datahub_agent_context/mcp_tools/assertions.py219CODE
LOW…ontext/src/datahub_agent_context/mcp_tools/entities.py29CODE
LOW…context/src/datahub_agent_context/mcp_tools/lineage.py142CODE
LOW…context/src/datahub_agent_context/mcp_tools/lineage.py324CODE
LOW…context/src/datahub_agent_context/mcp_tools/helpers.py91CODE
LOW…context/src/datahub_agent_context/mcp_tools/helpers.py237CODE
LOW…context/src/datahub_agent_context/mcp_tools/helpers.py366CODE
LOW…nt-context/src/datahub_agent_context/mcp_tools/base.py23CODE
LOW…xt/src/datahub_agent_context/mcp_tools/descriptions.py12CODE
LOW…t/src/datahub_agent_context/mcp_tools/save_document.py155CODE
LOW…gin/source/acryl/test_datahub_cloud_events_consumer.py514CODE
LOW…gin/source/acryl/test_datahub_cloud_events_consumer.py606CODE
LOW…ons/tests/unit/observability/test_kafka_lag_monitor.py309CODE
LOW…ons/tests/unit/observability/test_kafka_lag_monitor.py319CODE
LOW…ahub_actions/plugin/source/kafka/kafka_event_source.py384CODE
LOW…ahub_actions/plugin/source/kafka/kafka_event_source.py430CODE
LOW…ions/plugin/source/acryl/datahub_cloud_event_source.py182CODE
LOW…_actions/plugin/action/term/term_propagation_action.py82CODE
LOW…_actions/plugin/action/term/term_propagation_action.py128CODE
LOW…hub_actions/plugin/action/execution/executor_action.py93CODE
LOW…actions/plugin/action/propagation/propagation_utils.py258CODE
LOW…s/plugin/action/propagation/docs/propagation_action.py188CODE
LOW…s/plugin/action/propagation/docs/propagation_action.py229CODE
LOW…s/plugin/action/propagation/docs/propagation_action.py347CODE
LOW…s/plugin/action/propagation/docs/propagation_action.py405CODE
LOW…s/plugin/action/propagation/docs/propagation_action.py493CODE
LOW…s/plugin/action/propagation/docs/propagation_action.py670CODE
LOW…s/plugin/action/propagation/docs/propagation_action.py745CODE
LOW…ub_actions/plugin/action/tag/tag_propagation_action.py93CODE
LOW…tions/src/datahub_actions/utils/delta_extractor_mcl.py37CODE
LOWsmoke-test/conftest.py346CODE
LOWsmoke-test/test_system_info.py151CODE
LOWsmoke-test/tests/consistency_utils.py186CODE
LOWsmoke-test/tests/cypress/timestamp_updater.py20CODE
LOWsmoke-test/tests/cypress/timestamp_updater.py34CODE
LOWsmoke-test/tests/entity_graph_cache/helpers.py310CODE
LOW…ke-test/tests/cli/delete_cmd/test_timeseries_delete.py108CODE
LOW…oke-test/tests/cli/dataset_cmd/test_dataset_command.py249CODE
LOWsmoke-test/tests/zdu/framework/docker_compose.py235CODE
LOWsmoke-test/tests/zdu/framework/test_cleanup.py264CODE
LOWsmoke-test/tests/zdu/framework/log_monitor.py178CODE
LOWsmoke-test/tests/zdu/framework/log_monitor.py282CODE
LOW…oke-test/tests/zdu/framework/phases/rolling_restart.py208CODE
LOW…oke-test/tests/zdu/framework/phases/rolling_restart.py239CODE
LOW…ke-test/tests/zdu/framework/phases/upgrade_blocking.py161CODE
LOW…e-test/tests/zdu/framework/phases/kill_switch_sweep.py329CODE
LOWsmoke-test/tests/zdu/framework/phases/cleanup.py188CODE
1081 more matches not shown…
Docstring Block Structure168 hits · 840 pts
SeverityFileLineSnippetContext
HIGH…ntext/src/datahub_agent_context/snowflake/snowflake.py22Extract domain from DataHub URL for network rules. Args: datahub_url: DataHub instance URL (e.g., https://eSTRING
HIGH…ntext/src/datahub_agent_context/snowflake/snowflake.py311Auto-detect Snowflake connection parameters from an active connection. Args: connection: Active Snowflake cSTRING
HIGH…hub_agent_context/snowflake/udfs/add_glossary_terms.py7Generate ADD_GLOSSARY_TERMS UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.add_gloSTRING
HIGH…agent_context/snowflake/udfs/get_dataset_assertions.py7Generate GET_DATASET_ASSERTIONS UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.getSTRING
HIGH…t/src/datahub_agent_context/snowflake/udfs/add_tags.py7Generate ADD_TAGS UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.add_tags() to addSTRING
HIGH…nt_context/snowflake/udfs/get_lineage_paths_between.py7Generate GET_LINEAGE_PATHS_BETWEEN UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.STRING
HIGH…datahub_agent_context/snowflake/udfs/search_datahub.py7Generate SEARCH_DATAHUB UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.search() toSTRING
HIGH…hub_agent_context/snowflake/udfs/update_description.py7Generate UPDATE_DESCRIPTION UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.update_STRING
HIGH…tahub_agent_context/snowflake/udfs/get_datahub_chat.py7Generate GET_DATAHUB_CHAT UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.get_datahSTRING
HIGH…tahub_agent_context/snowflake/udfs/ask_datahub_chat.py7Generate ASK_DATAHUB_CHAT UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.ask_datahSTRING
HIGH…ub_agent_context/snowflake/udfs/get_dataset_queries.py7Generate GET_DATASET_QUERIES UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.get_daSTRING
HIGH…ntext/src/datahub_agent_context/snowflake/udfs/base.py12 Generate the SQL CREATE FUNCTION statement for a Python UDF. Args: function_name: Name of the UDF to cSTRING
HIGH…datahub_agent_context/snowflake/udfs/grep_documents.py7Generate GREP_DOCUMENTS UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.grep_documeSTRING
HIGH…tahub_agent_context/snowflake/udfs/search_documents.py7Generate SEARCH_DOCUMENTS UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.search_doSTRING
HIGH…hub_agent_context/snowflake/udfs/list_schema_fields.py7Generate LIST_SCHEMA_FIELDS UDF using datahub-agent-context. This UDF wraps datahub_agent_context.mcp_tools.list_scSTRING
HIGH…t-context/src/datahub_agent_context/mcp_tools/terms.py167Add one or more glossary terms (terms) to multiple DataHub entities or their columns (e.g., schema fields). This toSTRING
HIGH…t-context/src/datahub_agent_context/mcp_tools/terms.py235Remove one or more glossary terms (terms) from multiple DataHub entities or their column_paths (e.g., schema fields). STRING
HIGH…nt-context/src/datahub_agent_context/mcp_tools/tags.py168Add one or more tags to multiple DataHub entities or their columns (e.g., schema fields). This tool allows you to tSTRING
HIGH…nt-context/src/datahub_agent_context/mcp_tools/tags.py236Remove one or more tags from multiple DataHub entities or their column_paths (e.g., schema fields). This tool allowSTRING
HIGH…ext/src/datahub_agent_context/mcp_tools/ask_datahub.py138Ask DataHub a question about your data catalog. Sends a question to the DataHub AI assistant, which can search the STRING
HIGH…tahub_agent_context/mcp_tools/structured_properties.py86 Validate and convert a property value to the appropriate GraphQL format. Supports 5 data types: - datahub.STRING
HIGH…-context/src/datahub_agent_context/mcp_tools/owners.py205Add one or more owners to multiple DataHub entities. This tool allows you to assign multiple entities with multipleSTRING
HIGH…-context/src/datahub_agent_context/mcp_tools/owners.py276Remove one or more owners from multiple DataHub entities. This tool allows you to unassign multiple entities from mSTRING
HIGH…ntext/src/datahub_agent_context/mcp_tools/documents.py327Search for documents stored in the customer's DataHub deployment. These are the organization's own documents (runboSTRING
HIGH…ntext/src/datahub_agent_context/mcp_tools/documents.py522Search within document content using regex patterns. Similar to ripgrep/grep - finds matching excerpts within documSTRING
HIGH…context/src/datahub_agent_context/mcp_tools/domains.py66Set domain for multiple DataHub entities. This tool allows you to assign a domain to multiple entities in a single STRING
HIGH…context/src/datahub_agent_context/mcp_tools/domains.py166Remove domain assignment from multiple DataHub entities. This tool allows you to unset the domain for multiple entiSTRING
HIGH…context/src/datahub_agent_context/mcp_tools/queries.py52Get SQL queries associated with a dataset or column to understand usage patterns. This tool retrieves actual SQL quSTRING
HIGH…-context/src/datahub_agent_context/mcp_tools/search.py39Search across DataHub entities using structured full-text search. Results are ordered by relevance and importance - STRING
HIGH…ontext/src/datahub_agent_context/mcp_tools/entities.py133List schema fields for a dataset, with optional keyword filtering and pagination. Useful when schema fields were trSTRING
HIGH…context/src/datahub_agent_context/mcp_tools/lineage.py55Get filter for lineage degree (hops). Args: max_hops: Maximum number of hops to search for lineage STRING
HIGH…context/src/datahub_agent_context/mcp_tools/lineage.py152Get upstream or downstream lineage for any entity. Set upstream to True for upstream lineage, False for downstream STRING
HIGH…context/src/datahub_agent_context/mcp_tools/lineage.py369Internal helper to find upstream lineage path. Always queries upstream lineage (more bounded than downstream). STRING
HIGH…context/src/datahub_agent_context/mcp_tools/lineage.py505Internal helper to find lineage path in a specific direction. Always queries upstream internally (more efficient), STRING
HIGH…context/src/datahub_agent_context/mcp_tools/lineage.py574Get detailed lineage path(s) between two specific entities or columns. Returns the paths array from searchAcrossLinSTRING
HIGH…context/src/datahub_agent_context/mcp_tools/helpers.py139Convert a dataset URN to a schema field URN if column is provided. Args: urn: Dataset URN column: OSTRING
HIGH…xt/src/datahub_agent_context/mcp_tools/descriptions.py141Update description for a DataHub entity or its column (e.g., schema field). This tool allows you to set, append to,STRING
HIGHdatahub-actions/src/datahub_actions/cli/actions.py56 Load a config file as raw YAML/JSON without variable expansion. Args: config_file: Path to the configuSTRING
HIGH…n/src/datahub_airflow_plugin/_airflow_asset_adapter.py73Convert Airflow Asset URI to DataHub dataset URN. Args: asset: An Airflow Asset or Dataset object with a 'uSTRING
HIGHmetadata-ingestion/src/datahub/configuration/kafka.py26 Resolve OAuth callback string paths to callable functions. This helper resolves the oauth_cb configuration parSTRING
HIGHmetadata-ingestion/src/datahub/specific/datajob.py64 Adds an input data job to the DataJobPatchBuilder. Args: input: The input data job, which STRING
HIGHmetadata-ingestion/src/datahub/specific/datajob.py120 Sets the input data jobs for the DataJobPatchBuilder. Args: inputs: A list of Edge objectsSTRING
HIGHmetadata-ingestion/src/datahub/specific/datajob.py145 Adds an input dataset to the DataJobPatchBuilder. Args: input: The input dataset, which caSTRING
HIGHmetadata-ingestion/src/datahub/specific/datajob.py201 Sets the input datasets for the DataJobPatchBuilder. Args: inputs: A list of Edge objects STRING
HIGHmetadata-ingestion/src/datahub/specific/datajob.py228 Adds an output dataset to the DataJobPatchBuilder. Args: output: The output dataset, whichSTRING
HIGHmetadata-ingestion/src/datahub/specific/datajob.py284 Sets the output datasets for the DataJobPatchBuilder. Args: outputs: A list of Edge objectSTRING
HIGHmetadata-ingestion/src/datahub/specific/datajob.py309 Adds an input dataset field to the DataJobPatchBuilder. Args: input: The input dataset fieSTRING
HIGHmetadata-ingestion/src/datahub/specific/datajob.py354 Sets the input dataset fields for the DataJobPatchBuilder. Args: inputs: A list of Edge obSTRING
HIGHmetadata-ingestion/src/datahub/specific/datajob.py381 Adds an output dataset field to the DataJobPatchBuilder. Args: output: The output dataset STRING
HIGHmetadata-ingestion/src/datahub/specific/datajob.py426 Sets the output dataset fields for the DataJobPatchBuilder. Args: outputs: A list of Edge STRING
HIGHmetadata-ingestion/src/datahub/specific/chart.py52 Adds an input to the ChartPatchBuilder. Args: input: The input, which can be an Edge objecSTRING
HIGHmetadata-ingestion/src/datahub/specific/chart.py105 Sets the input edges for the ChartPatchBuilder. Args: inputs: A list of Edge objects repreSTRING
HIGHmetadata-ingestion/src/datahub/specific/dashboard.py53 Adds an dataset to the DashboardPatchBuilder. Args: dataset: The dataset, which can be an STRING
HIGHmetadata-ingestion/src/datahub/specific/dashboard.py111 Sets the dataset edges for the DashboardPatchBuilder. Args: datasets: A list of Edge objecSTRING
HIGHmetadata-ingestion/src/datahub/specific/dashboard.py136 Adds a chart edge to the DashboardPatchBuilder. Args: chart: The dataset, which can be an STRING
HIGHmetadata-ingestion/src/datahub/specific/dashboard.py194 Sets the chart edges for the DashboardPatchBuilder. Args: charts: A list of Edge objects rSTRING
HIGHmetadata-ingestion/src/datahub/specific/dashboard.py279 Adds an dashboard to the DashboardPatchBuilder. Args: dashboard: The dashboard, which can STRING
HIGH…-ingestion/src/datahub/ingestion/recording/db_proxy.py389Look up a recorded query result using multi-level matching. Matching strategy (in order of preference): STRING
HIGH…-ingestion/src/datahub/ingestion/recording/db_proxy.py433Find a recording using fuzzy string matching. This is a fallback for when exact and normalized matching fail. STRING
HIGH…datahub/ingestion/source/fivetran/fivetran_rest_api.py97 Get details for a specific connection from the Fivetran API. Args: connection_id: The FiveSTRING
108 more matches not shown…
Structural Annotation Overuse459 hits · 779 pts
SeverityFileLineSnippetContext
LOW…phql/resolvers/assertion/EntityAssertionsResolver.java58 // Step 1: Fetch set of assertions associated with the target entity from the GraphCOMMENT
LOW…phql/resolvers/assertion/EntityAssertionsResolver.java74 // Step 2: Hydrate the assertion entities based on the urns from step 1COMMENT
LOW…phql/resolvers/assertion/EntityAssertionsResolver.java82 // Step 3: Map GMS assertion model to GraphQL model, preserving graph-store order.COMMENT
LOW…phql/resolvers/assertion/EntityAssertionsResolver.java97 // Step 4: Package and return resultCOMMENT
LOW…hql/resolvers/assertion/AssertionRunEventResolver.java62 // Step 1: Fetch aspects from GMSCOMMENT
LOW…hql/resolvers/assertion/AssertionRunEventResolver.java77 // Step 2: Bind profiles into GraphQL strong types.COMMENT
LOW…hql/resolvers/assertion/AssertionRunEventResolver.java83 // Step 3: Package and return response.COMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java111 // Step 1: Search using service to get URNsCOMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java121 // Step 2: Extract URNs from search resultsCOMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java127 // Step 3: Batch hydrate/resolve the Document entitiesCOMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java135 // Step 4: Map entities in the same order as search resultsCOMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java141 // Step 5: Convert to GraphQL Document objectsCOMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java148 // Step 6: Build the resultCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java103 // Step 1: Search using service to get URNsCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java121 // Step 2: Extract URNs from search resultsCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java127 // Step 3: Batch hydrate/resolve the Document entitiesCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java135 // Step 4: Map entities in the same order as search resultsCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java141 // Step 5: Convert to GraphQL Document objectsCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java148 // Step 6: Build the resultCOMMENT
LOW…raphql/resolvers/incident/EntityIncidentsResolver.java68 // Step 1: Fetch set of incidents associated with the target entity from the SearchCOMMENT
LOW…raphql/resolvers/incident/EntityIncidentsResolver.java89 // Step 2: Hydrate the incident entitiesCOMMENT
LOW…raphql/resolvers/incident/EntityIncidentsResolver.java97 // Step 3: Map GMS incident model to GraphQL modelCOMMENT
LOW…raphql/resolvers/incident/EntityIncidentsResolver.java108 // Step 4: Package and return resultCOMMENT
LOW…ahub/graphql/resolvers/jobs/ExecutionRunsResolver.java64 // Step 1: Fetch set of task runs associated with the target entity from the SearchCOMMENT
LOW…ahub/graphql/resolvers/jobs/ExecutionRunsResolver.java82 // Step 2: Hydrate the incident entitiesCOMMENT
LOW…ahub/graphql/resolvers/jobs/ExecutionRunsResolver.java90 // Step 3: Map GMS incident model to GraphQL modelCOMMENT
LOW…ahub/graphql/resolvers/jobs/ExecutionRunsResolver.java101 // Step 4: Package and return resultCOMMENT
LOW…datahub/graphql/resolvers/jobs/EntityRunsResolver.java68 // Step 1: Fetch set of task runs associated with the target entity from the SearchCOMMENT
LOW…datahub/graphql/resolvers/jobs/EntityRunsResolver.java86 // Step 2: Hydrate the incident entitiesCOMMENT
LOW…datahub/graphql/resolvers/jobs/EntityRunsResolver.java94 // Step 3: Map GMS instance model to GraphQL modelCOMMENT
LOW…datahub/graphql/resolvers/jobs/EntityRunsResolver.java105 // Step 4: Package and return resultCOMMENT
LOW…resolvers/datacontract/EntityDataContractResolver.java48 // Step 1: Fetch the contract associated with the dataset.COMMENT
LOW…resolvers/datacontract/EntityDataContractResolver.java77 // Step 2: Hydrate the contract entities based on the urns from step 1COMMENT
LOW…resolvers/datacontract/EntityDataContractResolver.java86 // Step 4: Package and return resultCOMMENT
LOWdocker/airflow/docker-compose.yaml21# WARNING: This configuration is for local development. Do not use it in a production deployment.COMMENT
LOWdocker/airflow/local_airflow.md26## Step 1: Set up your Airflow areaCOMMENT
LOWdocker/airflow/local_airflow.md52## Step 2: Bring up AirflowCOMMENT
LOWdocker/airflow/local_airflow.md119## Step 3: Register DataHub connection (hook) to AirflowCOMMENT
LOWdocker/airflow/local_airflow.md137## Step 4: Find the DAGs and run itCOMMENT
LOW…/com/linkedin/metadata/trace/TraceServiceImplTest.java528 // Step 1: Verify that parsing this trace ID produces a far-future epochCOMMENT
LOW…/com/linkedin/metadata/trace/TraceServiceImplTest.java537 // Step 2: Verify that the queue time calculation would produce a value that overflowsCOMMENT
LOW…/com/linkedin/metadata/trace/TraceServiceImplTest.java543 // Step 3: Confirm that Duration.ofMillis(queueTimeMs).toNanos() would overflowCOMMENT
LOW…/com/linkedin/metadata/trace/TraceServiceImplTest.java555 // Step 4: Verify the fix — extractTraceIdEpochMillis returns null for this trace ID,COMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1399 // Step 1: Create initial index with 1 shardCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1405 // Step 2: Index some documentsCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1425 // Step 3: Create builder with different shard count to force requiresReindex, and non-zeroCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1471 // Step 6: Restore settingsCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1478 // Step 7: Verify next index has all documentsCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1494 // Step 8: Verify alias still points to original index (no swap happened)COMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1504 // Step 9: Verify next index has the new shard countCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1443 // Step 4: Run incremental reindex (Phase 1)COMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1459 // Step 5: Poll until reindex completesCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1516 // Step 10: Verify settings were restored (replicas back to target, refresh interval restored)COMMENT
LOW…n/metadata/search/elasticsearch/query/ESSearchDAO.java311 // Step 1: construct the queryCOMMENT
LOW…n/metadata/search/elasticsearch/query/ESSearchDAO.java325 // Step 2: execute the query and extract results, validated against document model as wellCOMMENT
LOW…sticsearch/indexbuilder/DestinationIndexOptimizer.java107 // Step 1: Fetch all original settings in a single API call (batch operation)COMMENT
LOW…sticsearch/indexbuilder/DestinationIndexOptimizer.java167 // Step 2: Apply optimizations in a single atomic API call (batch operation)COMMENT
LOW…ain/java/com/linkedin/metadata/kafka/CDCProcessor.java155 // Step 1: Parse JSON using Jackson ObjectMapperCOMMENT
LOW…ain/java/com/linkedin/metadata/kafka/CDCProcessor.java178 // Step 2: Extract "before" and "after" fields as JsonNode objectsCOMMENT
LOW…ain/java/com/linkedin/metadata/kafka/CDCProcessor.java182 // Step 3: Check if we should process this record (only latest versions)COMMENT
399 more matches not shown…
Unused Imports814 hits · 776 pts
SeverityFileLineSnippetContext
LOWdocker/snippets/ingestion/bundled_venv_config.py21CODE
LOWperf-test/authz-perf/run.py2CODE
LOWperf-test/authz-perf/compare.py2CODE
LOWperf-test/authz-perf/executor.py1CODE
LOWperf-test/authz-perf/scripts/extract_query_specs.py3CODE
LOWperf-test/authz-perf/lib/personas.py1CODE
LOWperf-test/authz-perf/lib/graphql.py1CODE
LOWperf-test/authz-perf/lib/graphql.py9CODE
LOWperf-test/authz-perf/lib/targets.py1CODE
LOWperf-test/authz-perf/lib/metadata.py1CODE
LOWperf-test/authz-perf/lib/variants.py1CODE
LOWperf-test/authz-perf/lib/query_spec.py1CODE
LOWperf-test/authz-perf/lib/paths.py1CODE
LOWperf-test/authz-perf/lib/results.py1CODE
LOWperf-test/authz-perf/lib/credentials.py1CODE
LOWperf-test/authz-perf/lib/session.py1CODE
LOWperf-test/authz-perf/lib/system_info.py1CODE
LOWperf-test/authz-perf/lib/graphql_adapt.py1CODE
LOWperf-test/authz-perf/lib/query_build.py1CODE
LOWperf-test/authz-perf/lib/persona_password_seed.py1CODE
LOWperf-test/authz-perf/lib/orchestration.py1CODE
LOWperf-test/authz-perf/lib/persona_credentials.py1CODE
LOWperf-test/authz-perf/lib/gms_config.py1CODE
LOWperf-test/authz-perf/lib/expectations.py1CODE
LOWperf-test/authz-perf/lib/stats.py1CODE
LOWperf-test/authz-perf/lib/datapack.py1CODE
LOWperf-test/authz-perf/lib/init.py1CODE
LOWperf-test/authz-perf/lib/output_paths.py1CODE
LOWdatahub-agent-context/tests/unit/fake_emitter.py3CODE
LOW…text/tests/unit/google_adk_registration/test_plugin.py1CODE
LOW…text/tests/unit/langchain_registration/test_handler.py1CODE
LOW…agent-context/examples/langchain/autoregister_agent.py20CODE
LOW…context/examples/google_adk/autoregister_google_adk.py17CODE
LOW…ontext/src/datahub_agent_context/_registration_core.py18CODE
LOW…ub-agent-context/src/datahub_agent_context/__init__.py17CODE
LOW…ub-agent-context/src/datahub_agent_context/__init__.py18CODE
LOW…ub-agent-context/src/datahub_agent_context/__init__.py18CODE
LOW…ub-agent-context/src/datahub_agent_context/__init__.py18CODE
LOW…ub-agent-context/src/datahub_agent_context/__init__.py18CODE
LOW…ub-agent-context/src/datahub_agent_context/__init__.py18CODE
LOW…ub-agent-context/src/datahub_agent_context/__init__.py25CODE
LOW…hub-agent-context/src/datahub_agent_context/context.py11CODE
LOW…hub-agent-context/src/datahub_agent_context/context.py12CODE
LOW…tahub-agent-context/src/datahub_agent_context/utils.py11CODE
LOW…src/datahub_agent_context/google_adk_tools/__init__.py6CODE
LOW…src/datahub_agent_context/google_adk_tools/__init__.py6CODE
LOW…/src/datahub_agent_context/google_adk_tools/builder.py20CODE
LOW…hub_agent_context/google_adk_registration/decorator.py1CODE
LOW…hub_agent_context/google_adk_registration/decorator.py7CODE
LOW…ahub_agent_context/google_adk_registration/__init__.py1CODE
LOW…ahub_agent_context/google_adk_registration/__init__.py3CODE
LOW…ahub_agent_context/google_adk_registration/__init__.py3CODE
LOW…ahub_agent_context/google_adk_registration/__init__.py7CODE
LOW…/src/datahub_agent_context/langchain_tools/__init__.py6CODE
LOW…/src/datahub_agent_context/langchain_tools/__init__.py6CODE
LOW…t/src/datahub_agent_context/langchain_tools/builder.py20CODE
LOW…datahub_agent_context/snowflake/generators/__init__.py3CODE
LOW…datahub_agent_context/snowflake/generators/__init__.py6CODE
LOW…datahub_agent_context/snowflake/generators/__init__.py9CODE
LOW…datahub_agent_context/snowflake/generators/__init__.py12CODE
754 more matches not shown…
Cross-Language Confusion138 hits · 688 pts
SeverityFileLineSnippetContext
HIGH…cker/snippets/ingestion/build_bundled_venvs_unified.py122 base_cmd = f"source {venv_path}/bin/activate && uv pip install --upgrade pip wheel setuptools --constraint {consCODE
HIGH…cker/snippets/ingestion/build_bundled_venvs_unified.py131 install_cmd = f"source {venv_path}/bin/activate && uv pip install {datahub_package} --constraint {constraintCODE
HIGH…cker/snippets/ingestion/build_bundled_venvs_unified.py135 f'source {venv_path}/bin/activate && uv pip install "{datahub_package}" 'CODE
HIGH…agent_context/snowflake/generators/stored_procedure.py47 columns.push(rs.getColumnName(i));CODE
HIGH…agent_context/snowflake/generators/stored_procedure.py59 results.push(row);CODE
HIGHsmoke-test/tests/audit_events/audit_events_test.py311 \"account_id\":null,CODE
HIGHsmoke-test/tests/audit_events/audit_events_test.py341 \"account_id\":null,CODE
HIGH…e-test/tests/service_accounts/test_service_accounts.py228 f"Expected defaultView to be null, got: {default_view}"CODE
HIGHsmoke-test/tests/oauth/test_oauth_cli_gms.py7 "pip install -e /repo/metadata-ingestion && pytest /smoke/test_oauth_cli_gms.py -v"STRING
HIGH…e-test/tests/library_examples/test_library_examples.py12Run with: cd smoke-test && source venv/bin/activate && pytest tests/library_examples/ -vSTRING
HIGHsmoke-test/tests/zdu/framework/test_config.py20 Running ``cd smoke-test && python -m tests.zdu`` used to produce aSTRING
HIGHsmoke-test/tests/zdu/framework/phases/build_images.py11configured ref via ``git fetch && git reset --hard <ref>``. This keepsSTRING
HIGHsmoke-test/tests/privileges/test_privileges.py268 \"account_id\":null,CODE
HIGHsmoke-test/tests/privileges/test_privileges.py308 \"account_id\":null,CODE
HIGH…oke-test/tests/authorization/test_aspect_write_auth.py91 batchSetDataProduct(input: { dataProductUrn: null, resourceUrns: $resourceUrns })CODE
HIGH…test/tests/managed_ingestion/managed_ingestion_test.py486 "recipe": '{"source":{"type":"mysql","config":{"include_tables":true,"database":null,"password":"${MYSQLCODE
HIGH…test/tests/managed_ingestion/managed_ingestion_test.py529 == '{"source":{"type":"mysql","config":{"include_tables":true,"database":null,"password":"${MYSQL_PASSWORD}","prCODE
HIGH…test/tests/managed_ingestion/managed_ingestion_test.py566 "recipe": '{"source":{"type":"mysql","config":{"include_tables":true,"database":null,"password":"${MYSQLCODE
HIGH…test/tests/managed_ingestion/managed_ingestion_test.py612 '{"source":{"type":"mysql","config":{"include_tables":true,"database":null,"password":"${MYSQL_PASSWORD}","pCODE
HIGHpython-build/generate_release_scripts.py71rm -rf build dist || trueCODE
HIGHmetadata-ingestion/tests/unit/test_superset_source.py1644 # ``{"result": null}`` is an API contract violation, not an emptyCOMMENT
HIGHmetadata-ingestion/tests/unit/test_superset_source.py2054 # ``{"result": null}`` would crash callers that doCOMMENT
HIGH…data-ingestion/tests/unit/test_unity_catalog_source.py2271 " synonyms: ['valid', 123, '', ' ', null, ['nested']]\n"CODE
HIGHmetadata-ingestion/tests/unit/test_cassandra_source.py47 {"keyspace_name": "playground", "table_name": "people", "column_name": "birthday", "clustering_order": "STRING
HIGHmetadata-ingestion/tests/unit/test_cassandra_source.py48 {"keyspace_name": "playground", "table_name": "people", "column_name": "email", "clustering_order": "nonSTRING
HIGHmetadata-ingestion/tests/unit/test_cassandra_source.py49 {"keyspace_name": "playground", "table_name": "people", "column_name": "name", "clustering_order": "noneSTRING
HIGHmetadata-ingestion/tests/unit/test_compare_metadata.py11 "auditHeader": null,STRING
HIGHmetadata-ingestion/tests/unit/test_compare_metadata.py59 "auditHeader": null,STRING
HIGHmetadata-ingestion/tests/unit/test_compare_metadata.py107 "auditHeader": null,STRING
HIGH…ta-ingestion/tests/unit/glue/test_glue_source_stubs.py187 "avro.schema.literal": '{"type":"record","name":"flights_avro_subset","namespace":"default","fields"CODE
HIGH…ta-ingestion/tests/unit/glue/test_glue_source_stubs.py198 "avro.schema.literal": '{"type":"record","name":"flights_avro_subset","namespace":"default","fields":[{"CODE
HIGH…ta-ingestion/tests/unit/glue/test_glue_source_stubs.py217 "avro.schema.literal": '{"type":"record","name":"flights_avro_subset","namespace":"default","fields":[{"nameCODE
HIGH…ta-ingestion/tests/unit/glue/test_glue_source_stubs.py1135 "avro.schema.literal": '{"type":"record","name":"flights_avro_subset","namespace":"default","fields"STRING
HIGH…ta-ingestion/tests/unit/glue/test_glue_source_stubs.py1146 "avro.schema.literal": '{"type":"record","name":"flights_avro_subset","namespace":"default","fields":[{"STRING
HIGH…ta-ingestion/tests/unit/glue/test_glue_source_stubs.py1165 "avro.schema.literal": '{"type":"record","name":"flights_avro_subset","namespace":"default","fields":[{"nameSTRING
HIGH…ta-ingestion/tests/unit/glue/test_glue_source_stubs.py1245 "avro.schema.literal": '{"type":"record","name":"flights_avro_subset","namespace":"default","fields"STRING
HIGH…ta-ingestion/tests/unit/glue/test_glue_source_stubs.py1256 "avro.schema.literal": '{"type":"record","name":"flights_avro_subset","namespace":"default","fields":[{"STRING
HIGH…ta-ingestion/tests/unit/glue/test_glue_source_stubs.py1273 "avro.schema.literal": '{"type":"record","name":"flights_avro_subset","namespace":"default","fields":[{"nameSTRING
HIGHmetadata-ingestion/tests/unit/dbt/test_dbt_source.py2257 """When dbt serializes error_after as {"count": null, "period": null},STRING
HIGH…estion/tests/unit/sqlalchemy_profiler/test_adapters.py499 mathematically undefined, so we return None (not 0.0).STRING
HIGH…estion/tests/unit/sqlalchemy_profiler/test_adapters.py1540 """stddevSamp returns NULL with ≤1 non-null row → None (mathematically undefined)."""STRING
HIGH…/tests/unit/snowflake/test_snowflake_dynamic_tables.py211 """INPUTS that parses to a non-list value (null, single object) doesn't crashSTRING
HIGH…tests/unit/utilities/test_sqlalchemy_type_converter.py119 assert schema_fields[0].fieldPath == "[version=2.0].[type=null]"CODE
HIGH…tests/unit/utilities/test_sqlalchemy_type_converter.py125 # multiple unrecognised columns collapse to the same "[version=2.0].[type=null]"COMMENT
HIGH…tests/unit/utilities/test_sqlalchemy_type_converter.py141 assert fields_a[0].fieldPath == "[version=2.0].[type=null].col_a"CODE
HIGH…tests/unit/utilities/test_sqlalchemy_type_converter.py142 assert fields_b[0].fieldPath == "[version=2.0].[type=null].col_b"CODE
HIGH…ion/tests/unit/utilities/test_graphql_query_adapter.py1303 cache_path.write_text('{"data": null}')CODE
HIGH…ata-ingestion/tests/unit/powerbi/test_user_creation.py137 When displayName is null, we fallback to user_id to avoid null values.STRING
HIGH…gestion/tests/unit/sql_parsing/test_sqlglot_lineage.py1344 col1 = t1.col1 || t1.col2,STRING
HIGH…gestion/tests/unit/sql_parsing/test_sqlglot_lineage.py1345 col2 = t1.col1 || t2.col2STRING
HIGH…gestion/tests/unit/sql_parsing/test_sqlglot_lineage.py1763 IF (main.id is not null, main, extras).* REPLACE (STRING
HIGH…data-ingestion/tests/integration/dremio/test_dremio.py58 command = f'docker exec --user root {container_name} sh -c "apt-get update && apt-get install -y mysql-client && /uCODE
HIGH…data-ingestion/tests/integration/looker/test_looker.py256 dynamic_fields='[{"table_calculation":"calc","label":"foobar","expression":"offset(${my_table.vaCODE
HIGH…data-ingestion/tests/integration/looker/test_looker.py402 dynamic_fields='[{"table_calculation":"calc","label":"foobar","expression":"offset(${my_table.value}CODE
HIGH…data-ingestion/tests/integration/looker/test_looker.py412 dynamic_fields='[{"table_calculation":"calc","label":"foobar","expression":"offset(${my_table.value}CODE
HIGH…data-ingestion/tests/integration/looker/test_looker.py314 dynamic_fields='[{"table_calculation":"calc","label":"foobar","expression":"offset(${my_table.value}CODE
HIGH…data-ingestion/tests/integration/looker/test_looker.py440 dynamic_fields='[{"table_calculation":"calc","label":"foobar","expression":"offset(${my_table.value}CODE
HIGH…data-ingestion/tests/integration/looker/test_looker.py1499 dynamic_fields='[{"table_calculation":"calc","label":"foobar","expression":"offset(${my_table.vaCODE
HIGH…data-ingestion/tests/integration/looker/test_looker.py1522 dynamic_fields='[{"table_calculation":"calc","label":"foobar","expression":"offset(${my_table.vaCODE
HIGH…data-ingestion/tests/integration/looker/test_looker.py1545 dynamic_fields='[{"table_calculation":"calc","label":"foobar","expression":"offset(${my_table.vaCODE
78 more matches not shown…
Over-Commented Block740 hits · 622 pts
SeverityFileLineSnippetContext
LOW.betterleaks.toml1title = "DataHub betterleaks config"COMMENT
LOW…va/com/linkedin/metadata/models/EntitySpecBuilder.java81 // Now validate that all relationships point to valid entities.COMMENT
LOW…n/metadata/models/annotation/SearchableAnnotation.java41 // Whether or not to add field to filters.COMMENT
LOW…esolvers/logical/UpdateLogicalModelSchemaResolver.java81COMMENT
LOWdocker/snippets/mssql_odbc.sh1#!/bin/bashCOMMENT
LOWdocker/snippets/oracle_instantclient.sh1#!/bin/bashCOMMENT
LOWdocker/snippets/ingestion/constraints.txt1cmdstanpy>=1.3.0,<2.0.0COMMENT
LOWdocker/snippets/ingestion/constraints.txt61# (unstructured / HTML parsing; bundled venvs such as datahub-documents-bundled.)COMMENT
LOWdocker/snippets/ingestion/bundled_venv_config.py1# Copyright 2025 Acryl Data, Inc.COMMENT
LOWdocker/snippets/uv/profiles/default.toml1# Empty file since the default is public PyPiCOMMENT
LOWdocker/datahub-mae-consumer/start.sh81 echo "[STARTUP] Generating deterministic classpath from extracted layers"COMMENT
LOWdocker/datahub-actions/readiness-check.sh1#!/bin/bashCOMMENT
LOWdocker/datahub-actions/start.sh1#!/bin/bashCOMMENT
LOWdocker/datahub-actions/config/teams_action.yaml1# Copyright 2021 Acryl Data, Inc.COMMENT
LOWdocker/datahub-actions/config/executor.yaml1# Copyright 2021 Acryl Data, Inc.COMMENT
LOWdocker/datahub-actions/config/slack_action.yaml1# Copyright 2021 Acryl Data, Inc.COMMENT
LOW…ker/datahub-actions/config/doc_propagation_action.yaml1# Copyright 2021 Acryl Data, Inc.COMMENT
LOWdocker/quickstart/quickstart_version_mapping.yaml1# This file is used by the CLI to map quickstart version "labels" to docker tags and git refs.COMMENT
LOWdocker/airflow/docker-compose.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWdocker/airflow/docker-compose.yaml21# WARNING: This configuration is for local development. Do not use it in a production deployment.COMMENT
LOWdocker/profiles/docker-compose.ollama.yml61# When the debug-ai profile is active, tell GMS to use the local Ollama provider.COMMENT
LOWdocker/profiles/docker-compose.zdu-test-override.yml1# ZDU test-framework compose override — NOT part of the production stack.COMMENT
LOWdocker/datahub-upgrade/README.md101DATAHUB_MAE_CONSUMER_HOST=<your-mae-consumer-host>COMMENT
LOW…/com/linkedin/metadata/trace/TraceServiceImplTest.java501COMMENT
LOW…etadata/entity/EbeanEntityServiceOptimizationTest.java41 Counts for ORM optimization calculationsCOMMENT
LOW…ch/elasticsearch/client/shim/SearchClientShimTest.java141 assertEquals(copy.getConnectionRequestTimeout(), Integer.valueOf(10000));COMMENT
LOW…va/com/linkedin/metadata/entity/EntityServiceImpl.java1101 // Generate default aspects within the transaction (they are re-calculatedCOMMENT
LOW…com/linkedin/metadata/entity/ebean/EbeanAspectDao.java421 }COMMENT
LOW…com/linkedin/metadata/entity/ebean/EbeanAspectDao.java621 @Nonnull final List<EbeanAspectV2.PrimaryKey> keys,COMMENT
LOW…/search/elasticsearch/indexbuilder/ESIndexBuilder.java221 // fixed...COMMENT
LOWdatahub-agent-context/setup.py1# Copyright 2025 Acryl Data, Inc.COMMENT
LOWdatahub-agent-context/tests/__init__.py1# Copyright 2025 Acryl Data, Inc.COMMENT
LOWdatahub-agent-context/tests/unit/__init__.py1# Copyright 2025 Acryl Data, Inc.COMMENT
LOW…gent-context/tests/unit/snowflake/test_udf_coverage.py241COMMENT
LOWdatahub-agent-context/examples/__init__.py1# Copyright 2025 Acryl Data, Inc.COMMENT
LOWdatahub-agent-context/examples/langchain/__init__.py1# Copyright 2025 Acryl Data, Inc.COMMENT
LOW…ub-agent-context/src/datahub_agent_context/_version.py1# Copyright 2025 Acryl Data, Inc.COMMENT
LOW…ub-agent-context/src/datahub_agent_context/__init__.py1# Copyright 2025 Acryl Data, Inc.COMMENT
LOW…xt/src/datahub_agent_context/mcp_tools/gql/__init__.py1# Copyright 2021 Acryl Data, Inc.COMMENT
LOW…nfiguration/src/main/resources/entity-graph-cache.yaml1# Bundled entity graph cache definitions (merged at startup via entityGraphCache.configFile).COMMENT
LOW…ce/configuration/src/main/resources/search_config.yaml41COMMENT
LOW…onfiguration/src/main/resources/rate-limit-config.yaml1# Optional rate-limit override (Tier 2) — intentionally empty.COMMENT
LOW…vice/configuration/src/main/resources/application.yaml101 # default. Baseline comes from entity-registry.yml (`viewUnrestricted: true`). Empty `value`COMMENT
LOW…vice/configuration/src/main/resources/application.yaml121 # The value of cliVersion is substituted in by the processResources Gradle task.COMMENT
LOW…vice/configuration/src/main/resources/application.yaml721 mappingConfig: ${ELASTICSEARCH_ENTITY_INDEX_V3_MAPPING_CONFIG:search_entity_mapping_config.yaml}COMMENT
LOW…vice/configuration/src/main/resources/application.yaml1761 # When true, timing metrics are collected for individual GraphQL field resolversCOMMENT
LOW…vice/configuration/src/main/resources/application.yaml1781 # Pattern syntax:COMMENT
LOW…vice/configuration/src/main/resources/application.yaml1801 # Override: GRAPHQL_SHAPE_LOGGING_ENABLED=trueCOMMENT
LOW…rc/main/resources/bootstrap_mcps/lifecycle-stages.yaml1# Example lifecycle stage types for entity governance.COMMENT
LOW…rc/main/resources/bootstrap_mcps/lifecycle-stages.yaml21# entityTypes:COMMENT
LOW…rc/main/resources/bootstrap_mcps/lifecycle-stages.yaml41# - glossaryTermCOMMENT
LOW…rc/main/resources/bootstrap_mcps/lifecycle-stages.yaml61# entityTypes:COMMENT
LOW…rc/main/resources/bootstrap_mcps/lifecycle-stages.yaml81# Remains visible in search with a deprecated label so consumers canCOMMENT
LOW…rc/main/resources/bootstrap_mcps/lifecycle-stages.yaml101# description: >-COMMENT
LOW…/metadata/config/search/BuildIndicesConfiguration.java81 // Requests per second during NORMAL cluster health tier (default 500)COMMENT
LOW…/metadata/config/search/BuildIndicesConfiguration.java101 // Environment variable: ELASTICSEARCH_BUILD_INDICES_WRITE_REJECTION_RED_THRESHOLDCOMMENT
LOW…factory/system_telemetry/OpenTelemetryBaseFactory.java121 props.put(propKey, "none");COMMENT
LOW…din/metadata/model/validation/ModelValidationTask.java41 "Failed to find Snapshot model with name %s in parsed schemas!",COMMENT
LOWdatahub-actions/setup.py1# Copyright 2021 Acryl Data, Inc.COMMENT
LOWdatahub-actions/tests/conftest.py1# Copyright 2021 Acryl Data, Inc.COMMENT
680 more matches not shown…
Cross-File Repetition116 hits · 580 pts
SeverityFileLineSnippetContext
HIGHsmoke-test/test_system_info.py0mutation createaccesstoken($input: createaccesstokeninput!) { createaccesstoken(input: $input) { accesstoken metadata { STRING
HIGHsmoke-test/test_authentication_e2e.py0mutation createaccesstoken($input: createaccesstokeninput!) { createaccesstoken(input: $input) { accesstoken metadata { STRING
HIGHsmoke-test/tests/utils.py0mutation createaccesstoken($input: createaccesstokeninput!) { createaccesstoken(input: $input) { accesstoken metadata { STRING
HIGHsmoke-test/tests/metrics/usage_aggregation_metrics.py0mutation createaccesstoken($input: createaccesstokeninput!) { createaccesstoken(input: $input) { accesstoken metadata { STRING
HIGHsmoke-test/test_system_info.py0mutation revokeaccesstoken($tokenid: string!) { revokeaccesstoken(tokenid: $tokenid) }STRING
HIGHsmoke-test/test_authentication_e2e.py0mutation revokeaccesstoken($tokenid: string!) { revokeaccesstoken(tokenid: $tokenid) }STRING
HIGHsmoke-test/tests/utils.py0mutation revokeaccesstoken($tokenid: string!) { revokeaccesstoken(tokenid: $tokenid) }STRING
HIGHsmoke-test/tests/audit_events/audit_events_test.py0mutation revokeaccesstoken($tokenid: string!) { revokeaccesstoken(tokenid: $tokenid) }STRING
HIGH…e-test/tests/service_accounts/test_service_accounts.py0mutation revokeaccesstoken($tokenid: string!) { revokeaccesstoken(tokenid: $tokenid) }STRING
HIGHsmoke-test/tests/tokens/token_utils.py0mutation revokeaccesstoken($tokenid: string!) { revokeaccesstoken(tokenid: $tokenid) }STRING
HIGHsmoke-test/tests/tokens/revokable_access_token_test.py0mutation revokeaccesstoken($tokenid: string!) { revokeaccesstoken(tokenid: $tokenid) }STRING
HIGH…ngestion/src/datahub/ingestion/source/gc/datahub_gc.py0mutation revokeaccesstoken($tokenid: string!) { revokeaccesstoken(tokenid: $tokenid) }STRING
HIGHsmoke-test/CLAUDE.MD0query getdataset($urn: string!) { dataset(urn: $urn) { urn name } }STRING
HIGH…ke-test/tests/knowledge/document_search_filter_test.py0query getdataset($urn: string!) { dataset(urn: $urn) { urn name } }STRING
HIGH…st/tests/knowledge/test_document_hierarchy_settings.py0query getdataset($urn: string!) { dataset(urn: $urn) { urn name } }STRING
HIGHsmoke-test/tests/audit_events/audit_events_test.py0mutation updatepolicy($urn: string!, $input: policyupdateinput!) {\n updatepolicy(urn: $urn, input: $input) }STRING
HIGHsmoke-test/tests/privileges/test_privileges.py0mutation updatepolicy($urn: string!, $input: policyupdateinput!) {\n updatepolicy(urn: $urn, input: $input) }STRING
HIGHsmoke-test/tests/privileges/utils.py0mutation updatepolicy($urn: string!, $input: policyupdateinput!) {\n updatepolicy(urn: $urn, input: $input) }STRING
HIGHsmoke-test/tests/audit_events/audit_events_test.py0mutation createaccesstoken($input: createaccesstokeninput!) { createaccesstoken(input: $input) { accesstoken metadata { STRING
HIGH…e-test/tests/service_accounts/test_service_accounts.py0mutation createaccesstoken($input: createaccesstokeninput!) { createaccesstoken(input: $input) { accesstoken metadata { STRING
HIGHsmoke-test/tests/tokens/revokable_access_token_test.py0mutation createaccesstoken($input: createaccesstokeninput!) { createaccesstoken(input: $input) { accesstoken metadata { STRING
HIGHmetadata-ingestion/src/datahub/cli/sso_cli.py0mutation createaccesstoken($input: createaccesstokeninput!) { createaccesstoken(input: $input) { accesstoken metadata { STRING
HIGHmetadata-ingestion/src/datahub/cli/cli_utils.py0mutation createaccesstoken($input: createaccesstokeninput!) { createaccesstoken(input: $input) { accesstoken metadata { STRING
HIGHsmoke-test/tests/audit_events/audit_events_test.py0query listaccesstokens($input: listaccesstokeninput!) { listaccesstokens(input: $input) { start count total tokens { urnSTRING
HIGHsmoke-test/tests/tokens/token_utils.py0query listaccesstokens($input: listaccesstokeninput!) { listaccesstokens(input: $input) { start count total tokens { urnSTRING
HIGHsmoke-test/tests/tokens/revokable_access_token_test.py0query listaccesstokens($input: listaccesstokeninput!) { listaccesstokens(input: $input) { start count total tokens { urnSTRING
HIGHsmoke-test/tests/status/test_lifecycle_state.py0mutation createdoc($input: createdocumentinput!) { createdocument(input: $input) }STRING
HIGH…ke-test/tests/knowledge/document_search_filter_test.py0mutation createdoc($input: createdocumentinput!) { createdocument(input: $input) }STRING
HIGH…st/tests/knowledge/test_document_hierarchy_settings.py0mutation createdoc($input: createdocumentinput!) { createdocument(input: $input) }STRING
HIGHsmoke-test/tests/status/test_lifecycle_state.py0mutation deletedoc($urn: string!) { deletedocument(urn: $urn) }STRING
HIGH…ke-test/tests/knowledge/document_search_filter_test.py0mutation deletedoc($urn: string!) { deletedocument(urn: $urn) }STRING
HIGH…st/tests/knowledge/test_document_hierarchy_settings.py0mutation deletedoc($urn: string!) { deletedocument(urn: $urn) }STRING
HIGHsmoke-test/tests/policies/test_policy_eval_perf.py0mutation createpolicy($input: policyupdateinput!) { createpolicy(input: $input) }STRING
HIGHsmoke-test/tests/policies/test_policies.py0mutation createpolicy($input: policyupdateinput!) { createpolicy(input: $input) }STRING
HIGHsmoke-test/tests/privileges/test_privileges.py0mutation createpolicy($input: policyupdateinput!) { createpolicy(input: $input) }STRING
HIGHsmoke-test/tests/privileges/utils.py0mutation createpolicy($input: policyupdateinput!) { createpolicy(input: $input) }STRING
HIGHsmoke-test/tests/policies/test_policies.py0fixture to execute setup before and tear down after all tests are runSTRING
HIGHsmoke-test/tests/privileges/test_privileges.py0fixture to execute setup before and tear down after all tests are runSTRING
HIGHsmoke-test/tests/tokens/revokable_access_token_test.py0fixture to execute setup before and tear down after all tests are runSTRING
HIGHsmoke-test/tests/tokens/session_access_token_test.py0fixture to execute setup before and tear down after all tests are runSTRING
HIGHsmoke-test/tests/utilities/multi_user.py0query getinvitetoken($input: getinvitetokeninput!) { getinvitetoken(input: $input){ invitetoken } }STRING
HIGHsmoke-test/tests/tokens/revokable_access_token_test.py0query getinvitetoken($input: getinvitetokeninput!) { getinvitetoken(input: $input){ invitetoken } }STRING
HIGHsmoke-test/tests/tokens/session_access_token_test.py0query getinvitetoken($input: getinvitetokeninput!) { getinvitetoken(input: $input){ invitetoken } }STRING
HIGH…e-test/tests/knowledge/test_document_search_history.py0mutation createka($input: createdocumentinput!) { createdocument(input: $input) }STRING
HIGHsmoke-test/tests/knowledge/test_document_crud.py0mutation createka($input: createdocumentinput!) { createdocument(input: $input) }STRING
HIGH…st/tests/knowledge/test_document_hierarchy_settings.py0mutation createka($input: createdocumentinput!) { createdocument(input: $input) }STRING
HIGH…e-test/tests/knowledge/document_change_history_test.py0mutation createka($input: createdocumentinput!) { createdocument(input: $input) }STRING
HIGH…e-test/tests/knowledge/test_document_search_history.py0mutation movedoc($input: movedocumentinput!) { movedocument(input: $input) }STRING
HIGHsmoke-test/tests/knowledge/test_document_crud.py0mutation movedoc($input: movedocumentinput!) { movedocument(input: $input) }STRING
HIGH…st/tests/knowledge/test_document_hierarchy_settings.py0mutation movedoc($input: movedocumentinput!) { movedocument(input: $input) }STRING
HIGH…e-test/tests/knowledge/test_document_search_history.py0mutation deleteka($urn: string!) { deletedocument(urn: $urn) }STRING
HIGHsmoke-test/tests/knowledge/test_document_crud.py0mutation deleteka($urn: string!) { deletedocument(urn: $urn) }STRING
HIGH…st/tests/knowledge/test_document_hierarchy_settings.py0mutation deleteka($urn: string!) { deletedocument(urn: $urn) }STRING
HIGH…e-test/tests/knowledge/document_change_history_test.py0mutation deleteka($urn: string!) { deletedocument(urn: $urn) }STRING
HIGH…e-test/tests/knowledge/test_document_search_history.py0query searchdocs($input: searchdocumentsinput!) { searchdocuments(input: $input) { total documents { urn info { title stSTRING
HIGH…ke-test/tests/knowledge/document_search_filter_test.py0query searchdocs($input: searchdocumentsinput!) { searchdocuments(input: $input) { total documents { urn info { title stSTRING
HIGH…st/tests/knowledge/test_document_hierarchy_settings.py0query searchdocs($input: searchdocumentsinput!) { searchdocuments(input: $input) { total documents { urn info { title stSTRING
HIGHsmoke-test/tests/knowledge/test_document_crud.py0mutation updatestatus($input: updatedocumentstatusinput!) { updatedocumentstatus(input: $input) }STRING
HIGH…ke-test/tests/knowledge/document_search_filter_test.py0mutation updatestatus($input: updatedocumentstatusinput!) { updatedocumentstatus(input: $input) }STRING
HIGH…st/tests/knowledge/test_document_hierarchy_settings.py0mutation updatestatus($input: updatedocumentstatusinput!) { updatedocumentstatus(input: $input) }STRING
56 more matches not shown…
Verbosity Indicators301 hits · 536 pts
SeverityFileLineSnippetContext
LOW…phql/resolvers/assertion/EntityAssertionsResolver.java58 // Step 1: Fetch set of assertions associated with the target entity from the GraphCOMMENT
LOW…phql/resolvers/assertion/EntityAssertionsResolver.java74 // Step 2: Hydrate the assertion entities based on the urns from step 1COMMENT
LOW…phql/resolvers/assertion/EntityAssertionsResolver.java82 // Step 3: Map GMS assertion model to GraphQL model, preserving graph-store order.COMMENT
LOW…phql/resolvers/assertion/EntityAssertionsResolver.java97 // Step 4: Package and return resultCOMMENT
LOW…hql/resolvers/assertion/AssertionRunEventResolver.java62 // Step 1: Fetch aspects from GMSCOMMENT
LOW…hql/resolvers/assertion/AssertionRunEventResolver.java77 // Step 2: Bind profiles into GraphQL strong types.COMMENT
LOW…hql/resolvers/assertion/AssertionRunEventResolver.java83 // Step 3: Package and return response.COMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java111 // Step 1: Search using service to get URNsCOMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java121 // Step 2: Extract URNs from search resultsCOMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java127 // Step 3: Batch hydrate/resolve the Document entitiesCOMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java135 // Step 4: Map entities in the same order as search resultsCOMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java141 // Step 5: Convert to GraphQL Document objectsCOMMENT
LOW…aphql/resolvers/knowledge/SearchDocumentsResolver.java148 // Step 6: Build the resultCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java103 // Step 1: Search using service to get URNsCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java121 // Step 2: Extract URNs from search resultsCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java127 // Step 3: Batch hydrate/resolve the Document entitiesCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java135 // Step 4: Map entities in the same order as search resultsCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java141 // Step 5: Convert to GraphQL Document objectsCOMMENT
LOW…phql/resolvers/knowledge/RelatedDocumentsResolver.java148 // Step 6: Build the resultCOMMENT
LOW…raphql/resolvers/incident/EntityIncidentsResolver.java68 // Step 1: Fetch set of incidents associated with the target entity from the SearchCOMMENT
LOW…raphql/resolvers/incident/EntityIncidentsResolver.java89 // Step 2: Hydrate the incident entitiesCOMMENT
LOW…raphql/resolvers/incident/EntityIncidentsResolver.java97 // Step 3: Map GMS incident model to GraphQL modelCOMMENT
LOW…raphql/resolvers/incident/EntityIncidentsResolver.java108 // Step 4: Package and return resultCOMMENT
LOW…ahub/graphql/resolvers/jobs/ExecutionRunsResolver.java64 // Step 1: Fetch set of task runs associated with the target entity from the SearchCOMMENT
LOW…ahub/graphql/resolvers/jobs/ExecutionRunsResolver.java82 // Step 2: Hydrate the incident entitiesCOMMENT
LOW…ahub/graphql/resolvers/jobs/ExecutionRunsResolver.java90 // Step 3: Map GMS incident model to GraphQL modelCOMMENT
LOW…ahub/graphql/resolvers/jobs/ExecutionRunsResolver.java101 // Step 4: Package and return resultCOMMENT
LOW…datahub/graphql/resolvers/jobs/EntityRunsResolver.java68 // Step 1: Fetch set of task runs associated with the target entity from the SearchCOMMENT
LOW…datahub/graphql/resolvers/jobs/EntityRunsResolver.java86 // Step 2: Hydrate the incident entitiesCOMMENT
LOW…datahub/graphql/resolvers/jobs/EntityRunsResolver.java94 // Step 3: Map GMS instance model to GraphQL modelCOMMENT
LOW…datahub/graphql/resolvers/jobs/EntityRunsResolver.java105 // Step 4: Package and return resultCOMMENT
LOW…resolvers/datacontract/EntityDataContractResolver.java48 // Step 1: Fetch the contract associated with the dataset.COMMENT
LOW…resolvers/datacontract/EntityDataContractResolver.java77 // Step 2: Hydrate the contract entities based on the urns from step 1COMMENT
LOW…resolvers/datacontract/EntityDataContractResolver.java86 // Step 4: Package and return resultCOMMENT
LOW…/com/linkedin/metadata/trace/TraceServiceImplTest.java528 // Step 1: Verify that parsing this trace ID produces a far-future epochCOMMENT
LOW…/com/linkedin/metadata/trace/TraceServiceImplTest.java537 // Step 2: Verify that the queue time calculation would produce a value that overflowsCOMMENT
LOW…/com/linkedin/metadata/trace/TraceServiceImplTest.java543 // Step 3: Confirm that Duration.ofMillis(queueTimeMs).toNanos() would overflowCOMMENT
LOW…/com/linkedin/metadata/trace/TraceServiceImplTest.java555 // Step 4: Verify the fix — extractTraceIdEpochMillis returns null for this trace ID,COMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1399 // Step 1: Create initial index with 1 shardCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1405 // Step 2: Index some documentsCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1425 // Step 3: Create builder with different shard count to force requiresReindex, and non-zeroCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1471 // Step 6: Restore settingsCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1478 // Step 7: Verify next index has all documentsCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1494 // Step 8: Verify alias still points to original index (no swap happened)COMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1504 // Step 9: Verify next index has the new shard countCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1443 // Step 4: Run incremental reindex (Phase 1)COMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1459 // Step 5: Poll until reindex completesCOMMENT
LOW…metadata/search/indexbuilder/IndexBuilderTestBase.java1516 // Step 10: Verify settings were restored (replicas back to target, refresh interval restored)COMMENT
LOW…n/metadata/search/elasticsearch/query/ESSearchDAO.java311 // Step 1: construct the queryCOMMENT
LOW…n/metadata/search/elasticsearch/query/ESSearchDAO.java325 // Step 2: execute the query and extract results, validated against document model as wellCOMMENT
LOW…sticsearch/indexbuilder/DestinationIndexOptimizer.java107 // Step 1: Fetch all original settings in a single API call (batch operation)COMMENT
LOW…sticsearch/indexbuilder/DestinationIndexOptimizer.java167 // Step 2: Apply optimizations in a single atomic API call (batch operation)COMMENT
LOW…in/metadata/aspect/consistency/ConsistencyService.java1138 // For orphan check, we need to check if entity exists in SQLCOMMENT
LOW…ain/java/com/linkedin/metadata/kafka/CDCProcessor.java155 // Step 1: Parse JSON using Jackson ObjectMapperCOMMENT
LOW…ain/java/com/linkedin/metadata/kafka/CDCProcessor.java178 // Step 2: Extract "before" and "after" fields as JsonNode objectsCOMMENT
LOW…ain/java/com/linkedin/metadata/kafka/CDCProcessor.java182 // Step 3: Check if we should process this record (only latest versions)COMMENT
LOW…ain/java/com/linkedin/metadata/kafka/CDCProcessor.java188 // Step 4: Extract urn, aspect, metadata, systemmetadata fields from both before/after CDCCOMMENT
LOW…ain/java/com/linkedin/metadata/kafka/CDCProcessor.java207 // Step 5: Deserialize the "metadata" JSON strings to RecordTemplate objectsCOMMENT
LOW…ain/java/com/linkedin/metadata/kafka/CDCProcessor.java228 // Step 6: Parse systemmetadata JSON strings to SystemMetadata objectsCOMMENT
LOW…ain/java/com/linkedin/metadata/kafka/CDCProcessor.java239 // Step 7: Create ChangeMCP using "after" record dataCOMMENT
241 more matches not shown…
Redundant / Tautological Comments281 hits · 424 pts
SeverityFileLineSnippetContext
LOWdatahub-agent-context/examples/langchain/setup_dev.sh9# Check if we're in the right directoryCOMMENT
LOW…tahub-agent-context/examples/google_adk/basic_agent.py172 # Set BIGQUERY_PROJECT_ID to control which project is billed for queries;COMMENT
LOWdatahub-agent-context/examples/google_adk/setup_dev.sh9# Check if we're in the right directoryCOMMENT
LOW…ntext/src/datahub_agent_context/snowflake/snowflake.py39 # Check if URL has a protocolCOMMENT
LOW…ontext/src/datahub_agent_context/mcp_tools/entities.py60 # Check if entity exists firstCOMMENT
LOW…ontext/src/datahub_agent_context/mcp_tools/entities.py86 # Check if entity data was returnedCOMMENT
LOW…ontext/src/datahub_agent_context/mcp_tools/entities.py199 # Check if entity data was returnedCOMMENT
LOW…context/src/datahub_agent_context/mcp_tools/lineage.py449 # Check if any paths contain QUERY entities (with safe null handling)COMMENT
LOW…context/src/datahub_agent_context/mcp_tools/helpers.py209 # Check if adding this entity would exceed budgetCOMMENT
LOW…context/src/datahub_agent_context/mcp_tools/helpers.py417 # Check if this is column-level lineage by looking for pathsCOMMENT
LOW…nt-context/src/datahub_agent_context/mcp_tools/base.py40 # Check if we've already determined newer GMS fields support for this graphCOMMENT
LOW…nt-context/src/datahub_agent_context/mcp_tools/base.py81 # Check if this is a field validation error and we tried with newer GMS fields enabledCOMMENT
LOW…ema-registry-servlet/scripts/extract_kafka_messages.sh25# Check if kcat is availableCOMMENT
LOW…ema-registry-servlet/scripts/extract_kafka_messages.sh43 # Check if topic exists and has messagesCOMMENT
LOW…ema-registry-servlet/scripts/extract_kafka_messages.sh50 # Check if topic has messages by trying to get the first messageCOMMENT
LOW…tahub-actions/src/datahub_actions/pipeline/pipeline.py273 # Increment statsCOMMENT
LOWsmoke-test/conftest.py352 # Check if FILTERED_TESTS is set (for retry logic)COMMENT
LOWsmoke-test/conftest.py373 # Check if this item's module is in the filtered listCOMMENT
LOWsmoke-test/tests/cypress/timestamp_updater.py82 # Check if this file needs timestamp updatesCOMMENT
LOWsmoke-test/tests/cypress/timestamp_updater.py87 # Read the fileCOMMENT
LOW…e-test/tests/library_examples/test_library_examples.py80 # Check if this test has dependenciesCOMMENT
LOWsmoke-test/tests/openapi/v1/test_tracking.py44 # Check if Mixpanel API secret is available in environment variablesCOMMENT
LOWsmoke-test/tests/openapi/v1/test_tracking.py49 # Check if Mixpanel is enabled in server configurationCOMMENT
LOWsmoke-test/tests/openapi/v1/test_tracking.py303 # Check if this is our test eventCOMMENT
LOWsmoke-test/tests/privileges/test_privileges.py219 # Assign privileges to the new user to manage secretsCOMMENT
LOWsmoke-test/tests/privileges/test_privileges.py287 # Assign privileges to the new user to manage ingestion sourceCOMMENT
LOWsmoke-test/tests/privileges/test_privileges.py383 # Assign privileges to the new user to create and manage access tokensCOMMENT
LOWsmoke-test/tests/privileges/test_privileges.py495 # Assign privileges to the new user to create and manage policiesCOMMENT
LOWsmoke-test/tests/privileges/test_privileges.py586 # Assign user to groupCOMMENT
LOWsmoke-test/tests/privileges/utils.py274 # Check if the response structure is as expected before accessingCOMMENT
LOW…e-test/tests/knowledge/document_change_history_test.py137 # Check if we have a CREATED eventSTRING
LOWsmoke-test/tests/semantic/test_current_offset_api.py56 # Check if offsetId is in responseCOMMENT
LOWsmoke-test/tests/semantic/test_event_mode_fallback.py482 # Check if state contains event offsetsCOMMENT
LOWsmoke-test/tests/semantic/test_event_driven_docs.py351 # Check if process is still runningSTRING
LOWsmoke-test/tests/semantic/test_event_driven_docs.py423 # Check if updated content appears in chunksSTRING
LOWsmoke-test/tests/analytics/conftest.py136 # Check if users file exists, create minimal one if notCOMMENT
LOW…ces/analytics_backfill/load_events_to_elasticsearch.sh97# Check if Elasticsearch is accessibleCOMMENT
LOW…ces/analytics_backfill/load_events_to_elasticsearch.sh106# Check if index existsCOMMENT
LOWmetadata-ingestion-modules/airflow-plugin/run-tests.sh26# Check if Docker is runningCOMMENT
LOWmetadata-ingestion-modules/airflow-plugin/run-tests.sh55 # Set HOME to /tmp so all cache directories are writableCOMMENT
LOW…gestion-modules/airflow-plugin/docker-compose.test.yml25 # Set HOME to /tmp so all cache directories are writableCOMMENT
LOW…b_airflow_plugin/airflow3/_athena_openlineage_patch.py75 # Check if SQL parsing result is already in run_facets (from SQLParser patch)COMMENT
LOW…rc/datahub_airflow_plugin/airflow3/datahub_listener.py694 # Check if the operator has OpenLineage supportCOMMENT
LOW…rc/datahub_airflow_plugin/airflow3/datahub_listener.py751 # Check if DataHub SQL parsing result is in run_facets (from our patch)COMMENT
LOW…rc/datahub_airflow_plugin/airflow3/datahub_listener.py1127 # Check if DAG is allowed by filter patternCOMMENT
LOW…rc/datahub_airflow_plugin/airflow3/datahub_listener.py1157 # Check if emitter is availableCOMMENT
LOW…rc/datahub_airflow_plugin/airflow3/datahub_listener.py1271 # Check if DAG is allowed before doing any expensive operationsCOMMENT
LOW…b_airflow_plugin/airflow3/_sqlite_openlineage_patch.py31 # Check if already patchedCOMMENT
LOW…c/datahub_airflow_plugin/airflow3/_sql_parser_patch.py76 # Check if OpenLineage plugin is enabled and load multi-statement flagCOMMENT
LOW…c/datahub_airflow_plugin/airflow3/_sql_parser_patch.py151 # Check if SQL still contains templates (should be rendered by operator)COMMENT
LOW…airflow_plugin/airflow3/_teradata_openlineage_patch.py96 # Check if SQL parsing result is already in run_facets (from SQLParser patch)COMMENT
LOW…airflow_plugin/airflow3/_teradata_openlineage_patch.py295 # Check if wrapper creation failed (import error)COMMENT
LOW…airflow_plugin/airflow3/_bigquery_openlineage_patch.py130 # Check if there's a destinationTable in configurationCOMMENT
LOW…airflow_plugin/airflow3/_bigquery_openlineage_patch.py253 # Check if operator should be patchedCOMMENT
LOW…ration/java/datahub-schematron/cli/scripts/mce_diff.py283 # Read the files into json objects and compare themCOMMENT
LOW…n/java/acryl-spark-lineage/scripts/generate-patches.sh35# Check if upstream directory existsCOMMENT
LOW.github/workflows/check-python-deps.yml170 # Check if we have violationsCOMMENT
LOW.github/workflows/update-test-weights.yml128 # Check if PR body was generated (non-empty file means changes exceed threshold)COMMENT
LOW.github/workflows/metadata-ingestion.yml300 # Check if any Python file in metadata-ingestion is in the changed filesCOMMENT
LOW.github/workflows/connector-tests-trigger.yml109 # Check if PR has the skip-connector-tests labelCOMMENT
221 more matches not shown…
Fake / Example Data393 hits · 411 pts
SeverityFileLineSnippetContext
LOWdatahub-graphql-core/README.md85 an URN to a "placeholder" GraphQL entity which is subsequently resolved by the GraphQL engine.CODE
LOW…va/com/linkedin/datahub/graphql/GraphQLEngineTest.java134 userDatabase.put("1", new User("1", "John Doe", "john@example.com"));CODE
LOW…va/com/linkedin/datahub/graphql/GraphQLEngineTest.java169 assertEquals(user.get("name"), "John Doe");CODE
LOW…om/linkedin/metadata/entity/EntityServiceImplTest.java146 CorpUserInfo originalInfo = AspectGenerationUtils.createCorpUserInfo("test@test.com");CODE
LOW…om/linkedin/metadata/entity/EntityServiceImplTest.java204 CorpUserInfo originalInfo = AspectGenerationUtils.createCorpUserInfo("test@test.com");CODE
LOW…om/linkedin/metadata/entity/EntityServiceImplTest.java266 CorpUserInfo newInfo = AspectGenerationUtils.createCorpUserInfo("test@test.com");CODE
LOW…om/linkedin/metadata/entity/EntityServiceImplTest.java375 CorpUserInfo originalInfo = AspectGenerationUtils.createCorpUserInfo("test@test.com");CODE
LOW…adata/search/query/request/SearchQueryBuilderTest.java1267 "name:'John Doe'");CODE
LOW…tem_info/collectors/SpringComponentsCollectorTest.java65 assertEquals(maeInfo.getProperties().get("mode"), "placeholder");CODE
LOW…tem_info/collectors/SpringComponentsCollectorTest.java74 assertEquals(mceInfo.getProperties().get("mode"), "placeholder");CODE
LOW…tem_info/collectors/SpringComponentsCollectorTest.java177 assertEquals(properties.get("mode"), "placeholder");CODE
LOW…tem_info/collectors/SpringComponentsCollectorTest.java209 assertEquals(properties.get("mode"), "placeholder");CODE
LOW…/system_info/collectors/SpringComponentsCollector.java139 "mode", "placeholder",CODE
LOW…/system_info/collectors/SpringComponentsCollector.java176 "mode", "placeholder",CODE
LOW…ent-context/tests/unit/mcp_tools/test_save_document.py39 "displayName": "John Doe",CODE
LOW…ent-context/tests/unit/mcp_tools/test_save_document.py40 "fullName": "John Doe",CODE
LOW…ent-context/tests/unit/mcp_tools/test_save_document.py45 "displayName": "John Doe",CODE
LOW…ent-context/tests/unit/mcp_tools/test_save_document.py77 assert _get_user_display_name(mock_user_info) == "John Doe"CODE
LOW…ent-context/tests/unit/mcp_tools/test_save_document.py182 assert result["author"] == "John Doe"CODE
LOW…ent-context/tests/unit/mcp_tools/test_save_document.py437 assert result["author"] == "John Doe"CODE
LOW…ent-context/tests/unit/mcp_tools/test_save_document.py628 assert result["author"] == "John Doe"CODE
LOW…ent-context/tests/unit/mcp_tools/test_save_document.py680 assert result["author"] == "John Doe"CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java43 patchBuilder.add("/name", "John Doe");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java99 addOp.setValue("John Doe");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java226 addressNode.put("street", "123 Main St");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java231 rootNode.put("name", "John Doe");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java252 assertEquals(dataMap.getString("name"), "John Doe");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java255 assertEquals(addressData.getString("street"), "123 Main St");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java264 phoneNumbers.add("555-1234");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java265 phoneNumbers.add("555-5678");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java300 assertEquals(phonesList.get(0), "555-1234");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java301 assertEquals(phonesList.get(1), "555-5678");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java346 homePhone.put("number", "555-1234");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java350 workPhone.put("number", "555-5678");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java392 assertEquals(homePhoneData.getString("number"), "555-1234");CODE
LOW…om/linkedin/metadata/utils/GenericRecordUtilsTest.java396 assertEquals(workPhoneData.getString("number"), "555-5678");CODE
LOW…ct/openapi/operations/v1/SystemInfoControllerTest.java240 "mode", "placeholder",CODE
LOW…tory/search/semantic/EmbeddingProviderFactoryTest.java386 "sk-test-fake-key", "https://api.openai.com/v1/embeddings", "text-embedding-3-small");CODE
LOW…tory/search/semantic/EmbeddingProviderFactoryTest.java424 "sk-test-fake-key", "https://api.openai.com/v1/embeddings", "text-embedding-3-large");CODE
LOW…io/datahubproject/event/ExternalEventsServiceTest.java85 testEvent1.put("name", "John Doe");CODE
LOW…io/datahubproject/event/ExternalEventsServiceTest.java90 testEvent2.put("name", "Jane Doe");CODE
LOW…ss/cypress/e2e/manage_tagsV2/search_bar_placeholder.js11 "placeholder",CODE
LOW…cypress/cypress/e2e/application/manage_applications.js7 "placeholder",CODE
LOWsmoke-test/tests/cli/user_cmd/test_user_add.py303 display_name = "John Doe"CODE
LOW…e-test/tests/zdu/framework/test_inject_traffic_dual.py23 urn="placeholder",CODE
LOW…e-test/tests/zdu/framework/test_inject_traffic_dual.py37 m.get_doc.return_value = {"urn": "placeholder"}CODE
LOW…ke-test/tests/zdu/framework/test_inject_traffic_pre.py23 urn="placeholder",CODE
LOW…ke-test/tests/zdu/framework/test_inject_traffic_pre.py37 m.get_doc.return_value = {"urn": "placeholder"}CODE
LOWsmoke-test/tests/containers/data.json144 "string": "John Doe"CODE
LOWsmoke-test/tests/containers/data.json156 "string": "John Doe"CODE
LOWdocs/cli.md850datahub user add --email user@example.com --display-name "John Doe" --password --role AdminCODE
LOWdocs/managed-datahub/smtp-email.md79export NOTIFICATION_FOOTER_TEXT="Acme Corp" # footer signature shown on every emailCODE
LOWdocs/api/tutorials/mlmodel-mlmodelgroup.md64>> Model Group Custom Properties: {'owner': 'John Doe', 'team': 'recommendations', 'domain': 'marketing'}CODE
LOWli-utils/src/test/resources/corp-user-info.json3 "email": "foo@bar.com",CODE
LOWdatahub-web-react/src/Mocks.tsx3959 description: 'Lorem ipsum dolor sit amet, consectetu',CODE
LOWdatahub-web-react/src/Mocks.tsx3959 description: 'Lorem ipsum dolor sit amet, consectetu',CODE
LOW…ct/src/app/entityV2/user/__tests__/UserHeader.test.tsx13 name="Jane Doe"CODE
LOW…ct/src/app/entityV2/user/__tests__/UserHeader.test.tsx21 expect(getByText('Jane Doe')).toBeInTheDocument();CODE
LOW…_/components/editor/extensions/htmlToMarkdown.test.tsx4 ['strike', '<strike>Lorem ipsum</strike>', '~Lorem ipsum~'],CODE
LOW…_/components/editor/extensions/htmlToMarkdown.test.tsx5 ['s', '<s>Lorem ipsum</s>', '~Lorem ipsum~'],CODE
333 more matches not shown…
Modern AI Meta-Vocabulary43 hits · 130 pts
SeverityFileLineSnippetContext
MEDIUMREADME.md145- **[Context Management Is the Missing Piece in the Agentic AI Puzzle](https://datahub.com/blog/context-management-is-thCODE
MEDIUMdocker/profiles/docker-compose.ollama.yml33 # One-shot init container that pulls the embedding model and warms it up.COMMENT
MEDIUM…context/src/datahub_agent_context/mcp_tools/queries.py185 # Truncate long SQL queries to prevent context window issuesCOMMENT
MEDIUM…context/src/datahub_agent_context/mcp_tools/helpers.py23# Maximum token count for tool responses to prevent context window issuesCOMMENT
MEDIUM…nt-context/src/datahub_agent_context/mcp_tools/base.py69 # Execute the GraphQL query with projection enabled for agentic callersCOMMENT
MEDIUMsmoke-test/tests/zdu/framework/runner.py187 # Phase 0 (combined) — SetupOldStackPhase orchestrates build_images +COMMENT
MEDIUM…est_resources/analytics_backfill/populate_analytics.sh5# This script orchestrates the entire process of:COMMENT
MEDIUMdocs/dev-guides/semantic-search/CONFIGURATION.md18# Vector dimensions (must match embedding model)COMMENT
MEDIUMdocs/dev-guides/semantic-search/CONFIGURATION.md41 # Define index mappings for each embedding model you useCOMMENT
MEDIUMmetadata-ingestion/setup.py516 # Unstructured ingest framework for pipeline orchestrationCOMMENT
MEDIUM…tadata-ingestion/tests/unit/informatica/test_source.py1328 # picks up MT1 as a predecessor; orchestrate's inputDatajobs is justCOMMENT
MEDIUM…tadata-ingestion/tests/unit/informatica/test_source.py1330 # ``input_ds → MT1 → MT2 → orchestrate → out_ds``.COMMENT
MEDIUM…tadata-ingestion/tests/unit/informatica/test_source.py1405 # End-of-lineage pass emits the orchestrate's DataJobInputOutput withCOMMENT
MEDIUM…tadata-ingestion/tests/unit/informatica/test_source.py1408 # ``last_MT → orchestrate → output_ds``.COMMENT
MEDIUM…tadata-ingestion/tests/unit/informatica/test_source.py1368 # Step metadata still preserved on orchestrate for auditing.COMMENT
MEDIUM…tadata-ingestion/tests/unit/informatica/test_source.py1454 # surface, so no orchestrate DataJob is emitted (keeps the catalogCOMMENT
MEDIUM…estion/tests/unit/sql_parsing/test_split_statements.py462 # surrounding WHILE/LOOP/RETURN scaffolding (equivalent-or-better for lineage).STRING
MEDIUM…/tests/integration/azure_data_factory/complex_mocks.py1284 # Main orchestration pipeline with both ExecutePipeline and Copy activitiesCOMMENT
MEDIUM…tegration/azure_data_factory/test_complex_pipelines.py345# Scenario: Parent pipeline orchestrates child pipelinesCOMMENT
MEDIUM…tegration/azure_data_factory/test_complex_pipelines.py1142# - Understanding orchestration hierarchiesCOMMENT
MEDIUM…tegration/azure_data_factory/test_complex_pipelines.py362# - Users need to see the full orchestration hierarchyCOMMENT
MEDIUM…tegration/azure_data_factory/test_complex_pipelines.py986# - Users need visibility into all orchestration activitiesCOMMENT
MEDIUM…tadata-ingestion/tests/integration/sigma/test_sigma.py2651 # Minimal workspace + workbook scaffolding so the pipeline runs.COMMENT
MEDIUM…tion/tests/integration/informatica/test_informatica.py184 # orchestrate DataJob + aggregated-lineage end-to-end.COMMENT
MEDIUM…sources/datahub-documents/datahub-documents_recipe.yml7 # Enables event-driven mode and incremental processingCOMMENT
MEDIUM…cs/sources/datahub-documents/datahub-documents_post.md125 # - Updating embedding modelCOMMENT
MEDIUM…ingestion/examples/recipes/datahub_documents_event.yml3# This recipe processes Document entities from DataHub in event-driven mode.COMMENT
MEDIUM…ingestion/examples/recipes/datahub_documents_batch.yml28 enabled: false # Set to true to use event-driven mode insteadCODE
MEDIUM…a-ingestion/examples/recipes/confluence_to_datahub.yml104# model: "text-embedding-3-small" # OpenAI embedding modelCOMMENT
MEDIUM…/datahub/ingestion/source/snowflake/snowflake_query.py26# scaffolding the filter is embedded in.COMMENT
MEDIUM…n/src/datahub/ingestion/source/notion/notion_source.py151 model: "embed-english-v3.0" # Cohere embedding modelSTRING
MEDIUM…tion/src/datahub/ingestion/source/snowplow/snowplow.py236 # Create processor dependencies (dependency injection)COMMENT
MEDIUM…ion/src/datahub/ingestion/source/informatica/source.py178 # ``input_ds → MT1 → … → MTn → orchestrate → out_ds``.COMMENT
MEDIUM…ion/src/datahub/ingestion/source/informatica/source.py181 # up to any Taskflow's orchestrate.COMMENT
MEDIUM…ion/src/datahub/ingestion/source/informatica/source.py997 # orchestrate so the Taskflow Lineage view has the full pipeline.COMMENT
MEDIUM…ion/src/datahub/ingestion/source/informatica/source.py1211 # onto the orchestrate's accumulated ``outputDatasets``.COMMENT
MEDIUM…datahub/ingestion/source/confluence/confluence_html.py81 # Template / space scaffoldingCOMMENT
MEDIUM…tahub/ingestion/source/unstructured/chunking_source.py331 # Choose mode: event-driven or batchCOMMENT
MEDIUM…/src/datahub/ingestion/source/sap_datasphere/client.py506 # Shared CSN request scaffold for flow/object design-time fetches: GET theCOMMENT
MEDIUM…stion/workunit_processors/auto_resolve_lineage_urns.py218 # These are the aspects a BI / orchestration source emits that carry *upstreamCOMMENT
MEDIUM…/src/datahub/ingestion/glossary/classifier_registry.py8# orchestration mixin) is intentionally retained so custom classifiers can still beCOMMENT
MEDIUM…src/datahub/ingestion/glossary/classification_types.py9# the orchestration mixin usable by third-party classifiers without the dependency.COMMENT
MEDIUMmetadata-ingestion/src/datahub/sdk/document.py1238 # Build embedding model data with metadataCOMMENT
AI Slop Vocabulary58 hits · 118 pts
SeverityFileLineSnippetContext
MEDIUM…vice/configuration/src/main/resources/application.yaml1780 # Works in conjunction with fieldLevelOperations - both conditions must match if both are setCOMMENT
LOWdatahub-actions/tests/unit/utils/test_kafka_msk_iam.py19 # If already present (package installed), just return the real moduleCOMMENT
LOW…hub_actions/plugin/action/execution/executor_action.py207 # and not just dicts, we can just pass in the DataHubSecretStoreConfigCOMMENT
MEDIUMsmoke-test/smoke.sh4# Runs a basic e2e test. It is not meant to be fully comprehensive,COMMENT
MEDIUMsmoke-test/tests/oauth/test_oauth_cli_gms.py38# harness overlays the triggering ref's SDK source onto the released installCOMMENT
MEDIUMsmoke-test/tests/zdu/framework/scenarios.py697 # harness — those need infrastructure outside this branch's scopeCOMMENT
LOWsmoke-test/tests/zdu/framework/test_rolling_restart.py317 # restart in a future profile) must not crash — just return empty.COMMENT
MEDIUMsmoke-test/tests/semantic/test_semantic_search.py628 # it is robust to stale documents from prior test runs ranking above ours.COMMENT
MEDIUM…sources/analytics_backfill/backfill_activity_events.py46# Entity types for analytics - comprehensive list of DataHub entitiesCOMMENT
MEDIUM…odules/airflow-plugin/tests/integration/test_plugin.py154 # task instance actually succeeded (the harness's own task dump shows allCOMMENT
LOW…odules/airflow-plugin/tests/integration/test_plugin.py860 # When run directly, just set up a local airflow instance.COMMENT
MEDIUM…rc/datahub_airflow_plugin/airflow3/datahub_listener.py915 # harness). Requires Airflow 3.x AssetEvent ORM.COMMENT
MEDIUM.github/scripts/compare_test_weights.py33 """Calculate comprehensive change statistics."""STRING
MEDIUM…gestion/tests/unit/test_athena_properties_extractor.py541 # Test comprehensive TBLPROPERTIES for IcebergSTRING
LOW…ata-ingestion/tests/unit/test_hive_metastore_source.py657 # Should not crash, just return no lineageCOMMENT
LOW…ata-ingestion/tests/unit/test_hive_metastore_source.py631 # Should not crash, just return no lineageCOMMENT
MEDIUMmetadata-ingestion/tests/unit/sdk_v2/test_chart.py362 # Add some input datasets for comprehensive testingCOMMENT
MEDIUM…tests/unit/tableau/test_tableau_virtual_connections.py339 """Test comprehensive error handling"""STRING
MEDIUMmetadata-ingestion/tests/unit/sigma/test_sigma_api.py2590 # stringify for substring matching so this is robust to theCOMMENT
MEDIUM…-ingestion/tests/unit/snowplow/test_snowplow_client.py393 """Test all API methods for comprehensive coverage."""STRING
LOW…ingestion/tests/unit/snowplow/test_schema_processor.py211 # Should not raise, just return empty mappingCOMMENT
LOW…data-ingestion/tests/integration/looker/test_looker.py694 # here we just return empty so the dashboard/look goldens are unaffected.COMMENT
LOW…estion/tests/integration/dbt/jaffle_shop_manifest.json1{"metadata": {"dbt_schema_version": "https://schemas.getdbt.com/dbt/manifest/v5.json", "dbt_version": "1.1.0", "generateCODE
MEDIUM…ests/integration/azure_data_factory/test_adf_source.py354 """Generate comprehensive test data for the ADF source."""STRING
MEDIUM…/tests/integration/kafka_connect/test_kafka_connect.py137 # a double and more robust check here is neededCOMMENT
MEDIUM…stion/tests/integration/cassandra/setup/cassandra.yaml1558# each write which may be lower in order to facilitate availability.COMMENT
MEDIUM…a-ingestion/examples/library/dataflow_comprehensive.py9# Create a DataFlow with comprehensive metadataCOMMENT
MEDIUMmetadata-ingestion/examples/iceberg/create_table.py12# Define a more comprehensive schema for ski resort dataCOMMENT
MEDIUMmetadata-ingestion/scripts/connector_registry.py111 """Generate a comprehensive registry of connector metadata across all plugins."""STRING
MEDIUMmetadata-ingestion/scripts/connector_registry.py257 """Generate a comprehensive connector registry for all ingestion sources."""STRING
LOW…ata-ingestion/src/datahub/ingestion/source/superset.py900 # can just return the urn directlyCOMMENT
LOW…data-ingestion/src/datahub/ingestion/source/openapi.py167 # TODO: We should just create a requests.Session and set all the authCOMMENT
LOW…stion/src/datahub/ingestion/source/ge_data_profiler.py937 # Note that we can't just call `self._get_dataset_rows(profile)` here becauseCOMMENT
LOW…n/src/datahub/ingestion/source/looker/view_upstream.py1354 # Don't throw an error, just return the original field nameCOMMENT
LOW…estion/src/datahub/ingestion/source/tableau/tableau.py1278 # and extract the hostname, otherwise just return the connection string.COMMENT
LOW…src/datahub/ingestion/source/azure/abs_folder_utils.py157 # Unlike container tags, if an object does not have tags, it will just return an empty arrayCOMMENT
MEDIUM…ahub/ingestion/source/azure_data_factory/adf_source.py993 # Get the Data Flow name using our robust lookupCOMMENT
MEDIUM…src/datahub/ingestion/source/snowflake/snowflake_v2.py1042 # or to handle serde errors gracefully, or to use a robust serialization format instead of pickle,COMMENT
LOW…n/src/datahub/ingestion/source/notion/notion_source.py680 # Fallback if pick is not available - just use kwargs directlyCOMMENT
MEDIUM…n/src/datahub/ingestion/source/kafka_connect/common.py195 # Confluent Cloud Kafka API configuration for comprehensive topic retrievalCOMMENT
MEDIUM…atahub/ingestion/source/kafka_connect/kafka_connect.py414 # First try to get all topics from Kafka REST API for comprehensive coverageCOMMENT
LOW…stion/source/powerbi/rest_api_wrapper/data_resolver.py53 # It is not failure so no need to log the message just return with FalseCOMMENT
LOW…rc/datahub/ingestion/source/powerbi/m_query/_bridge.py146 # If we just set _bridge_instance = None here, Python's GC decidesCOMMENT
MEDIUM…-ingestion/src/datahub/ingestion/source/kafka/kafka.py441 # Handle comprehensive schema resolution for topics without schemasCOMMENT
LOW…n/src/datahub/ingestion/source/kafka/kafka_profiler.py329 # If no simple type found, just use the first oneCOMMENT
LOW…tion/src/datahub/ingestion/source/aws/s3_boto_utils.py66 # Unlike bucket tags, if an object does not have tags, it will just return an empty arrayCOMMENT
LOW…tahub/ingestion/source/unstructured/chunking_config.py348 # Don't fail if config file doesn't exist - just use localhostCOMMENT
LOW…tahub/ingestion/source/unstructured/chunking_config.py383 # Don't fail if config file doesn't exist - just return NoneCOMMENT
LOW…gestion/src/datahub/ingestion/source/git/git_import.py47 # so we can just add one unconditionally.COMMENT
LOW…gestion/src/datahub/ingestion/source/git/git_import.py86 # we can't just use the --branch flag of Git clone. Doing a blobless clone allowsCOMMENT
MEDIUM…atahub/ingestion/source/sql/hive/hive_thrift_client.py755 # _fetch_*_rows() methods, enabling seamless integration with the parent class.COMMENT
MEDIUM…-ingestion/src/datahub/emitter/serialization_helper.py34 # the aforementioned assumption in our tests.COMMENT
LOW…ngestion/src/datahub/utilities/prefix_batch_builder.py66 # However, we'll just use a greedy algorithm for simplicity.COMMENT
LOW…ata-ingestion/src/datahub/utilities/yaml_sync_utils.py32 # We should support that, but for now, we just use the sequence indent.COMMENT
LOWmetadata-ingestion/src/datahub/sdk/resolver_client.py65 # TODO: In auto methods, should we just create the user/domain/etc if it doesn't exist?COMMENT
LOW…a-ingestion/src/datahub/sql_parsing/sqlglot_lineage.py1807 # If it fails, just return the original statement.COMMENT
MEDIUM…ata-ingestion/src/datahub/sql_parsing/sqlglot_utils.py222 # The r" ?" makes it more robust to uneven spacing.COMMENT
LOW…tion/src/datahub/sql_parsing/sql_parsing_aggregator.py1795 # This is a cycle, so we just return the query as-is.COMMENT
Magic Placeholder Names16 hits · 92 pts
SeverityFileLineSnippetContext
HIGHdatahub-agent-context/examples/langchain/setup_dev.sh29echo " export OPENAI_API_KEY='your-api-key-here'"CODE
HIGHdatahub-agent-context/examples/google_adk/setup_dev.sh29echo " export GOOGLE_API_KEY='your-api-key-here' # Gemini Developer API"CODE
HIGH…ged-datahub/datahub-api/graphql-api/getting-started.md29curl -X GET 'https://your-account.acryl.io/api/gms/config' --header <YOUR_TOKEN>CODE
HIGHdocs/how-to/semantic-search-configuration.md21kubectl create secret generic openai-secret --from-literal=api-key=sk-your-api-key-hereCODE
HIGHdocs/how-to/semantic-search-configuration.md95OPENAI_API_KEY=sk-your-api-key-hereCODE
HIGHdocs/dev-guides/semantic-search/CONFIGURATION.md223OPENAI_API_KEY=sk-your-api-key-hereCODE
HIGH…ct/src/app/ingest/source/builder/RecipeForm/airbyte.ts56 placeholder: 'your-api-key',CODE
HIGH…ts/integration/snowplow/docs/REAL_BDP_TESTING_GUIDE.md40export SNOWPLOW_API_KEY_ID="your-api-key-id-here"CODE
HIGH…ts/integration/snowplow/docs/REAL_BDP_TESTING_GUIDE.md41export SNOWPLOW_API_KEY="your-api-key-secret-here"CODE
HIGH…tadata-ingestion/docs/sources/fivetran/fivetran_pre.md297 api_key: "your_api_key"CODE
HIGH…tadata-ingestion/docs/sources/fivetran/fivetran_pre.md342 api_key: "your_api_key"CODE
HIGH…ta-ingestion/docs/sources/fivetran/fivetran_recipe.yml74 # api_key: "your_api_key"COMMENT
HIGH…data-ingestion/docs/sources/airbyte/airbyte_recipe.yml13 # api_key: your_api_key # Alternative: API token if availableCOMMENT
HIGH…necone/skill_docs/PINECONE_CONNECTOR_IMPLEMENTATION.md255export PINECONE_API_KEY="your-api-key"CODE
HIGH…rce/pinecone/skill_docs/PINECONE_CONNECTOR_PLANNING.md120pc = Pinecone(api_key="YOUR_API_KEY")CODE
HIGHdocs-website/generateDocsDir.ts726// everything else (code-fence placeholders like <YOUR_TOKEN>, config-tableCOMMENT
AI Structural Patterns63 hits · 54 pts
SeverityFileLineSnippetContext
LOWperf-test/authz-perf/lib/metadata.py74CODE
LOW…ub-actions/src/datahub_actions/event/event_envelope.py50CODE
LOW…e-test/tests/library_examples/test_library_examples.py51CODE
LOWsmoke-test/tests/cli/user_cmd/test_user_add.py55CODE
LOW…ts/zdu/framework/phases/skip_already_migrated_sweep.py82CODE
LOW…e-test/tests/zdu/framework/phases/kill_switch_sweep.py76CODE
LOW…e-test/tests/zdu/framework/phases/batch_delay_sweep.py67CODE
LOW…ke-test/tests/knowledge/document_search_filter_test.py32CODE
LOW…e-test/tests/knowledge/document_change_history_test.py28CODE
LOWsmoke-test/tests/semantic/test_semantic_search.py147CODE
LOW…tion-modules/gx-plugin/src/datahub_gx_plugin/action.py90CODE
LOW…/src/datahub_dagster_plugin/sensors/datahub_sensors.py73CODE
LOW…les/prefect-plugin/src/prefect_datahub/example/flow.py14CODE
LOWmetadata-ingestion/tests/unit/test_transform_dataset.py1655CODE
LOWmetadata-ingestion/tests/unit/test_transform_dataset.py3262CODE
LOWmetadata-ingestion/tests/unit/test_transform_dataset.py3433CODE
LOWmetadata-ingestion/tests/unit/hive_test_utils.py18CODE
LOWmetadata-ingestion/tests/unit/glue/test_glue_source.py100CODE
LOW…data-ingestion/tests/unit/hex/test_document_builder.py37CODE
LOW…stion/tests/unit/bigquery/test_bigquery_policy_tags.py30CODE
LOW…/tests/unit/snowflake/test_snowflake_semantic_model.py71CODE
LOWmetadata-ingestion/tests/unit/odcs/test_odcs_mapper.py58CODE
LOW…tadata-ingestion/tests/integration/snowflake/common.py197CODE
LOWmetadata-ingestion/src/datahub/entrypoints.py353CODE
LOW…a-ingestion/src/datahub/ingestion/recording/archive.py227CODE
LOW…ub/ingestion/source/looker/looker_template_language.py350CODE
LOW…src/datahub/ingestion/source/tableau/tableau_common.py1118CODE
LOW…a-ingestion/src/datahub/ingestion/source/hex/mapper.py84CODE
LOW…b/ingestion/source/sqlalchemy_profiler/base_adapter.py406CODE
LOW…ta-ingestion/src/datahub/ingestion/source/omni/omni.py442CODE
LOW…gestion/src/datahub/ingestion/source/sql/clickhouse.py453CODE
LOW…ub/ingestion/source/sql/athena_properties_extractor.py219CODE
LOW…ngestion/src/datahub/ingestion/source/sql/sql_utils.py62CODE
LOW…ngestion/src/datahub/ingestion/source/sql/sql_utils.py126CODE
LOW…adata-ingestion/src/datahub/ingestion/graph/openapi.py229CODE
LOW…adata-ingestion/src/datahub/ingestion/graph/openapi.py337CODE
LOW…adata-ingestion/src/datahub/ingestion/graph/openapi.py413CODE
LOW…adata-ingestion/src/datahub/ingestion/graph/openapi.py508CODE
LOW…tadata-ingestion/src/datahub/ingestion/graph/client.py975CODE
LOW…tadata-ingestion/src/datahub/ingestion/graph/client.py1050CODE
LOW…tadata-ingestion/src/datahub/ingestion/graph/client.py1201CODE
LOWmetadata-ingestion/src/datahub/emitter/rest_emitter.py482CODE
LOWmetadata-ingestion/src/datahub/emitter/mcp_builder.py310CODE
LOWmetadata-ingestion/src/datahub/emitter/mcp_builder.py440CODE
LOW…data-ingestion/src/datahub/cli/specific/file_loader.py26CODE
LOWmetadata-ingestion/src/datahub/sdk/glossary_node.py74CODE
LOWmetadata-ingestion/src/datahub/sdk/datajob.py67CODE
LOWmetadata-ingestion/src/datahub/sdk/mlmodel.py64CODE
LOWmetadata-ingestion/src/datahub/sdk/mlmodel.py315CODE
LOWmetadata-ingestion/src/datahub/sdk/semantic_model.py167CODE
LOWmetadata-ingestion/src/datahub/sdk/semantic_model.py533CODE
LOWmetadata-ingestion/src/datahub/sdk/chart.py62CODE
LOWmetadata-ingestion/src/datahub/sdk/mlmodelgroup.py50CODE
LOWmetadata-ingestion/src/datahub/sdk/container.py61CODE
LOWmetadata-ingestion/src/datahub/sdk/glossary_term.py102CODE
LOWmetadata-ingestion/src/datahub/sdk/dataset.py510CODE
LOWmetadata-ingestion/src/datahub/sdk/dashboard.py64CODE
LOWmetadata-ingestion/src/datahub/sdk/metric.py95CODE
LOWmetadata-ingestion/src/datahub/sdk/document.py343CODE
LOWmetadata-ingestion/src/datahub/sdk/document.py480CODE
3 more matches not shown…
Slop Phrases10 hits · 24 pts
SeverityFileLineSnippetContext
MEDIUMdocker/airflow/docker-compose.yaml42# Feel free to modify this file to suit your needs.COMMENT
MEDIUM…kedin/metadata/registry/SchemaRegistryServiceImpl.java415 // This is a basic implementation - in production you'd want more sophisticated checkingCOMMENT
MEDIUM…kedin/metadata/registry/SchemaRegistryServiceImpl.java432 // This is a basic implementation - in production you'd want more sophisticated checkingCOMMENT
LOW…ub/client/v2/entity/RequiresMutableAnnotationTest.java15 * <p>This test ensures developers don't forget to annotate mutation methods, which would bypassCOMMENT
MEDIUM…stion/tests/integration/cassandra/setup/cassandra.yaml54# initial_token allows you to specify tokens manually. While you can use it withCOMMENT
MEDIUM…stion/tests/integration/cassandra/setup/cassandra.yaml819# you may want to adjust max_value_size accordingly. This should be positive and less than 2048.COMMENT
MEDIUM…-ingestion/tests/integration/azure_ad/test_azure_ad.py126# Azure offers a tool called 'graph-explorer' that you can use to generate fake data,COMMENT
LOW…n/src/datahub/ingestion/source/looker/looker_source.py328 # for measure, we can also make sure to index the underlying field that the measure usesCOMMENT
LOW…b/ingestion/source/state/redundant_run_skip_handler.py207 # make sure to consider complete time bucket for usageCOMMENT
LOWmetadata-ingestion/src/datahub/cli/docker_check.py91 # Yield the client and make sure to close it.COMMENT
AI Response Leakage3 hits · 22 pts
SeverityFileLineSnippetContext
HIGHdocs/troubleshooting/quickstart.md250## I've modified the default user.props file to include a custom username and password, but I don't see the new user(s) COMMENT
HIGH…ns/datahub-demo-dataset-governance-validator/README.md34# In this example, we start with the current stable DataHub image- this can be any GMS image however.COMMENT
HIGH…gestion/tests/unit/sql_parsing/test_sqlglot_lineage.py1075 # In this example, output col1 should come from table3 and not table1, since the cte is unused.COMMENT
Dead Code9 hits · 14 pts
SeverityFileLineSnippetContext
MEDIUMmetadata-ingestion/tests/unit/test_mode_source.py568CODE
MEDIUMmetadata-ingestion/tests/unit/test_mode_source.py583CODE
MEDIUMmetadata-ingestion/tests/unit/test_mode_source.py598CODE
MEDIUMmetadata-ingestion/tests/unit/test_mode_source.py615CODE
MEDIUMmetadata-ingestion/tests/unit/test_oracle_source.py1847CODE
MEDIUM…-ingestion/tests/unit/test_unity_catalog_usage_join.py1863CODE
MEDIUM…-ingestion/tests/unit/test_unity_catalog_usage_join.py1124CODE
MEDIUM…tests/unit/bigquery/test_bigquery_queries_extractor.py1072CODE
MEDIUM…gestion/source/vertexai/vertexai_training_extractor.py205CODE
TODO Padding9 hits · 12 pts
SeverityFileLineSnippetContext
LOW…/com/linkedin/metadata/service/LineageServiceTest.java116 // TODO: Add tests for permissions once we add permissions for updating lineageCOMMENT
LOW…pp/entityV2/shared/tabs/Dataset/Queries/QueriesTab.tsx47 // TODO: implement search filtering properlyCOMMENT
LOW…yV2/summary/properties/hooks/usePropertiesFromAsset.ts10 // TODO: implement loading and transformation of asset propertiesCOMMENT
LOWdatahub-web-react/src/app/homeV3/modules/utils.ts22 // TODO: implement getting of the correct descriptionCOMMENT
LOW…tadata-ingestion/tests/integration/snowflake/common.py415 # TODO: Add tests for view pagination.STRING
LOW…tadata-ingestion/tests/integration/snowflake/common.py595 # TODO: Add tests for stream pagination.STRING
LOWmetadata-ingestion/src/datahub/cli/lineage_cli.py279 # TODO: implement get_paths_between in LineageClientCOMMENT
LOWmetadata-ingestion/src/datahub/sdk/entity_client.py115 # TODO: add error handling around this with a suggested alternative if not yet supportedCOMMENT
LOWmetadata-ingestion/src/datahub/sdk/entity.py197 # TODO: Add validation to ensure that an "extra aspect" does not conflictCOMMENT
Example Usage Blocks6 hits · 9 pts
SeverityFileLineSnippetContext
LOW…gent-skills/test-review/scripts/detect-test-changes.sh14# Usage:COMMENT
LOW…sts/integration/hive-metastore/docker-compose.hms3.yml13# Usage:COMMENT
LOW…integration/hive-metastore/kerberos/test-connection.sh8# Usage:COMMENT
LOW…tests/integration/recording/test_recording_workflow.sh4# Usage:COMMENT
LOWmetadata-ingestion/examples/ai/dh_ai_client_sample.py40 # Example usageCOMMENT
LOW…n/src/datahub/api/entities/external/restricted_text.py42 # Usage exampleSTRING
Overly Generic Function Names7 hits · 8 pts
SeverityFileLineSnippetContext
LOW…ub-agent-context/tests/unit/snowflake/test_udf_base.py118 assert "def test_function():" in resultCODE
LOWsmoke-test/tests/utils.py270 def test_function():STRING
LOW…n-modules/dagster-plugin/examples/advanced_ops_jobs.py52def do_stuff():CODE
LOW…a-ingestion-modules/dagster-plugin/examples/ops_job.py38def do_stuff():CODE
LOW…stion/tests/unit/vertexai/test_vertexai_ml_metadata.py88 def helper(self, mock_metadata_client, ml_metadata_config, mock_uri_parser):CODE
LOW…tests/integration/snowflake/test_snowflake_failures.py27 def my_function(query):CODE
LOW…tests/integration/snowflake/test_snowflake_failures.py38 def my_function(query):CODE
Synthetic Comment Markers1 hit · 5 pts
SeverityFileLineSnippetContext
HIGHdocs/managed-datahub/release-notes/v_0_3_12.md37- Fix incorrect/missing closing parenthesis in links generated by AICODE