Repository Analysis

open-metadata/OpenMetadata

The Open Context Layer for Data and AI , OpenMetadata is the open platform for building trusted data context and business semantics for humans, AI assistants, and agents.

10.0 Low AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of open-metadata/OpenMetadata, a TypeScript project with 15,021 GitHub stars. SynthScan v2.0 examined 3,295,668 lines of code across 14472 source files, recording 16603 pattern matches distributed across 28 syntactic categories. The overall adjusted score of 10.0 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).

10.0
Adjusted Score
10.0
Raw Score
100%
Time Factor
2026-08-28
Last Push
15.0K
Stars
TypeScript
Language
3.3M
Lines of Code
14.5K
Files
16.6K
Pattern Hits
2026-08-29
Scan Date
0.14
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 1156HIGH 871MEDIUM 922LOW 13654

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 16603 distinct pattern matches across 28 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.

Hallucination Indicators1156 hits · 11956 pts
SeverityFileLineSnippetContext
CRITICAL…main/java/org/openmetadata/schema/utils/JsonUtils.java617 com.github.fge.jsonpatch.JsonPatch.fromJson(patchNode);CODE
CRITICALingestion/tests/unit/test_dbt.py4605 return source.context.get.return_value.dbt_tests.get(manifest_node.unique_id + "_freshness")CODE
CRITICALingestion/tests/unit/test_dbt_config_errors.py266 from azure.core.exceptions import ResourceNotFoundErrorCODE
CRITICALingestion/tests/unit/test_dbt_config_errors.py281 from azure.core.exceptions import ClientAuthenticationErrorCODE
CRITICALingestion/tests/unit/test_dbt_config_errors.py298 from azure.core.exceptions import HttpResponseErrorCODE
CRITICALingestion/tests/unit/test_ssl_manager.py119 kafka_source_with_ssl.service_connection.schemaRegistrySSL.root.caCertificate.get_secret_value(),CODE
CRITICALingestion/tests/unit/test_ssl_manager.py123 kafka_source_with_ssl.service_connection.schemaRegistrySSL.root.sslKey.get_secret_value(),CODE
CRITICALingestion/tests/unit/test_ssl_manager.py127 kafka_source_with_ssl.service_connection.schemaRegistrySSL.root.sslCertificate.get_secret_value(),CODE
CRITICALingestion/tests/unit/test_ssl_manager.py196 cassandra_source_with_ssl.service_connection.sslConfig.root.caCertificate.get_secret_value(),CODE
CRITICALingestion/tests/unit/test_ssl_manager.py200 cassandra_source_with_ssl.service_connection.sslConfig.root.sslKey.get_secret_value(),CODE
CRITICALingestion/tests/unit/test_ssl_manager.py204 cassandra_source_with_ssl.service_connection.sslConfig.root.sslCertificate.get_secret_value(),CODE
CRITICAL…t/topology/database/test_datalake_azure_blob_client.py23from azure.core.exceptions import ResourceNotFoundErrorCODE
CRITICAL…estion/tests/unit/topology/pipeline/test_airflowapi.py38from metadata.utils.helpers import datetime_to_tsCODE
CRITICALingestion/tests/unit/topology/dashboard/test_tableau.py523 self.tableau.config.serviceConnection.root.config.sslConfig.root.sslCertificate.get_secret_value(),CODE
CRITICALingestion/tests/unit/topology/dashboard/test_tableau.py527 self.tableau.config.serviceConnection.root.config.sslConfig.root.sslKey.get_secret_value(),CODE
CRITICALingestion/tests/unit/topology/dashboard/test_tableau.py531 self.tableau.config.serviceConnection.root.config.sslConfig.root.caCertificate.get_secret_value(),CODE
CRITICALingestion/tests/unit/topology/dashboard/test_tableau.py549 self.tableau.config.serviceConnection.root.config.sslConfig.root.caCertificate.get_secret_value(),CODE
CRITICAL…n/tests/unit/topology/dashboard/test_tableau_client.py128 self.client.tableau_server.users.get_by_id.assert_not_called()CODE
CRITICALingestion/tests/unit/topology/drive/test_googledrive.py223 mock_client.drive_service.files.return_value.list.assert_called()CODE
CRITICALingestion/tests/unit/topology/drive/test_googledrive.py375 mock_client.drive_service.files.return_value.list.assert_called()CODE
CRITICALingestion/tests/unit/topology/drive/test_googledrive.py428 mock_client.sheets_service.spreadsheets.return_value.get.assert_called_with(spreadsheetId="sheet_001")CODE
CRITICALingestion/tests/integration/conftest.py167 "type": db_service.connection.config.type.value.lower(),CODE
CRITICALingestion/tests/integration/conftest.py190 "type": db_service.connection.config.type.value.lower(),CODE
CRITICALingestion/tests/integration/conftest.py389 "type": db_service.connection.config.type.value.lower(),CODE
CRITICAL…tion/tests/integration/ometa/test_ometa_service_api.py69 assert service.connection.config.authType.password.get_secret_value() == "openmetadata_password"CODE
CRITICAL…tion/tests/integration/ometa/test_ometa_service_api.py224 assert service.connection.config.authType.password.get_secret_value() == "tb_pwd"CODE
CRITICAL…stion/tests/integration/ometa/test_ometa_test_suite.py52from metadata.utils.helpers import datetime_to_tsCODE
CRITICAL…ion/tests/integration/ometa/test_ometa_pipeline_api.py30from metadata.utils.helpers import datetime_to_tsCODE
CRITICALingestion/tests/integration/ometa/test_ometa_patch.py55from metadata.utils.helpers import find_column_in_tableCODE
CRITICAL…ion/tests/integration/ometa/test_ometa_workflow_api.py105 assert res.request.connection.config.authType.password.get_secret_value() == "password"CODE
CRITICAL…assification/databases/test_azuresql_temporal_table.py226 "type": db_service.connection.config.type.value.lower(),STRING
CRITICAL…assification/databases/test_azuresql_temporal_table.py246 "type": db_service.connection.config.type.value.lower(),STRING
CRITICAL…sification/databases/test_global_sample_data_config.py67 "type": db_service.connection.config.type.value.lower(),CODE
CRITICAL…sification/databases/test_global_sample_data_config.py112 "type": db_service.connection.config.type.value.lower(),CODE
CRITICAL…on/auto_classification/databases/test_tag_processor.py54 "type": db_service.connection.config.type.value.lower(),CODE
CRITICAL…on/auto_classification/databases/test_tag_processor.py96 "type": db_service.connection.config.type.value.lower(),CODE
CRITICAL…ation/auto_classification/messaging/test_kafka_sasl.py107 "type": sasl_messaging_service.connection.config.type.value.lower(),CODE
CRITICALingestion/tests/integration/data_quality/conftest.py102 "type": postgres_service.connection.config.type.value.lower(),CODE
CRITICAL…ts/integration/data_quality/test_failed_row_samples.py263 "type": postgres_service.connection.config.type.value.lower(),CODE
CRITICAL…ts/integration/data_quality/test_failed_row_samples.py291 "type": db_service.connection.config.type.value.lower(),CODE
CRITICALingestion/tests/integration/kafka/conftest.py122 "type": db_service.connection.config.type.value.lower(),STRING
CRITICALingestion/tests/integration/sdk/conftest.py206 "type": db_service.connection.config.type.value.lower(),CODE
CRITICAL…/sources/database/delta_lake/test_deltalake_storage.py127 type=service.connection.config.type.value.lower(),CODE
CRITICAL…sts/integration/sources/mlmodels/mlflow/test_mlflow.py206 type=service.connection.config.type.value.lower(),CODE
CRITICAL…tion/tests/integration/profiler/test_nosql_profiler.py43from metadata.utils.helpers import datetime_to_tsCODE
CRITICAL…on/src/airflow_provider_openmetadata/lineage/runner.py72from metadata.utils.helpers import clean_uri, datetime_to_ts # noqa: E402CODE
CRITICAL…on/src/airflow_provider_openmetadata/lineage/status.py25from metadata.utils.helpers import datetime_to_tsCODE
CRITICALingestion/src/metadata/clients/domo_client.py34from metadata.utils.helpers import clean_uriCODE
CRITICALingestion/src/metadata/parsers/protobuf_parser.py30from metadata.utils.helpers import snake_to_camelCODE
CRITICAL…adata/ingestion/source/database/query_parser_source.py36from metadata.utils.helpers import get_start_and_end, retry_with_docker_hostCODE
CRITICAL…tadata/ingestion/source/database/sql_column_handler.py35from metadata.utils.helpers import clean_up_starting_ending_double_quotes_in_stringCODE
CRITICAL…/src/metadata/ingestion/source/database/sample_data.py195from metadata.utils.helpers import get_standard_chart_typeCODE
CRITICAL…metadata/ingestion/source/database/common_db_source.py77from metadata.utils.helpers import retry_with_docker_hostCODE
CRITICAL…c/metadata/ingestion/source/database/lineage_source.py109 # from metadata.utils.helpers import can_spawn_child_processCOMMENT
CRITICAL…adata/ingestion/source/database/common_nosql_source.py61from metadata.utils.helpers import retry_with_docker_hostCODE
CRITICAL…a/ingestion/source/database/stored_procedures_mixin.py48from metadata.utils.helpers import pprint_format_objectCODE
CRITICAL…ata/ingestion/source/database/unitycatalog/metadata.py104from metadata.utils.helpers import retry_with_docker_hostCODE
CRITICAL…data/ingestion/source/database/unitycatalog/lineage.py56from metadata.utils.helpers import retry_with_docker_hostCODE
CRITICAL…c/metadata/ingestion/source/database/dbt/dbt_config.py710 from azure.core.exceptions import AzureError, ClientAuthenticationErrorCODE
CRITICAL…c/metadata/ingestion/source/database/dbt/dbt_config.py56from metadata.utils.helpers import clean_uriCODE
1096 more matches not shown…
Hyper-Verbose Identifiers9330 hits · 9282 pts
SeverityFileLineSnippetContext
LOWtooling/antd-codemods/transforms/antd-button-to-core.js381 function replaceImportPreservingHeader(path, newDecl) {CODE
LOWtooling/antd-codemods/transforms/antd-button-to-core.js386 function removeImportPreservingHeader(path) {CODE
LOW…ng/antd-codemods/transforms/antd-typography-to-core.js416 function replaceImportPreservingHeader(path, newDecl) {CODE
LOW…ng/antd-codemods/transforms/antd-typography-to-core.js421 function removeImportPreservingHeader(path) {CODE
LOWingestion/operators/docker/exit_handler.py470def update_pipeline_status_with_diagnostics(CODE
LOWingestion/operators/docker/exit_handler.py370def get_or_create_pipeline_status(metadata: OpenMetadata, workflow_config) -> PipelineStatus:CODE
LOWingestion/operators/docker/exit_handler.py401def gather_failure_diagnostics(CODE
LOWingestion/tests/unit/test_exit_handler.py39 def test_has_diagnostics_with_logs(self):CODE
LOWingestion/tests/unit/test_exit_handler.py44 def test_has_diagnostics_with_description(self):CODE
LOWingestion/tests/unit/test_exit_handler.py49 def test_has_diagnostics_with_both(self):CODE
LOWingestion/tests/unit/test_exit_handler.py54 def test_has_diagnostics_empty(self):CODE
LOWingestion/tests/unit/test_exit_handler.py64 def test_summary_with_description(self):CODE
LOWingestion/tests/unit/test_exit_handler.py314 def test_creates_step_summary_with_logs(self):CODE
LOWingestion/tests/unit/test_exit_handler.py323 def test_creates_step_summary_with_description(self):CODE
LOWingestion/tests/unit/test_exit_handler.py330 def test_creates_step_summary_with_both(self):CODE
LOWingestion/tests/unit/test_exit_handler.py338 def test_handles_empty_diagnostics(self):CODE
LOWingestion/tests/unit/test_exit_handler.py80 def test_in_cluster_config_success(self, mock_client, mock_config):CODE
LOWingestion/tests/unit/test_exit_handler.py92 def test_fallback_to_kubeconfig(self, mock_client, mock_config):CODE
LOWingestion/tests/unit/test_exit_handler.py104 def test_returns_none_on_failure(self, mock_config):CODE
LOWingestion/tests/unit/test_exit_handler.py117 def test_returns_none_with_invalid_params(self):CODE
LOWingestion/tests/unit/test_exit_handler.py127 def test_finds_pod_by_job_name_label(self):CODE
LOWingestion/tests/unit/test_exit_handler.py142 def test_returns_none_when_no_pods_found(self):CODE
LOWingestion/tests/unit/test_exit_handler.py153 def test_handles_api_exceptions_gracefully(self):CODE
LOWingestion/tests/unit/test_exit_handler.py166 def test_returns_logs_successfully(self):CODE
LOWingestion/tests/unit/test_exit_handler.py184 def test_returns_none_for_invalid_pod(self):CODE
LOWingestion/tests/unit/test_exit_handler.py196 def test_handles_api_exceptions_gracefully(self):CODE
LOWingestion/tests/unit/test_exit_handler.py212 def test_builds_description_with_status(self):CODE
LOWingestion/tests/unit/test_exit_handler.py233 def test_returns_none_for_invalid_pod(self):CODE
LOWingestion/tests/unit/test_exit_handler.py240 def test_handles_exceptions_gracefully(self):CODE
LOWingestion/tests/unit/test_exit_handler.py267 def test_returns_empty_when_pod_not_found(self, mock_find_pod, mock_get_client):CODE
LOWingestion/tests/unit/test_exit_handler.py280 def test_gathers_all_diagnostics(self, mock_description, mock_logs, mock_find_pod, mock_get_client):CODE
LOWingestion/tests/unit/test_exit_handler.py297 def test_continues_on_partial_failure(self, mock_description, mock_logs, mock_find_pod, mock_get_client):CODE
LOWingestion/tests/unit/test_version.py22def test_get_version_from_string():CODE
LOWingestion/tests/unit/test_version.py33def test_get_client_version_from_string():CODE
LOWingestion/tests/unit/test_column_type_parser.py101 def test_check_datatype_support(self):CODE
LOWingestion/tests/unit/test_column_type_parser.py139def test_superset_parse_array_data_type():CODE
LOWingestion/tests/unit/test_column_type_parser.py152def test_struct_field_name_with_colons():CODE
LOWingestion/tests/unit/test_column_type_parser.py168def test_struct_field_name_with_colons_backtick_quoted():CODE
LOWingestion/tests/unit/test_column_type_parser.py178def test_struct_field_name_with_colons_mixed_and_nested():CODE
LOWingestion/tests/unit/test_column_type_parser.py190def test_struct_field_without_colon_still_raises():CODE
LOW…stion/tests/unit/test_workflow_parse_example_config.py15 def test_parse_workflow_config(self):CODE
LOWingestion/tests/unit/test_owner_utils.py30 def test_simple_default_owner(self):CODE
LOWingestion/tests/unit/test_owner_utils.py42 def test_level_specific_owner(self):CODE
LOWingestion/tests/unit/test_owner_utils.py70 def test_specific_entity_mapping(self):CODE
LOWingestion/tests/unit/test_owner_utils.py110 def test_simple_name_fallback(self):CODE
LOWingestion/tests/unit/test_owner_utils.py137 def test_inheritance_disabled(self):CODE
LOWingestion/tests/unit/test_owner_utils.py201 def test_multiple_owners_array(self):CODE
LOWingestion/tests/unit/test_owner_utils.py238 def test_multiple_owners_partial_success(self):CODE
LOWingestion/tests/unit/test_owner_utils.py270 def test_multiple_owners_all_fail(self):CODE
LOWingestion/tests/unit/test_owner_utils.py281 def test_backward_compatibility_single_string(self):CODE
LOWingestion/tests/unit/test_owner_utils.py293 def test_multiple_owners_with_fqn(self):CODE
LOWingestion/tests/unit/test_pydantic_v2.py102def test_serialize_as_any_includes_subclass_fields():CODE
LOWingestion/tests/unit/conftest.py45def register_sqlite_math_functions():CODE
LOWingestion/tests/unit/conftest.py84def pytest_pycollect_makeitem(collector, name, obj):CODE
LOWingestion/tests/unit/test_ometa_utils.py160 def test_render_query_headers_builds_the_right_string(self) -> None:CODE
LOWingestion/tests/unit/test_ometa_utils.py163 def test_build_entity_reference(self) -> None:CODE
LOWingestion/tests/unit/test_ometa_utils.py169 def test_decode_jwt_token_valid(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py193 def test_decode_jwt_token_with_padding(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py249 def test_decode_jwt_token_none_input(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py254 def test_decode_jwt_token_empty_string(self):CODE
9270 more matches not shown…
Cross-File Repetition691 hits · 3455 pts
SeverityFileLineSnippetContext
HIGH…ests/unit/topology/database/test_datalake_s3_client.py0tests for skip_cold_storage filtering in get_table_namesSTRING
HIGH…t/topology/database/test_datalake_azure_blob_client.py0tests for skip_cold_storage filtering in get_table_namesSTRING
HIGH…sts/unit/topology/database/test_datalake_gcs_client.py0tests for skip_cold_storage filtering in get_table_namesSTRING
HIGH…/topology/database/test_databricks_ordinal_position.py0test that ordinal position is set for a single columnSTRING
HIGH…it/topology/database/test_redshift_ordinal_position.py0test that ordinal position is set for a single columnSTRING
HIGH…opology/database/test_unitycatalog_ordinal_position.py0test that ordinal position is set for a single columnSTRING
HIGHingestion/tests/unit/topology/dashboard/test_looker.py0test that when includeowners is true, owner information is processedSTRING
HIGHingestion/tests/unit/topology/dashboard/test_tableau.py0test that when includeowners is true, owner information is processedSTRING
HIGH…on/tests/unit/topology/dashboard/test_microstrategy.py0test that when includeowners is true, owner information is processedSTRING
HIGH…gestion/tests/unit/topology/dashboard/test_metabase.py0test that when includeowners is true, owner information is processedSTRING
HIGH…stion/tests/unit/topology/dashboard/test_quicksight.py0test that when includeowners is true, owner information is processedSTRING
HIGH…estion/tests/unit/topology/dashboard/test_qliksense.py0test that when includeowners is true, owner information is processedSTRING
HIGHingestion/tests/unit/topology/dashboard/test_sigma.py0test that when includeowners is true, owner information is processedSTRING
HIGHingestion/tests/unit/topology/dashboard/test_looker.py0test that when includeowners is false, owner information is not processedSTRING
HIGHingestion/tests/unit/topology/dashboard/test_tableau.py0test that when includeowners is false, owner information is not processedSTRING
HIGH…on/tests/unit/topology/dashboard/test_microstrategy.py0test that when includeowners is false, owner information is not processedSTRING
HIGH…gestion/tests/unit/topology/dashboard/test_metabase.py0test that when includeowners is false, owner information is not processedSTRING
HIGH…stion/tests/unit/topology/dashboard/test_quicksight.py0test that when includeowners is false, owner information is not processedSTRING
HIGH…estion/tests/unit/topology/dashboard/test_qliksense.py0test that when includeowners is false, owner information is not processedSTRING
HIGHingestion/tests/unit/topology/dashboard/test_sigma.py0test that when includeowners is false, owner information is not processedSTRING
HIGHingestion/tests/unit/topology/dashboard/test_looker.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGHingestion/tests/unit/topology/dashboard/test_ssrs.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGHingestion/tests/unit/topology/dashboard/test_tableau.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGH…on/tests/unit/topology/dashboard/test_microstrategy.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGHingestion/tests/unit/topology/dashboard/test_grafana.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGH…estion/tests/unit/topology/dashboard/test_qlikcloud.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGH…gestion/tests/unit/topology/dashboard/test_metabase.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGH…stion/tests/unit/topology/dashboard/test_quicksight.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGH…on/tests/unit/topology/dashboard/test_domodashboard.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGH…estion/tests/unit/topology/dashboard/test_qliksense.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGHingestion/tests/unit/topology/dashboard/test_sigma.py0verify register_record_chart populates chart_source_state after yield_dashboard_chart.STRING
HIGHingestion/tests/unit/topology/dashboard/test_tableau.py0implements the necessary methods to extract domo dashboard unit testSTRING
HIGH…gestion/tests/unit/topology/dashboard/test_metabase.py0implements the necessary methods to extract domo dashboard unit testSTRING
HIGH…on/tests/unit/topology/dashboard/test_domodashboard.py0implements the necessary methods to extract domo dashboard unit testSTRING
HIGHingestion/tests/unit/topology/dashboard/test_sigma.py0implements the necessary methods to extract domo dashboard unit testSTRING
HIGHingestion/tests/unit/topology/dashboard/test_tableau.py0test that the includeowners flag is properly set in the configurationSTRING
HIGH…on/tests/unit/topology/dashboard/test_microstrategy.py0test that the includeowners flag is properly set in the configurationSTRING
HIGH…gestion/tests/unit/topology/dashboard/test_metabase.py0test that the includeowners flag is properly set in the configurationSTRING
HIGH…stion/tests/unit/topology/dashboard/test_quicksight.py0test that the includeowners flag is properly set in the configurationSTRING
HIGH…estion/tests/unit/topology/dashboard/test_qliksense.py0test that the includeowners flag is properly set in the configurationSTRING
HIGHingestion/tests/unit/topology/dashboard/test_sigma.py0test that the includeowners flag is properly set in the configurationSTRING
HIGHingestion/tests/unit/topology/dashboard/test_tableau.py0test that the includeowners flag affects how owner information is processedSTRING
HIGH…on/tests/unit/topology/dashboard/test_microstrategy.py0test that the includeowners flag affects how owner information is processedSTRING
HIGH…gestion/tests/unit/topology/dashboard/test_metabase.py0test that the includeowners flag affects how owner information is processedSTRING
HIGH…stion/tests/unit/topology/dashboard/test_quicksight.py0test that the includeowners flag affects how owner information is processedSTRING
HIGH…estion/tests/unit/topology/dashboard/test_qliksense.py0test that the includeowners flag affects how owner information is processedSTRING
HIGHingestion/tests/unit/topology/dashboard/test_sigma.py0test that the includeowners flag affects how owner information is processedSTRING
HIGH…sts/unit/source/database/databricks/test_connection.py0mirror ``sqlalchemy.exc.dbapierror``: wraps the driver error on ``.orig``.STRING
HIGH…ests/unit/source/database/snowflake/test_connection.py0mirror ``sqlalchemy.exc.dbapierror``: wraps the driver error on ``.orig``.STRING
HIGH…tests/unit/source/database/redshift/test_connection.py0mirror ``sqlalchemy.exc.dbapierror``: wraps the driver error on ``.orig``.STRING
HIGH…tests/unit/source/database/postgres/test_connection.py0mirror ``sqlalchemy.exc.dbapierror``: wraps the driver error on ``.orig``.STRING
HIGH…/tests/unit/source/pipeline/airflow/test_connection.py0the provider borrows the client baseconnection owns, rather than opening a second one behind its back.STRING
HIGH…tests/unit/source/pipeline/dbtcloud/test_connection.py0the provider borrows the client baseconnection owns, rather than opening a second one behind its back.STRING
HIGH…/tests/unit/source/pipeline/prefect/test_connection.py0the provider borrows the client baseconnection owns, rather than opening a second one behind its back.STRING
HIGH…/tests/unit/source/dashboard/looker/test_connection.py0a provider over a borrowed client - the one its connection owns.STRING
HIGH…tests/unit/source/dashboard/tableau/test_connection.py0a provider over a borrowed client - the one its connection owns.STRING
HIGH…tests/unit/source/dashboard/powerbi/test_connection.py0a provider over a borrowed client - the one its connection owns.STRING
HIGH…ility/profiler/test_nosql_profiler_processor_status.py0verify each metric group reports a separate status entry.STRING
HIGH…servability/profiler/test_profiler_processor_status.py0verify each metric group reports a separate status entry.STRING
HIGH…servability/profiler/pandas/test_profiler_interface.py0verify each metric group reports a separate status entry.STRING
631 more matches not shown…
Decorative Section Separators683 hits · 2234 pts
SeverityFileLineSnippetContext
MEDIUM…ing/antd-codemods/__tests__/move-named-imports.test.js93// ── --toPath: destination is a file in the repo, not a package ──────────────COMMENT
MEDIUMingestion/pyproject.toml118# ─── Selected rule families ──────────────────────────────────────────────COMMENT
MEDIUMingestion/pyproject.toml155# ─── Ignores: justify EVERY one ──────────────────────────────────────────COMMENT
MEDIUMingestion/pyproject.toml292# ── Real-bug catchers held to error ──────────────────────────────────────COMMENT
MEDIUMingestion/pyproject.toml306# ── Cheap promotions: real-bug rules that fire rarely ────────────────────COMMENT
MEDIUMingestion/pyproject.toml311# ── Stub-gap noise: explicitly off (matches `standard` defaults) ─────────COMMENT
MEDIUMingestion/pyproject.toml324# ── Project-specific waivers ─────────────────────────────────────────────COMMENT
MEDIUMingestion/pyproject.toml347# ── Ratchet scaffold: enable subtree-by-subtree promotions later ────────COMMENT
MEDIUMingestion/noxfile.py108# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/noxfile.py110# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/noxfile.py137# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/noxfile.py139# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/noxfile.py185# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/noxfile.py187# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/noxfile.py243# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/noxfile.py245# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_status.py34 # ── as_string ────────────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/test_status.py88 # ── failed / fail_all ────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/test_status.py103 # ── calculate_success ────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/test_status.py127 # ── warning / filter ─────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/test_status.py137 # ── truncation of stack traces ───────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/test_query_parser.py426 # -------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_query_parser.py428 # -------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py88# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py90# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py132# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py134# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py420# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py422# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py482# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py484# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py569# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py571# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py41# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py43# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py306# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py308# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py551# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_scaffold.py553# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/topology/test_queue.py32 # ------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/topology/database/test_iomete.py68# ── get_connection: URL construction ─────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/topology/database/test_iomete.py146# ── IometeSource.create ───────────────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/topology/database/test_iomete.py30# ── fixtures ──────────────────────────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/topology/database/test_iomete.py187# ── get_schema_definition ─────────────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/topology/database/test_iomete.py259# ── get_database_names ────────────────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/topology/database/test_iomete.py289# ── set_inspector ─────────────────────────────────────────────────────────────COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py144# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py146# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py290# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py292# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py355# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py357# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py740# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py742# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py830# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py832# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py858# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py860# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py992# ---------------------------------------------------------------------------COMMENT
MEDIUM…logy/database/test_snowflake_access_history_lineage.py994# ---------------------------------------------------------------------------COMMENT
623 more matches not shown…
Excessive Try-Catch Wrapping1836 hits · 1819 pts
SeverityFileLineSnippetContext
LOWingestion/operators/docker/exit_handler.py97 except Exception as in_cluster_error:CODE
LOWingestion/operators/docker/exit_handler.py102 except Exception as kubeconfig_error:CODE
LOWingestion/operators/docker/exit_handler.py107 except Exception as unexpected_error: # noqa: B025CODE
LOWingestion/operators/docker/exit_handler.py301 except Exception as event_error:CODE
LOWingestion/operators/docker/exit_handler.py306 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py316 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py446 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py455 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py464 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py161 except Exception as list_error:CODE
LOWingestion/operators/docker/exit_handler.py173 except Exception as pod_error:CODE
LOWingestion/operators/docker/exit_handler.py180 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py215 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py281 except Exception as container_error:CODE
LOWingestion/operators/docker/exit_handler.py284 except Exception as status_error:CODE
LOWingestion/operators/docker/exit_handler.py423 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py434 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py498 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py501 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py572 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py580 except Exception as e:CODE
LOWingestion/operators/docker/exit_handler.py591 except Exception as e:CODE
LOWingestion/tests/unit/test_column_type_parser.py96except Exception as exc:CODE
LOW…stion/tests/unit/test_workflow_parse_example_config.py24 except Exception as exc:CODE
LOWingestion/tests/unit/test_dbt_ingest.py285 except Exception as e:CODE
LOWingestion/tests/unit/test_parser_connection_fallback.py258 except Exception as e:CODE
LOWingestion/tests/unit/test_parser_connection_class.py117 except Exception as e:CODE
LOWingestion/tests/unit/test_parser_connection_module.py164 except Exception as e:CODE
LOWingestion/tests/unit/test_parser_connection_module.py197 except Exception as e:CODE
LOWingestion/tests/unit/test_parser_connection_module.py229 except Exception as e:CODE
LOWingestion/tests/unit/test_parser_connection_module.py259 except Exception as e:CODE
LOWingestion/tests/unit/test_parser_connection_module.py403 except Exception as e:CODE
LOW…estion/tests/unit/test_generated_models_defer_build.py113 except Exception as exc:CODE
LOW…estion/tests/unit/test_generated_models_defer_build.py154 except Exception:CODE
LOW…estion/tests/unit/test_generated_models_defer_build.py176 except Exception as err:CODE
MEDIUM…estion/tests/unit/test_generated_models_defer_build.py109def validate(worker_number):CODE
LOW…/tests/unit/topology/database/test_common_db_source.py392 except Exception:CODE
LOW…/tests/unit/topology/database/test_common_db_source.py533 except Exception:CODE
LOW…/tests/unit/topology/database/test_common_db_source.py559 except Exception:CODE
LOWingestion/tests/unit/topology/pipeline/test_airflow.py506 except Exception: # pylint: disable=broad-exception-caughtCODE
LOW…ests/unit/topology/dashboard/test_looker_multi_repo.py340 except Exception:CODE
LOW…on/tests/unit/source/database/mssql/test_connection.py177 except Exception as raised:CODE
LOWingestion/tests/unit/utils/test_datalake.py600 except Exception as e:CODE
LOWingestion/tests/unit/utils/test_datalake.py666 except Exception as e:CODE
LOWingestion/tests/unit/utils/test_memory_limit.py736 except Exception as e:CODE
LOW…ity/profiler/sqlalchemy/test_sqa_profiler_interface.py183 except Exception as e:CODE
MEDIUM…ity/profiler/sqlalchemy/test_sqa_profiler_interface.py184 print(f"Error during table setup: {str(e)}") # noqa: RUF010, T201CODE
LOW…ity/profiler/sqlalchemy/test_sqa_profiler_interface.py200 except Exception as e:CODE
MEDIUM…ity/profiler/sqlalchemy/test_sqa_profiler_interface.py201 print(f"Error during cleanup: {str(e)}") # noqa: RUF010, T201CODE
LOWingestion/tests/unit/lineage/queries/helpers.py284 except Exception as e:CODE
LOWingestion/tests/unit/lineage/queries/helpers.py312 except Exception as e:CODE
LOWingestion/tests/unit/lineage/queries/helpers.py340 except Exception as e:CODE
LOWingestion/tests/unit/lineage/queries/helpers.py388 except Exception as e:CODE
LOWingestion/tests/unit/lineage/queries/helpers.py449 except Exception as e:CODE
LOWingestion/tests/unit/lineage/queries/helpers.py477 except Exception as e:CODE
LOWingestion/tests/unit/lineage/queries/helpers.py505 except Exception as e:CODE
LOWingestion/tests/unit/lineage/queries/helpers.py553 except Exception as e:CODE
LOWingestion/tests/unit/readers/test_parquet_batches.py230 except Exception as e:CODE
LOWingestion/tests/unit/readers/test_s3_n_plus_one.py73 except Exception:CODE
LOWingestion/tests/unit/readers/test_s3_n_plus_one.py138 except Exception:CODE
1776 more matches not shown…
Cross-Language Confusion142 hits · 742 pts
SeverityFileLineSnippetContext
HIGHingestion/tests/unit/test_avro_parser.py550 "default": null,CODE
HIGHingestion/tests/unit/test_avro_parser.py698 self.parse_schema_assert_without_child(UNION_EXAMPLE_1, "UNION<null,int>")STRING
HIGHingestion/tests/unit/test_avro_parser.py699 self.parse_schema_assert_without_child(UNION_EXAMPLE_2, "UNION<null,int,string,boolean>")STRING
HIGHingestion/tests/unit/test_avro_parser.py700 self.parse_schema_assert_one_child(UNION_EXAMPLE_3, "UNION<null,record>")STRING
HIGHingestion/tests/unit/test_avro_parser.py701 self.parse_schema_assert_without_child(UNION_EXAMPLE_4, "UNION<null,record,record>")STRING
HIGHingestion/tests/unit/test_avro_parser.py702 self.parse_schema_assert_without_child(UNION_OF_ARRAY, "UNION<null,ARRAY<int>>")STRING
HIGHingestion/tests/unit/test_avro_parser.py704 self.parse_schema_assert_one_child(UNION_OF_ARRAY_OF_RECORD, "UNION<null,ARRAY<record>>")STRING
HIGHingestion/tests/unit/topology/database/test_datalake.py150 {"name":"John","age":16,"sex":"M","address":null},CODE
HIGH…n/tests/unit/topology/database/test_burstiq_sampler.py275 # BurstIQ gaps arrive as NaN; they must serialize as null, not "nan".COMMENT
HIGH…tion/tests/unit/topology/pipeline/test_kafkaconnect.py741 # Create CDC topic with only 'before' field having data (after only has null)COMMENT
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py105 "deferring_job_definition_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py106 "deferring_environment_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py108 "lifecycle_webhooks_url": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py205 "should_start_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py206 "trigger": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py207 "job": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py208 "environment": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py241 "git_branch": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py242 "git_sha": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py243 "status_message": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py244 "owner_thread_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py245 "executed_by_thread_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py246 "deferring_run_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py248 "artifact_s3_path": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py257 "dequeued_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py258 "started_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py259 "finished_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py260 "last_checked_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py261 "last_heartbeat_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py262 "should_start_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py263 "trigger": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py264 "job": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py265 "environment": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py93 "dbt_version": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py94 "raw_dbt_version": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py142 "job_completion_trigger_condition": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py145 "next_run": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py189 "owner_thread_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py191 "deferring_run_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py224 "retrying_run_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py228 "is_running": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py281 "retrying_run_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py285 "is_running": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py320 "rawSql": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py335 "rawSql": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py350 "rawSql": null,STRING
HIGH…stion/tests/unit/topology/pipeline/test_openlineage.py829 """Missing, null, or wrongly typed facet shapes yield an empty list."""STRING
HIGHingestion/tests/unit/topology/dashboard/test_omni.py231 # MOCK_DOCUMENT has no folder -> must be non-null, not None.COMMENT
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py123 Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [Catalog="DEMO_CATALOG", DatCODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py129 [Catalog="DEMO_CATALOG", Database=null, EnableAutomaticProxyDiscovery=null])CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py131 "select * from PUBLIC.STG_CUSTOMERS", null, [EnableFolding=true])CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py138 Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [ Catalog= "DEMO_CATALOGCODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py145 Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [Catalog="DEMO_CATALOG", DatCODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py150 Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [Catalog="DEMO_CATALOG", DatCODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py182 "null, [EnableFolding=true])\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py203 "null, [EnableFolding=true])\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py227 "null, [EnableFolding=true])\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py250 "null, [EnableFolding=true]),\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py270 "null, [EnableFolding=true]),\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py322 "null, [EnableFolding=true]),\n"CODE
82 more matches not shown…
Over-Commented Block550 hits · 537 pts
SeverityFileLineSnippetContext
LOWgenerate_ts.sh1#!/bin/bashCOMMENT
LOWingestion/pyproject.toml281# (basedpyright's default) enables `reportUnknown*` which is catastrophicCOMMENT
LOWingestion/pyproject.toml341# When we ratchet `reportUnknown*` to `warning` later (see executionEnvironmentsCOMMENT
LOWingestion/airflow-constraints-3.3.1.txt1COMMENT
LOWingestion/airflow-constraints-3.3.1.txt21#COMMENT
LOWingestion/setup.py1# Copyright 2025 CollateCOMMENT
LOWingestion/ingestion_dependency.sh1#!/usr/bin/env bashCOMMENT
LOWingestion/noxfile.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/conftest.py1import mathCOMMENT
LOWingestion/tests/unit/test_usage_filter.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/test_import_cost.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/test_usage_log.py1# Copyright 2025 CollateCOMMENT
LOW…gestion/tests/unit/topology/database/test_snowflake.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/topology/database/test_datalake.py1# pylint: disable=line-too-longCOMMENT
LOW…estion/tests/unit/topology/database/test_databricks.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/topology/database/test_bigquery.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/topology/pipeline/test_nifi.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/topology/pipeline/test_airbyte.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/topology/pipeline/test_spline.py1# Copyright 2025 CollateCOMMENT
LOW…it/topology/dashboard/test_dashboard_group_progress.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/topology/drive/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/pii/algorithms/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/pii/algorithms/data/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…ests/unit/source/database/deltalake/test_connection.py1# Copyright 2025 CollateCOMMENT
LOW…n/tests/unit/source/database/saperp/test_connection.py1# Copyright 2025 CollateCOMMENT
LOW…/tests/unit/source/database/burstiq/test_connection.py1# Copyright 2025 CollateCOMMENT
LOW…tion/tests/unit/source/database/sas/test_connection.py1# Copyright 2025 CollateCOMMENT
LOW…sts/unit/source/database/salesforce/test_connection.py1# Copyright 2025 CollateCOMMENT
LOW…s/unit/source/database/domodatabase/test_connection.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/pipeline/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…estion/tests/unit/source/pipeline/fivetran/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/pipeline/nifi/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/pipeline/flink/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…gestion/tests/unit/source/pipeline/dagster/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…gestion/tests/unit/source/pipeline/airflow/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…ts/unit/source/pipeline/databrickspipeline/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…estion/tests/unit/source/pipeline/dbtcloud/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…on/tests/unit/source/pipeline/kafkaconnect/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/pipeline/spline/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…ion/tests/unit/source/pipeline/openlineage/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…gestion/tests/unit/source/pipeline/airbyte/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…gestion/tests/unit/source/pipeline/prefect/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…on/tests/unit/source/pipeline/gluepipeline/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…on/tests/unit/source/pipeline/domopipeline/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/mlmodel/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/mlmodel/mlflow/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…estion/tests/unit/source/mlmodel/sagemaker/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/mcp/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/storage/s3/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/storage/gcs/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…estion/tests/unit/source/search/opensearch/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…ion/tests/unit/source/search/elasticsearch/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/dashboard/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/dashboard/ssrs/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…/tests/unit/source/dashboard/microstrategy/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…ion/tests/unit/source/dashboard/quicksight/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…tion/tests/unit/source/dashboard/qlikcloud/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…gestion/tests/unit/source/dashboard/looker/__init__.py1# Copyright 2025 CollateCOMMENT
LOW…estion/tests/unit/source/dashboard/tableau/__init__.py1# Copyright 2025 CollateCOMMENT
490 more matches not shown…
Structural Annotation Overuse346 hits · 513 pts
SeverityFileLineSnippetContext
LOW…a/ingestion/source/database/my_db/CONNECTOR_CONTEXT.md44## Step 1: Read the Reference ConnectorCOMMENT
LOW…a/ingestion/source/database/my_db/CONNECTOR_CONTEXT.md56## Step 2: Implement the Connector FilesCOMMENT
LOW…a/ingestion/source/database/my_db/CONNECTOR_CONTEXT.md74## Step 3: Register the ConnectorCOMMENT
LOW…a/ingestion/source/database/my_db/CONNECTOR_CONTEXT.md96## Step 4: Code Generation and FormattingCOMMENT
LOW…a/ingestion/source/database/my_db/CONNECTOR_CONTEXT.md107## Step 5: Write Tests and ValidateCOMMENT
LOW…src/metadata/ingestion/source/database/dbt/metadata.py484 # Step 1: Check if property exists in OpenMetadataCOMMENT
LOW…src/metadata/ingestion/source/database/dbt/metadata.py500 # Step 2: Validate and convert value (single pass)COMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py905 # Step 2: Create table-to-table lineage for downstream dependenciesCOMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py823 # Step 1: Create Kafka topic -> DLT table lineageCOMMENT
LOWingestion/src/metadata/cli/scaffold.py1533 s.append("## Step 4: Code Generation and Formatting")STRING
LOWingestion/src/metadata/cli/scaffold.py1546 s.append("## Step 5: Write Tests and Validate")STRING
LOWingestion/src/metadata/cli/scaffold.py1381 s.append("## Step 1: Read the Reference Connector")STRING
LOWingestion/src/metadata/cli/scaffold.py1406 s.append("## Step 2: Implement the Connector Files")STRING
LOWingestion/src/metadata/cli/scaffold.py1509 s.append("## Step 3: Register the Connector")STRING
LOW…ta/profiler/metrics/hybrid/cardinality_distribution.py92 # Step 1: Get value counts and ranksCOMMENT
LOW…ta/profiler/metrics/hybrid/cardinality_distribution.py120 # Step 3: Final aggregation with simple GROUP BYCOMMENT
LOWbin/distributed-test/CLUSTER-SIZING-RUNBOOK.md37### Step 1: Environment SetupCOMMENT
LOWbin/distributed-test/CLUSTER-SIZING-RUNBOOK.md77### Step 2: Find Optimal Concurrency (Optional)COMMENT
LOWbin/distributed-test/CLUSTER-SIZING-RUNBOOK.md95### Step 3: Run Progressive BenchmarkCOMMENT
LOWbin/distributed-test/CLUSTER-SIZING-RUNBOOK.md165### Step 4: Analyze ResultsCOMMENT
LOWbin/distributed-test/CLUSTER-SIZING-RUNBOOK.md223### Step 5: Apply RecommendationsCOMMENT
LOWbin/distributed-test/CLUSTER-SIZING-RUNBOOK.md314### Step 6: Re-validateCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4218 // Step 1: Ingestion creates entities (no tags)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4223 // Step 2: User adds tags to entities via PATCHCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4241 // Step 3: Ingestion re-runs — bulk update with only description changes (no tags in request)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4248 // Step 4: Verify tags are still present after re-ingestionCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4268 // Step 1: Ingestion creates entities (no owners)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4273 // Step 2: User adds owners via PATCHCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4284 // Step 3: Re-ingestion with only description changesCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4291 // Step 4: Verify owners preservedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3047 // Step 1: Create a dedicated glossary for this test to avoid interferenceCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3054 // Step 2: Create two terms - both should start as APPROVED (default status when no reviewers)COMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3071 // Step 3: Update the second term to IN_REVIEW statusCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3076 // Step 4: Search without entityStatus filter - both terms should be returnedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3093 // Step 5: Search with APPROVED status - only the first term should be returnedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3115 // Step 6: Search with IN_REVIEW status - only the second term should be returnedCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1861 // Step 1: Get the existing Certification classification (seeded by the system)COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1866 // Step 2: Create a new tag under CertificationCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1876 // Step 3: Create the DB hierarchy and a DatabaseSchemaCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1883 // Step 4: Apply the certification tag to the DatabaseSchema via setCertification()COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1942 // Step 6: Rename the certification tag (change its name — this changes the FQN)COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1950 // Step 7: Wait until certification tagFQN propagates to the entityCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1907 // Step 5: Verify search finds the schema by the original tag FQNCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1973 // Step 8: Search must find the schema under the new tag FQNCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java2009 // Step 9: Delete the certification tag and verify the schema no longer has a certificationCOMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java68 // Step 1: Create two domains - source and targetCOMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java72 // Step 2: Create a data product in the source domainCOMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java85 // Step 3: Create tables with source domain and add them as assets to the data productCOMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java115 // Step 4: Change the data product's domain from source to targetCOMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java135 // Step 5: Verify assets now have target domain via API (database check - THE KEY TEST)COMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java139 // Step 6: Verify assets appear in target domain's /assets endpoint (THE ACTUAL USER ENDPOINT)COMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java143 // Step 7: Verify assets now appear in target domain's search (search index check)COMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java146 // Step 8: Verify assets no longer appear in source domain's searchCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java90 // Step 1: Create a policy that allows VIEW_ALL on entities with PII.Sensitive tagCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java107 // Step 2: Create a role with that policyCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java116 // Step 3: Create a team with that role as defaultCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java126 // Step 4: Create a user in that teamCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java140 // Step 5: Create database service and schema using factoriesCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java148 // Step 6: Create a table WITH the PII.Sensitive tag using fluent APICOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java169 // Step 7: Create a query that references the table (query does NOT have the tag)COMMENT
286 more matches not shown…
Self-Referential Comments148 hits · 481 pts
SeverityFileLineSnippetContext
MEDIUMingestion/tests/unit/test_ometa_utils.py171 # Create a mock JWT payloadCOMMENT
MEDIUMingestion/tests/unit/test_ometa_utils.py183 # Create a mock JWT token (header.payload.signature)COMMENT
MEDIUMingestion/tests/unit/test_ometa_utils.py195 # Create a payload that will need paddingCOMMENT
MEDIUMingestion/tests/unit/test_dbt.py1026 # Create a mock manifest node with list of ownersCOMMENT
MEDIUMingestion/tests/unit/test_dbt.py1043 # Create a mock manifest node with list of ownersCOMMENT
MEDIUMingestion/tests/unit/test_dbt.py950 # Create a mock manifest node with openmetadata.ownerCOMMENT
MEDIUMingestion/tests/unit/test_dbt.py966 # Create a mock manifest node with old format ownerCOMMENT
MEDIUMingestion/tests/unit/test_dbt.py2499 # Create a mock source nodeCOMMENT
MEDIUMingestion/tests/unit/test_db_utils.py69 # Create a mock table entityCOMMENT
MEDIUMingestion/tests/unit/test_db_utils.py81 # Create a mock source table entity for lineage testsCOMMENT
MEDIUMingestion/tests/unit/test_db_utils.py94 # Create a mock TableViewCOMMENT
MEDIUMingestion/tests/unit/test_db_utils.py278 # Create a valid AddLineageRequest for the mockCOMMENT
MEDIUMingestion/tests/unit/test_lineage_empty_result.py28 # Create an in-memory SQLite database for testingCOMMENT
MEDIUMingestion/tests/unit/test_lineage_empty_result.py31 # Create a test tableCOMMENT
MEDIUMingestion/tests/unit/topology/test_context_manager.py46 # Create a new thread context based on the main threadCOMMENT
MEDIUMingestion/tests/unit/topology/test_context_manager.py48 # Create the new thread context based on the main thread oneCOMMENT
MEDIUMingestion/tests/unit/topology/test_context_manager.py64 # Create the new thread context based on the main thread oneCOMMENT
MEDIUMingestion/tests/unit/topology/test_queue.py34 # Create a new QueueItem and add it to the queueCOMMENT
MEDIUM…/tests/unit/topology/database/test_burstiq_metadata.py78 # Create a mock source instanceCOMMENT
MEDIUM…estion/tests/unit/topology/database/test_databricks.py834 # Create a mock inspectorCOMMENT
MEDIUM…estion/tests/unit/topology/database/test_databricks.py842 # Create a mock dialect with get_table_names methodCOMMENT
MEDIUM…estion/tests/unit/topology/database/test_databricks.py866 # Create a mock inspectorCOMMENT
MEDIUM…estion/tests/unit/topology/database/test_databricks.py874 # Create a mock dialect with get_view_names methodCOMMENT
MEDIUM…estion/tests/unit/topology/database/test_databricks.py899 # Create a mock dialect instanceCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_sap_hana.py191 # Create a mock engine and connectionCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_sap_hana.py201 # Create a DataSource with DATA_BASE_TABLE typeCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_sap_hana.py235 # Create a simple parsed lineageCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_sap_hana.py708 # Create a scenario with circular dependenciesCOMMENT
MEDIUM…gestion/tests/unit/topology/database/test_deltalake.py134 # Create the DF as a tmp view to be able to run Spark SQL statements on topCOMMENT
MEDIUM…gestion/tests/unit/topology/database/test_deltalake.py139 # Create a database. We will be ingesting that as a schemaCOMMENT
MEDIUM…tion/tests/unit/topology/database/test_athena_utils.py72 # Create a column object that raises AttributeError when accessing parametersCOMMENT
MEDIUM…tion/tests/unit/topology/database/test_athena_utils.py107 # Create a column object without parameters attributeCOMMENT
MEDIUM…tion/tests/unit/topology/database/test_athena_utils.py138 # Create a column object with None parametersCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py458 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py501 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py514 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py530 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py569 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py582 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py622 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py661 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py692 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py722 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py744 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py765 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/database/test_postgres.py811 # Create a mock source config with the required attributesCOMMENT
MEDIUMingestion/tests/unit/topology/pipeline/test_airflow.py453 # Create a mock serialized DAG resultCOMMENT
MEDIUMingestion/tests/unit/topology/pipeline/test_airflow.py492 # Create a mock serialized DAG resultCOMMENT
MEDIUMingestion/tests/unit/topology/pipeline/test_airflow.py850 # Create a new AirflowSource instance (or use self.airflow if safe)COMMENT
MEDIUM…tion/tests/unit/topology/pipeline/test_kafkaconnect.py360 # Create a minimal source instanceCOMMENT
MEDIUM…tion/tests/unit/topology/pipeline/test_kafkaconnect.py545 # Create a mock source that bypasses __init__COMMENT
MEDIUM…tion/tests/unit/topology/pipeline/test_kafkaconnect.py551 # Create a mock Debezium CDC topic with nested envelope structureCOMMENT
MEDIUM…tion/tests/unit/topology/pipeline/test_kafkaconnect.py670 # Create a regular (non-CDC) topicCOMMENT
MEDIUMingestion/tests/unit/topology/search/test_opensearch.py140# Create a mock search service. Adjust the serviceType if you have a dedicated type for OpenSearch.COMMENT
MEDIUMingestion/tests/unit/topology/dashboard/test_looker.py696 # Create a dashboard with no user_idSTRING
MEDIUM…n/tests/unit/topology/dashboard/test_grafana_simple.py29 # Create a minimal instance just for testing the methodCOMMENT
MEDIUMingestion/tests/unit/topology/dashboard/test_tableau.py732 # Create a mock dashboard with owner informationCOMMENT
MEDIUM…estion/tests/unit/topology/dashboard/_test_superset.py486 # Create a dashboard without position_json (Superset 5.0.0 list endpoint)COMMENT
MEDIUM…estion/tests/unit/topology/dashboard/_test_superset.py516 # Create a dashboard WITH position_json (Superset 4.x list endpoint)COMMENT
MEDIUM…unit/topology/dashboard/test_looker_extends_lineage.py77 # Create a view that extends another viewCOMMENT
88 more matches not shown…
Deep Nesting562 hits · 467 pts
SeverityFileLineSnippetContext
LOWingestion/operators/docker/exit_handler.py119CODE
LOWingestion/operators/docker/exit_handler.py222CODE
LOW…stion/tests/unit/test_workflow_parse_example_config.py15CODE
LOWingestion/tests/unit/test_dbt.py2425CODE
LOWingestion/tests/unit/test_dbt.py2495CODE
LOWingestion/tests/unit/test_dbt.py2727CODE
LOWingestion/tests/unit/test_parser_connection_class.py97CODE
LOWingestion/tests/unit/topology/database/test_sap_hana.py373CODE
LOW…tion/tests/unit/topology/database/test_athena_utils.py69CODE
LOW…tion/tests/unit/topology/database/test_athena_utils.py104CODE
LOW…tion/tests/unit/topology/database/test_athena_utils.py135CODE
LOWingestion/tests/unit/topology/pipeline/test_dbtcloud.py985CODE
LOWingestion/tests/unit/topology/pipeline/test_dbtcloud.py1045CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py289CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py418CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py332CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py380CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py467CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py513CODE
LOW…sts/unit/topology/dashboard/test_hex_ingestion_flow.py108CODE
LOW…sts/unit/topology/dashboard/test_hex_ingestion_flow.py243CODE
LOW…sts/unit/topology/dashboard/test_hex_ingestion_flow.py382CODE
LOW…sts/unit/topology/dashboard/test_hex_ingestion_flow.py431CODE
LOW…sts/unit/topology/dashboard/test_hex_ingestion_flow.py532CODE
LOW…sts/unit/topology/dashboard/test_hex_ingestion_flow.py580CODE
LOW…estion/tests/unit/topology/dashboard/test_qlikcloud.py441CODE
LOWingestion/tests/unit/topology/api/test_rest.py615CODE
LOW…quality/validations/test_row_count_logic_with_total.py8CODE
LOW…lity/validations/test_passed_failed_row_calculation.py8CODE
LOW…t/observability/profiler/pandas/test_custom_metrics.py163CODE
LOW…t/observability/profiler/pandas/test_custom_metrics.py254CODE
LOW…tests/unit/sampler/test_container_sampler_processor.py156CODE
LOWingestion/tests/unit/lineage/queries/helpers.py119CODE
LOWingestion/tests/unit/lineage/queries/helpers.py234CODE
LOWingestion/tests/unit/lineage/queries/helpers.py401CODE
LOWingestion/tests/unit/sdk/test_sdk_fluent_api.py40CODE
LOWingestion/tests/cli_e2e/test_cli_tableau.py312CODE
LOWingestion/tests/cli_e2e/test_cli_tableau.py365CODE
LOWingestion/tests/cli_e2e/test_cli_tableau.py392CODE
LOWingestion/tests/cli_e2e/test_cli_tableau.py500CODE
LOWingestion/tests/cli_e2e/common/test_cli_db.py115CODE
LOW…/integration/ometa/test_ometa_custom_properties_api.py532CODE
LOW…assification/databases/test_azuresql_temporal_table.py148CODE
LOWingestion/tests/integration/fivetran/conftest.py249CODE
LOW…stion/tests/integration/data_quality/test_data_diff.py613CODE
LOWingestion/tests/integration/trino/test_classifier.py27CODE
LOWingestion/tests/integration/sftp/conftest.py65CODE
LOW…integration/datalake/test_table_rule_library_pandas.py40CODE
LOW…tests/integration/datalake/test_rule_library_pandas.py50CODE
LOWingestion/tests/integration/nats/populate_nats.py145CODE
LOW…/tests/integration/powerbi/test_powerbi_file_client.py82CODE
LOW…/tests/integration/sources/mlmodels/mlflow/conftest.py77CODE
LOWingestion/tests/load/test_load.py41CODE
LOWingestion/tests/load/test_resources/all_resources.py16CODE
LOW…enmetadata_testutils/pytest_openmetadata/test_utils.py7CODE
LOW…ion/src/_openmetadata_testutils/pydantic/test_utils.py7CODE
LOW…on/src/airflow_provider_openmetadata/lineage/runner.py235CODE
LOW…on/src/airflow_provider_openmetadata/lineage/runner.py540CODE
LOWingestion/src/metadata/pii/conflict_resolver.py100CODE
LOWingestion/src/metadata/pii/classification_manager.py98CODE
502 more matches not shown…
Verbosity Indicators262 hits · 387 pts
SeverityFileLineSnippetContext
LOW…src/metadata/ingestion/source/database/dbt/metadata.py484 # Step 1: Check if property exists in OpenMetadataCOMMENT
LOW…src/metadata/ingestion/source/database/dbt/metadata.py500 # Step 2: Validate and convert value (single pass)COMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py905 # Step 2: Create table-to-table lineage for downstream dependenciesCOMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py823 # Step 1: Create Kafka topic -> DLT table lineageCOMMENT
LOWingestion/src/metadata/cli/scaffold.py1533 s.append("## Step 4: Code Generation and Formatting")STRING
LOWingestion/src/metadata/cli/scaffold.py1546 s.append("## Step 5: Write Tests and Validate")STRING
LOWingestion/src/metadata/cli/scaffold.py1381 s.append("## Step 1: Read the Reference Connector")STRING
LOWingestion/src/metadata/cli/scaffold.py1406 s.append("## Step 2: Implement the Connector Files")STRING
LOWingestion/src/metadata/cli/scaffold.py1509 s.append("## Step 3: Register the Connector")STRING
LOW…ta/profiler/metrics/hybrid/cardinality_distribution.py92 # Step 1: Get value counts and ranksCOMMENT
LOW…ta/profiler/metrics/hybrid/cardinality_distribution.py120 # Step 3: Final aggregation with simple GROUP BYCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4218 // Step 1: Ingestion creates entities (no tags)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4223 // Step 2: User adds tags to entities via PATCHCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4241 // Step 3: Ingestion re-runs — bulk update with only description changes (no tags in request)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4248 // Step 4: Verify tags are still present after re-ingestionCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4268 // Step 1: Ingestion creates entities (no owners)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4273 // Step 2: User adds owners via PATCHCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4284 // Step 3: Re-ingestion with only description changesCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4291 // Step 4: Verify owners preservedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3047 // Step 1: Create a dedicated glossary for this test to avoid interferenceCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3054 // Step 2: Create two terms - both should start as APPROVED (default status when no reviewers)COMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3071 // Step 3: Update the second term to IN_REVIEW statusCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3076 // Step 4: Search without entityStatus filter - both terms should be returnedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3093 // Step 5: Search with APPROVED status - only the first term should be returnedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3115 // Step 6: Search with IN_REVIEW status - only the second term should be returnedCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1861 // Step 1: Get the existing Certification classification (seeded by the system)COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1866 // Step 2: Create a new tag under CertificationCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1876 // Step 3: Create the DB hierarchy and a DatabaseSchemaCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1883 // Step 4: Apply the certification tag to the DatabaseSchema via setCertification()COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1942 // Step 6: Rename the certification tag (change its name — this changes the FQN)COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1950 // Step 7: Wait until certification tagFQN propagates to the entityCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1907 // Step 5: Verify search finds the schema by the original tag FQNCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1973 // Step 8: Search must find the schema under the new tag FQNCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java2009 // Step 9: Delete the certification tag and verify the schema no longer has a certificationCOMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java68 // Step 1: Create two domains - source and targetCOMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java72 // Step 2: Create a data product in the source domainCOMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java85 // Step 3: Create tables with source domain and add them as assets to the data productCOMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java115 // Step 4: Change the data product's domain from source to targetCOMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java135 // Step 5: Verify assets now have target domain via API (database check - THE KEY TEST)COMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java139 // Step 6: Verify assets appear in target domain's /assets endpoint (THE ACTUAL USER ENDPOINT)COMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java143 // Step 7: Verify assets now appear in target domain's search (search index check)COMMENT
LOW…penmetadata/it/tests/DataProductDomainMigrationIT.java146 // Step 8: Verify assets no longer appear in source domain's searchCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java90 // Step 1: Create a policy that allows VIEW_ALL on entities with PII.Sensitive tagCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java107 // Step 2: Create a role with that policyCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java116 // Step 3: Create a team with that role as defaultCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java126 // Step 4: Create a user in that teamCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java140 // Step 5: Create database service and schema using factoriesCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java148 // Step 6: Create a table WITH the PII.Sensitive tag using fluent APICOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java169 // Step 7: Create a query that references the table (query does NOT have the tag)COMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java189 // Step 8: Verify the test user CAN view the table (due to tag-based policy)COMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java198 // Step 9: Verify the test user CAN view queries for that tableCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1026 // Step 1: Create a glossary with initial version 0.1COMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1031 // Step 2: Prepare CSV content with multiple glossary termsCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1034 // Step 3: Import CSV using SYNC method (now also creates version history!)COMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1052 // Step 4: Verify version incremented to 0.2COMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1060 // Step 5: Retrieve version historyCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1067 // Step 6: Get version 0.2 and verify it has change descriptionCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1072 // Step 7: Verify change description contains 'bulkImport' field changeCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1078 // Step 8: Verify bulkImport field has statisticsCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1089 // Step 9: Verify glossary terms were actually createdCOMMENT
202 more matches not shown…
Fake / Example Data293 hits · 310 pts
SeverityFileLineSnippetContext
LOWingestion/tests/unit/test_dbt.py1966 self.assertTrue(validate_email_format("user@example.com"))CODE
LOWingestion/tests/unit/test_dbt.py2116 is_valid, error, value = validate_custom_property_value("testProp", "email", None, "user@example.com")CODE
LOWingestion/tests/unit/test_dbt.py2118 self.assertEqual(value, "user@example.com")CODE
LOW…ts/unit/topology/database/test_databricks_ownership.py215 assert resolver.get_owner_ref("user@example.com") == "email-ref"CODE
LOW…ts/unit/topology/database/test_databricks_ownership.py228 assert resolver.get_owner_ref("user@example.com") == "owner-ref"CODE
LOW…/unit/topology/database/test_databricks_get_columns.py133 ("Owner", "user@example.com", None),CODE
LOW…nit/topology/database/test_bigquery_test_connection.py39 "projectId": "placeholder",CODE
LOW…nit/topology/database/test_bigquery_test_connection.py42 "clientEmail": "user@example.com",CODE
LOW…/database/test_redshift_incremental_table_processor.py136 "COMMENT ON VIEW {table_name} IS 'lorem ipsum'",CODE
LOW…/database/test_redshift_incremental_table_processor.py140 " \tCOMMENT \n ON VIEW {table_name}\n\t\n IS 'lorem ipsum'",CODE
LOW…s/unit/topology/pipeline/test_openlineage_ownership.py76 user = build_user("jdoe", "John Doe")CODE
LOWingestion/tests/unit/topology/search/test_opensearch.py61 "securityConfig": {"jwtToken": "eyJraWQiOiJ...dummy_token..."},CODE
LOWingestion/tests/unit/topology/dashboard/test_grafana.py247 updatedBy="admin@example.com",CODE
LOWingestion/tests/unit/topology/dashboard/test_grafana.py248 createdBy="admin@example.com",CODE
LOWingestion/tests/unit/topology/dashboard/test_grafana.py601 "updatedBy": "user@example.com",CODE
LOWingestion/tests/unit/topology/dashboard/test_grafana.py602 "createdBy": "admin@example.com",CODE
LOWingestion/tests/unit/topology/dashboard/test_grafana.py668 updatedBy="user@example.com",CODE
LOWingestion/tests/unit/topology/dashboard/test_grafana.py669 createdBy="admin@example.com",CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py581 "displayName": "John Doe",CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py602 "displayName": "John Doe",CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py611 root=[EntityReference(id=uuid.uuid4(), name="John Doe", type="user")]CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py690 displayName="Jane Doe",CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py865 self.assertEqual(owner_ref.root[0].name, "John Doe")CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py881 self.assertEqual(owner_ref.root[0].name, "John Doe")CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py1015 return EntityReferenceList(root=[EntityReference(id=uuid.uuid4(), name="John Doe", type="user")])CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py1030 self.assertIn("John Doe", owner_names)CODE
LOWingestion/tests/unit/topology/drive/test_googledrive.py138 owners=[GoogleDriveOwner(displayName="John Doe")],CODE
LOWingestion/tests/unit/pii/test_ner_scanner.py34 "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Nam consequat quam sagittis convallis cursus."CODE
LOWingestion/tests/unit/pii/test_ner_scanner.py34 "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Nam consequat quam sagittis convallis cursus."CODE
LOWingestion/tests/unit/pii/test_ner_scanner.py131 '{"email": "johndoe@example.com", "address": {"street": "123 Main St"}}',CODE
LOW…t/resources/datasets/databricks_pipeline_resource.json136 "name": "John Doe"CODE
LOW…sts/unit/source/database/test_json_schema_extractor.py410 json_values = [{"user-name": "John", "email@domain": "test@test.com"}]CODE
LOW…tests/unit/source/database/bigquery/test_connection.py43 "projectId": "placeholder",CODE
LOW…tests/unit/source/database/bigquery/test_connection.py46 "clientEmail": "user@example.com",CODE
LOWingestion/tests/unit/source/messaging/test_pubsub.py245 privateKey="fake-key",CODE
LOW…sts/unit/source/messaging/test_common_broker_source.py77 payload = json.dumps({"email": "user@example.com"}).encode("utf-8")CODE
LOW…sts/unit/source/messaging/test_common_broker_source.py84 body = json.dumps({"email": "user@example.com"}).encode("utf-8")CODE
LOW…tion/tests/unit/observability/data_quality/conftest.py124 fullname="John Doe",CODE
LOW…tion/tests/unit/observability/data_quality/conftest.py148 fullname="John Doe",CODE
LOW…bservability/data_quality/test_validations_datalake.py45 "John Doe",CODE
LOW…bservability/data_quality/test_validations_datalake.py71 "John Doe",CODE
LOW…ability/data_quality/validations/test_data_diff_url.py251 "user": "user@example.com",CODE
LOW…s/runtime_param_setter/test_base_diff_params_setter.py213 username="user@example.com",CODE
LOW…s/runtime_param_setter/test_base_diff_params_setter.py242 "user": "user@example.com",CODE
LOW…s/runtime_param_setter/test_base_diff_params_setter.py282 assert client._args["user"] == "user@example.com"CODE
LOW…servability/profiler/custom_types/test_custom_types.py54 fullname="John Doe",CODE
LOW…servability/profiler/custom_types/test_custom_types.py70 fullname="John Doe",CODE
LOW…ity/profiler/sqlalchemy/test_sqa_profiler_interface.py188 User(name="John", fullname="John Doe", nickname="johnny b goode", age=30),CODE
LOW…/unit/observability/profiler/sqlalchemy/test_sample.py160 fullname="John Doe",CODE
LOW…/unit/observability/profiler/sqlalchemy/test_sample.py174 fullname="John Doe",CODE
LOW…/unit/observability/profiler/sqlalchemy/test_sample.py320 fullname="John Doe",CODE
LOW…unit/observability/profiler/sqlalchemy/test_metrics.py114 fullname="John Doe",CODE
LOW…unit/observability/profiler/sqlalchemy/test_metrics.py136 fullname="John Doe",CODE
LOW…nit/observability/profiler/sqlalchemy/test_profiler.py129 User(name="John", fullname="John Doe", nickname="johnny b goode", age=30),CODE
LOW…/unit/observability/profiler/sqlalchemy/test_runner.py121 fullname="John Doe",CODE
LOW…/unit/observability/profiler/sqlalchemy/test_runner.py135 fullname="John Doe",CODE
LOW…ts/unit/observability/profiler/pandas/test_profiler.py305 # Test with fullname column - it has repeated values ("John Doe", "Jone Doe" appear twice each)COMMENT
LOWingestion/tests/unit/sampler/test_messaging_sampler.py104 "email": "user@example.com",CODE
LOWingestion/tests/unit/sampler/test_messaging_sampler.py112 assert row["Order.email"] == "user@example.com"CODE
LOWingestion/tests/unit/sampler/test_messaging_sampler.py157 message = {"email": "user@example.com", "ssn": "123-45-6789"}CODE
233 more matches not shown…
Unused Imports301 hits · 284 pts
SeverityFileLineSnippetContext
LOWingestion/tests/unit/conftest.py12CODE
LOW…ts/unit/topology/database/test_vertica_type_mapping.py24CODE
LOWingestion/tests/unit/topology/database/test_postgres.py907CODE
LOWingestion/tests/unit/topology/database/test_postgres.py918CODE
LOWingestion/tests/unit/topology/database/test_postgres.py930CODE
LOWingestion/tests/unit/topology/database/test_postgres.py940CODE
LOW…profiler/sqlalchemy/azuresql/test_azuresql_sampling.py8CODE
LOWingestion/tests/integration/sdk/test_sdk_integration.py8CODE
LOWingestion/scripts/debug_tag_processor.py46CODE
LOW…estion/src/_openmetadata_testutils/helpers/__init__.py1CODE
LOW…/src/airflow_provider_openmetadata/lineage/callback.py27CODE
LOW…on/src/airflow_provider_openmetadata/lineage/status.py28CODE
LOW…on/src/airflow_provider_openmetadata/lineage/status.py29CODE
LOW…on/src/airflow_provider_openmetadata/lineage/status.py30CODE
LOW…on/src/airflow_provider_openmetadata/lineage/status.py31CODE
LOWingestion/src/metadata/pii/algorithms/tag_scoring.py16CODE
LOWingestion/src/metadata/ingestion/ometa/task_models.py19CODE
LOW…on/src/metadata/ingestion/ometa/announcement_models.py15CODE
LOW…/metadata/ingestion/ometa/mixins/conversation_mixin.py15CODE
LOW…/metadata/ingestion/ometa/mixins/data_insight_mixin.py17CODE
LOW…/metadata/ingestion/ometa/mixins/announcement_mixin.py15CODE
LOW…ion/src/metadata/ingestion/ometa/mixins/patch_mixin.py57CODE
LOWingestion/src/metadata/ingestion/progress/registry.py32CODE
LOW…tion/src/metadata/ingestion/progress/runner_tracker.py35CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py23CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py23CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py23CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py28CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py28CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py28CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py28CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py34CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py34CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py34CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py34CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py34CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py41CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py41CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py41CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py46CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py46CODE
LOWingestion/src/metadata/ingestion/progress/modes.py24CODE
LOWingestion/src/metadata/ingestion/progress/_render.py22CODE
LOW…data/ingestion/source/database/ai_governance_sample.py14CODE
LOW…rc/metadata/ingestion/source/database/glue/metadata.py78CODE
LOW…/metadata/ingestion/source/database/glue/connection.py18CODE
LOW…ata/ingestion/source/database/unitycatalog/metadata.py109CODE
LOW…a/ingestion/source/database/unitycatalog/connection.py15CODE
LOW…data/ingestion/source/database/unitycatalog/lineage.py60CODE
LOW…tadata/ingestion/source/database/deltalake/metadata.py57CODE
LOW…tadata/ingestion/source/database/timescale/__init__.py1CODE
LOW…data/ingestion/source/database/databricks/ownership.py15CODE
LOW…adata/ingestion/source/database/databricks/metadata.py95CODE
LOW…ata/ingestion/source/database/databricks/connection.py16CODE
LOW…metadata/ingestion/source/database/burstiq/metadata.py71CODE
LOW…etadata/ingestion/source/database/datalake/metadata.py78CODE
LOW…adata/ingestion/source/database/bigquery/connection.py16CODE
LOW…data/ingestion/source/database/snowflake/connection.py16CODE
LOW…adata/ingestion/source/database/redshift/connection.py16CODE
LOW…adata/ingestion/source/database/postgres/connection.py16CODE
241 more matches not shown…
Docstring Block Structure32 hits · 160 pts
SeverityFileLineSnippetContext
HIGHingestion/tests/unit/test_owner_config.py129 Unwrap OwnerValue Pydantic model to get actual value. OwnerValue wraps the actual values in nested root attribSTRING
HIGH…ion/src/metadata/ingestion/ometa/mixins/table_mixin.py453Get profile data Args: fqn (str): fullyQualifiedName start_ts (int): start timestamp STRING
HIGH…estion/src/metadata/ingestion/ometa/mixins/es_mixin.py346 Paginate through the ES results, ignoring individual errors. Args: entity: The entity typeSTRING
HIGH…etadata/ingestion/source/database/bigquery/metadata.py286 Get the project ID from the service connection or ADC. Args: service_connection: Optional STRING
HIGH…adata/ingestion/source/pipeline/kafkaconnect/client.py40 Parse CDC topic names to extract database and table information. Common CDC topic naming patterns: - DebezSTRING
HIGH…ta/ingestion/source/dashboard/hex/warehouse_queries.py209 Get the Hex query template for a specific warehouse type Args: warehouse_type: Type of the warehouse (STRING
HIGH…stion/src/metadata/ingestion/source/api/rest/parser.py50 Parse OpenAPI schema from HTTP response. Supports both JSON and YAML formats. Args: response: HTTPSTRING
HIGHingestion/src/metadata/ingestion/sink/metadata_rest.py994 Generic dispatcher for ingesting sample data for any classifiable entity. Uses singledispatchmethod forSTRING
HIGH…metadata/data_quality/validations/base_test_handler.py298Execute dimensional validation query for a single dimension column Must be implemented by child classes to suppSTRING
HIGH…metadata/data_quality/validations/base_test_handler.py320Evaluate the test condition based on computed metrics This is the core logic that determines if the test passesSTRING
HIGH…metadata/data_quality/validations/base_test_handler.py352Format the result message for the test Override in child classes to provide human-readable test results. STRING
HIGH…data_quality/validations/mixins/sqa_validator_mixin.py123Run the metric query against the column Args: runner (QueryRunner): runner object witj sqlalchemy sSTRING
HIGH…data_quality/validations/mixins/sqa_validator_mixin.py163compute row count for between tests Args: runner (QueryRunner): runner column (Column):STRING
HIGH…column/base/columnRuleLibrarySqlExpressionValidator.py63Compile SQL expression template using Jinja2. Replaces: - {{ column_name }} with the actual column nameSTRING
HIGH…data_quality/validations/table/sqlalchemy/tableDiff.py135Compile a list of elements into a string with 'and' clauses. Args: elements: A string or a list of strings STRING
HIGH…s/table/base/tableRuleLibrarySqlExpressionValidator.py59Compile SQL expression template using Jinja2. Replaces: - {{ table_name }} with the actual table path STRING
HIGHingestion/src/metadata/utils/credentials.py267 Get Azure access token using the provided Azure configuration. Args: azure_config: Azure configurationSTRING
HIGHingestion/src/metadata/utils/helpers.py289Remove start and ending double quotes in a string Args: string (str): a string Raises: TypeErrSTRING
HIGH…adata/utils/dependency_injector/dependency_injector.py330 Extract the type argument from an Inject type. Args: tp: The type to extract from Returns: STRING
HIGH…c/metadata/sdk/data_quality/workflow_config_builder.py239Safely fetch entity by name with exception handling. Args: entity_type: Entity class to fetch STRING
HIGH…c/metadata/sdk/data_quality/workflow_config_builder.py265Safely fetch entity by ID with exception handling. Args: entity_type: Entity class to fetch STRING
HIGHingestion/src/metadata/sdk/data_quality/runner.py123Initialize runner for a specific table FQN. Args: table_fqn: Fully qualified name of the table (e.gSTRING
HIGHingestion/src/metadata/sdk/data_quality/runner.py219Add multiple test definitions at once. Args: *test_definitions: Variable number of test definition STRING
HIGH…src/metadata/sdk/data_quality/dataframes/validators.py119Whether the validator requires a whole table to return appropriate results Examples: - `columnValuesToBeUniSTRING
HIGH…data/sdk/data_quality/dataframes/validation_results.py119Merge multiple ValidationResult objects into one. Aggregates results from multiple validation runs, useful whenSTRING
HIGHingestion/src/metadata/great_expectations/action.py184Return the batch spec the expectations ran against Args: meta: metadata attached to a validation reSTRING
HIGH…c/metadata/profiler/metrics/system/snowflake/system.py184Resolve the fully qualified name of the table from snowflake based on the following logic: 1. If the schema is pSTRING
HIGH…c/metadata/profiler/metrics/system/snowflake/system.py220Get query identifiers from the query text. If the schema is not provided in the query, we'll look for the table STRING
HIGH…/src/metadata/profiler/interface/profiler_interface.py124create class method is used to dispatch the profiler protocol to the correct object based on the service connectSTRING
HIGHingestion/src/metadata/profiler/processor/core.py195Check if the profile data are empty. if empty then raise else return Args: profile (CreateTableProfSTRING
HIGHingestion/src/metadata/profiler/adaptors/factory.py54 Create a client instance of the type of the given source client. Args: interface_type (strSTRING
HIGH…on/src/metadata/profiler/orm/functions/unique_count.py38 Get dialect-specific expressions for unique count computation. This centralizes all dialect-specific logic forSTRING
Redundant / Tautological Comments85 hits · 132 pts
SeverityFileLineSnippetContext
LOWgenerate_ts.sh25# Check if a file path is providedCOMMENT
LOWingestion/noxfile.py31 # Check if we are in GitHub Actions (i.e., if the 'PYTHON_VERSIONS' environment variable is set)COMMENT
LOW…tion/tests/unit/topology/database/test_athena_utils.py51 # Check if this is a non-current Iceberg columnCOMMENT
LOWingestion/tests/unit/topology/database/test_glue.py258 # Check if this is a non-current Iceberg columnCOMMENT
LOW…nit/topology/dashboard/test_looker_standalone_views.py126 # Check if this is the last exploreCOMMENT
LOW…/utils/dependency_injector/test_dependency_injector.py256 # Increment counterCOMMENT
LOW…on/src/airflow_provider_openmetadata/lineage/status.py83 # Check if we already have a pipelineStatus forCOMMENT
LOW…airflow_provider_openmetadata/lineage/config/loader.py52 # Check if value is a literal string `true`COMMENT
LOW…estion/src/metadata/pii/scanners/custom_ner_scanner.py161 # Check if confidence meets thresholdCOMMENT
LOW…ion/src/metadata/ingestion/ometa/mixins/patch_mixin.py838 # Check if domains are already the same, skip if identicalCOMMENT
LOW…/src/metadata/ingestion/source/database/sample_data.py875 # Check if service already existsCOMMENT
LOW…c/metadata/ingestion/source/database/lineage_source.py224 # Check if the process has timed outCOMMENT
LOW…rc/metadata/ingestion/source/database/glue/metadata.py424 # Check if this is an Iceberg tableCOMMENT
LOW…rc/metadata/ingestion/source/database/glue/metadata.py453 # Check if this is a non-current Iceberg columnCOMMENT
LOW…rc/metadata/ingestion/source/database/glue/metadata.py470 # Check if this is a non-current Iceberg columnCOMMENT
LOW…ata/ingestion/source/database/unitycatalog/metadata.py717 # Check if the referred table exists in OpenMetadata before adding constraintCOMMENT
LOW…src/metadata/ingestion/source/database/dbt/metadata.py524 # Check if conversion failed (converted_value is None)COMMENT
LOW…rc/metadata/ingestion/source/database/dbt/dbt_utils.py192 # Check if columns match exactlyCOMMENT
LOW…etadata/ingestion/source/database/databricks/client.py192 # Check if queries executed successfully by fetching resultsCOMMENT
LOW…etadata/ingestion/source/database/bigquery/metadata.py231 # Check if the engine is established before setting project IDsCOMMENT
LOW…ource/database/redshift/incremental_table_processor.py149 # Check if Schema is presentCOMMENT
LOW…data/ingestion/source/database/saphana/cdata_parser.py415 # Check if we've already processed this nodeCOMMENT
LOW…src/metadata/ingestion/source/database/athena/utils.py168 # Check if this is an Iceberg tableCOMMENT
LOW…src/metadata/ingestion/source/database/athena/utils.py197 # Check if this is a non-current Iceberg columnCOMMENT
LOW…ta/ingestion/source/pipeline/airflow/lineage_parser.py276 # Check if we can properly build the OMEntity classCOMMENT
LOW…tadata/ingestion/source/pipeline/airflow/api/client.py72 # Check if this is MWAA (AWS credentials)COMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py914 # Check if source is a view/table that reads from S3COMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py376 # Check if it's a Databricks or Unity Catalog serviceCOMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py796 # Check if we have anything to processCOMMENT
LOW…ion/source/pipeline/databrickspipeline/kafka_parser.py410 # Check if it reads from KafkaCOMMENT
LOW…ion/source/pipeline/databrickspipeline/kafka_parser.py422 # Check if it reads from S3COMMENT
LOW…ion/source/pipeline/databrickspipeline/kafka_parser.py472 # Check if snapshot table is builtCOMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py259 # Check if any broker hostname matchesCOMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py764 # Check if this is a Debezium CDC envelope structureCOMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py776 # Check if schemaText has CDC envelope fieldsCOMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py1637 # Check if this is a container dataset (storage sink)COMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py1665 # Check if we have any topics to processCOMMENT
LOW…adata/ingestion/source/pipeline/kafkaconnect/client.py67 # Check if topic starts with the server name prefixCOMMENT
LOW…adata/ingestion/source/pipeline/kafkaconnect/client.py82 # Check if topic exactly matches server name (edge case)COMMENT
LOW…adata/ingestion/source/pipeline/kafkaconnect/client.py329 # Check if this is Confluent Cloud format (array of {config, value})COMMENT
LOW…n/src/metadata/ingestion/source/storage/s3/metadata.py834 # Check if custom console endpoint URL is configured (for external S3-compatible storage)COMMENT
LOW…n/src/metadata/ingestion/source/storage/s3/metadata.py858 # Check if custom console endpoint URL is configured (for external S3-compatible storage)COMMENT
LOW…/src/metadata/ingestion/source/storage/gcs/metadata.py135 # Check if we have entries in the manifest file belonging to this bucketCOMMENT
LOW…metadata/ingestion/source/dashboard/looker/metadata.py532 # Check if filteredCOMMENT
LOW…adata/ingestion/source/dashboard/looker/bulk_parser.py100 # Check if any suffix is in our extension listCOMMENT
LOW…c/metadata/ingestion/source/dashboard/looker/parser.py162 # Check if any suffix is in our extension listCOMMENT
LOW…rc/metadata/ingestion/source/dashboard/hex/metadata.py255 # Check if we have lineage data for this projectCOMMENT
LOW…/src/metadata/ingestion/source/dashboard/hex/client.py63 # Check if we got a successful response with dataCOMMENT
LOW…/metadata/ingestion/source/dashboard/grafana/client.py111 # Check if we need to fetch more pagesCOMMENT
LOW…/metadata/ingestion/source/dashboard/grafana/client.py148 # Check if we need to fetch more pagesCOMMENT
LOW…etadata/ingestion/source/dashboard/powerbi/metadata.py1192 # Check if source expression references a dataset expressionCOMMENT
LOW…etadata/ingestion/source/dashboard/powerbi/metadata.py1213 # Check if this is a direct BigQuery connectionCOMMENT
LOW…etadata/ingestion/source/dashboard/powerbi/metadata.py1373 # Check if schema has a parent (database)COMMENT
LOW…ion/src/metadata/ingestion/source/api/rest/metadata.py417 # Check if type exists in DataTypeTopic enumCOMMENT
LOW…etadata/ingestion/source/drive/googledrive/metadata.py462 # Check if parent directory was included (if it has a parent)COMMENT
LOW…etadata/ingestion/source/drive/googledrive/metadata.py548 # Check if parent directory actually exists in OpenMetadataCOMMENT
LOW…gestion/src/metadata/ingestion/connections/builders.py189 # Check if IamAuth exists - specific to Mysql and Postgres connection.COMMENT
LOWingestion/src/metadata/ingestion/lineage/parser.py234 # Check if involved_tables is presentCOMMENT
LOWingestion/src/metadata/utils/fqn.py432 # Check if parent_container already starts with service_nameCOMMENT
LOWingestion/src/metadata/utils/fqn.py899 # Check if parent_container already starts with service_nameCOMMENT
25 more matches not shown…
Modern Structural Boilerplate91 hits · 95 pts
SeverityFileLineSnippetContext
LOW…on/tests/cli_e2e/test_cli_bigquery_multiple_project.py61 def update_table_row(self) -> None:STRING
LOWingestion/tests/cli_e2e/test_cli_redshift.py111 def update_table_row(self) -> None:STRING
LOWingestion/tests/cli_e2e/test_cli_bigquery.py94 def update_table_row(self) -> None:STRING
LOWingestion/tests/cli_e2e/test_cli_snowflake.py172 def update_table_row(self) -> None:STRING
LOWingestion/tests/cli_e2e/base/test_cli_db.py432 def update_table_row() -> None:CODE
LOWingestion/tests/cli_e2e/base/test_cli.py77 def set_ingestion_bot_jwt_token(cls) -> None:CODE
LOWingestion/tests/integration/conftest.py222logger = logging.getLogger(__name__)CODE
LOWingestion/tests/integration/ometa/conftest.py62logger = logging.getLogger(__name__)CODE
LOW…assification/databases/test_azuresql_temporal_table.py104logger = logging.getLogger(__name__)CODE
LOW…ation/auto_classification/messaging/test_kafka_sasl.py55logger = logging.getLogger(__name__)CODE
LOW…ests/integration/orm_profiler/test_orm_profiler_e2e.py52logger = logging.getLogger(__name__)CODE
LOWingestion/tests/integration/data_quality/conftest.py27__all__ = [CODE
LOWingestion/tests/load/test_resources/all_resources.py13logger = logging.getLogger(__name__)CODE
LOW…estion/src/_openmetadata_testutils/helpers/__init__.py3__all__ = ["xfail_param"]CODE
LOW…on/src/airflow_provider_openmetadata/lineage/runner.py25logger = logging.getLogger(__name__)CODE
LOW…/src/airflow_provider_openmetadata/lineage/operator.py23logger = logging.getLogger(__name__)CODE
LOWingestion/src/metadata/pii/algorithms/presidio_utils.py141def set_presidio_logger_level(log_level: int | str = logging.ERROR) -> None:CODE
LOW…stion/src/metadata/ingestion/ometa/mixins/csv_mixin.py17logger = logging.getLogger(__name__)CODE
LOWingestion/src/metadata/ingestion/progress/registry.py147 def set_total(self, type_: str, total: Optional[int]) -> None: # noqa: UP045CODE
LOWingestion/src/metadata/ingestion/progress/registry.py154 def set_reconcilable(self, type_: str) -> None:CODE
LOWingestion/src/metadata/ingestion/progress/__init__.py51__all__ = [CODE
LOWingestion/src/metadata/ingestion/progress/modes.py45 def set_total(self, entity_type: str, total: Optional[int]) -> None: # noqa: UP045CODE
LOW…etadata/ingestion/source/database/sqlalchemy_source.py54 def set_inspector(self, database_name: str) -> None:CODE
LOW…metadata/ingestion/source/database/common_db_source.py155 def set_inspector(self, database_name: str) -> None:CODE
LOW…/metadata/ingestion/source/database/presto/metadata.py131 def set_inspector(self, database_name: str) -> None:CODE
LOW…etadata/ingestion/source/database/bigtable/metadata.py179 def _set_nested(dct: dict, keys: List[str], value: any) -> None: # noqa: UP006CODE
LOW…ata/ingestion/source/database/unitycatalog/metadata.py338 def _set_incremental_table_processor(self, catalog: str) -> None:CODE
LOW…e/database/unitycatalog/incremental_table_processor.py56 def set_table_map(self, catalog: str, start_timestamp: int) -> None:CODE
LOW…c/metadata/ingestion/source/database/trino/metadata.py347 def set_inspector(self, database_name: str) -> None:CODE
LOW…metadata/ingestion/source/database/trino/connection.py237 def set_basic_auth(connection: TrinoConnectionConfig, connection_args: ConnectionArguments) -> None:CODE
LOW…metadata/ingestion/source/database/trino/connection.py265 def set_jwt_auth(connection: TrinoConnectionConfig, connection_args: ConnectionArguments) -> None:CODE
LOW…metadata/ingestion/source/database/trino/connection.py288 def set_azure_auth(connection: TrinoConnectionConfig, connection_args: ConnectionArguments) -> None:CODE
LOW…metadata/ingestion/source/database/trino/connection.py308 def set_oauth2_auth(connection: TrinoConnectionConfig, connection_args: ConnectionArguments) -> None:CODE
LOW…tadata/ingestion/source/database/timescale/__init__.py3__all__ = ["TimescaleSource"]CODE
LOW…adata/ingestion/source/database/databricks/metadata.py886 def set_inspector(self, database_name: str) -> None:CODE
LOW…ta/ingestion/source/database/snowflake/query_parser.py88 def set_session_query_tag(self) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py330 def set_partition_details(self) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py337 def set_schema_description_map(self) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py343 def set_database_description_map(self) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py350 def set_external_location_map(self, database_name: str) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py358 def set_schema_tags_map(self, database_name: str) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py311 def set_session_query_tag(self) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py389 def set_database_tags_map(self, database_name: str) -> None:CODE
LOW…etadata/ingestion/source/database/redshift/metadata.py275 def set_external_location_map(self, database_name: str) -> None:CODE
LOW…etadata/ingestion/source/database/postgres/metadata.py151 def set_schema_description_map(self) -> None:CODE
LOW…/database/hive/metastore_dialects/postgres/__init__.py20__all__ = ["HivePostgresMetaStoreDialect"]CODE
LOW…rce/database/hive/metastore_dialects/mysql/__init__.py20__all__ = ["HiveMysqlMetaStoreDialect"]CODE
LOW…tadata/ingestion/source/database/cockroach/metadata.py106 def set_schema_description_map(self) -> None:CODE
LOW…metadata/ingestion/source/database/vertica/metadata.py283 def set_schema_description_map(self) -> None:CODE
LOW…c/metadata/ingestion/source/database/mssql/metadata.py128 def set_schema_description_map(self) -> None:CODE
LOW…c/metadata/ingestion/source/database/mssql/metadata.py134 def set_database_description_map(self) -> None:CODE
LOW…c/metadata/ingestion/source/database/mssql/metadata.py140 def set_stored_procedure_description_map(self) -> None:CODE
LOW…/metadata/ingestion/source/database/iomete/metadata.py54 def set_inspector(self, database_name: str) -> None:CODE
LOW…on/src/metadata/ingestion/source/mcp/mcp/connection.py21__all__ = ["get_connection", "test_connection"]CODE
LOW…/ingestion/source/dashboard/powerbi/workspace_state.py121 def set_filtered_datamodels(self, datamodels: list[DataModelLike]) -> None:CODE
LOWingestion/src/metadata/ingestion/models/topology.py202 def update_context_name(self, stage: NodeStage, right: C) -> None:CODE
LOWingestion/src/metadata/ingestion/models/topology.py217 def update_context_value(self, stage: NodeStage, value: Any) -> None:CODE
LOW…/metadata/ingestion/connections/strategies/__init__.py19__all__ = ["ClientStrategy", "BasicAuthStrategy", "AzureAdStrategy"]CODE
LOWingestion/src/metadata/ingestion/diagnostics/kernel.py37def set_handler(handler: DiagnosticsHandler | None) -> None:CODE
LOW…/metadata/core/connections/test_connection/__init__.py36__all__ = [CODE
31 more matches not shown…
AI Slop Vocabulary32 hits · 66 pts
SeverityFileLineSnippetContext
MEDIUMingestion/tests/unit/test_dbt_ingest.py252 """Test comprehensive URL validation scenarios including valid and invalid URLs"""STRING
MEDIUMingestion/tests/unit/test_dbt_ingest.py512 """Integration test using actual test resources with comprehensive validation"""STRING
MEDIUMingestion/tests/unit/test_dbt.py1962 # New comprehensive tests for custom property validationCOMMENT
MEDIUMingestion/tests/unit/models/test_custom_pydantic.py265# Additional comprehensive tests for enhanced functionalityCOMMENT
MEDIUMingestion/tests/unit/models/test_custom_pydantic.py384 # Test with comprehensive table propertiesCOMMENT
MEDIUMingestion/tests/unit/models/test_custom_pydantic.py267 """Extended test suite for comprehensive validation of custom Pydantic functionality."""STRING
MEDIUMingestion/tests/unit/models/test_custom_pydantic.py422 """Test comprehensive DashboardDataModel scenarios."""STRING
MEDIUMingestion/tests/unit/models/test_custom_pydantic.py451 """Test comprehensive CreateRequest scenarios."""STRING
MEDIUMingestion/tests/unit/models/test_custom_pydantic.py638 """Test comprehensive table constraints scenarios."""STRING
MEDIUM…ts/unit/lineage/queries/test_complex_query_patterns.py2373 """Test 5-level star schema joins with comprehensive column lineage"""STRING
MEDIUM…ts/unit/lineage/queries/test_complex_query_patterns.py4056 """Test 3-branch UNION ALL with comprehensive column mapping"""STRING
MEDIUM…ts/unit/lineage/queries/test_complex_query_patterns.py4932 """Test UNION with subqueries and joins - comprehensive lineage"""STRING
MEDIUMingestion/tests/cli_e2e/test_cli_tableau.py209 """Test comprehensive metadata ingestion validation - runs after base ingestion"""STRING
MEDIUMingestion/tests/cli_e2e/test_cli_tableau.py224 """Test comprehensive lineage validation - Enable actual lineage testing"""STRING
MEDIUM…sts/integration/airflow/test_airflow_api_connection.py549 """Test comprehensive DAG metadata extraction with Airflow 3.x data."""STRING
MEDIUM…etadata/ingestion/source/database/bigquery/metadata.py239 # Upon invoking the set_project_id method, we retrieve a comprehensiveCOMMENT
LOW…metadata/ingestion/source/database/snowflake/models.py77 # If removing the () leaves us with nothing, then just return the parenthesisCOMMENT
LOW…metadata/ingestion/source/database/redshift/queries.py588# For now, we just use the number of queries as a placeholder until we figure outSTRING
MEDIUMingestion/src/metadata/ingestion/models/topology.py252 # We can leverage this to guarantee we keep track of the MainThread ID.COMMENT
MEDIUMingestion/src/metadata/ingestion/models/topology.py278 """Cleans the TopologyContext of a given thread in order to lower the Memory Profile."""STRING
LOWingestion/src/metadata/utils/uuid_encoder.py27 # if the obj is uuid, we simply return the value of uuidCOMMENT
MEDIUMingestion/src/metadata/utils/datalake/datalake_utils.py214 """A column parser object. This serves as a Creator class for the appropriate column parser object parserSTRING
MEDIUM…enmetadata/it/tests/AsyncSearchIndexConsistencyIT.java78 // write returns. We still poll with Awaitility to stay robust to Elasticsearch's own refreshCOMMENT
MEDIUM…va/org/openmetadata/playwright/ui/pages/TablePage.java17 // name testid is always present. We accept either so the locator is robust across both.COMMENT
MEDIUM…ations/template/handlebars/helpers/TextDiffHelper.java110 // Compute token diff with LCS (simple, robust, dependency-free)COMMENT
MEDIUM…/openmetadata/operator/controller/OMJobReconciler.java159 // Check if main pod already exists (using selectors for robust discovery)COMMENT
LOWscripts/reindex-perf-bootstrap.sh92 # Fallback: just use the admin JWT directly. It has all permissions in the dev profile.COMMENT
MEDIUM.github/workflows/java-playwright-nightly.yml92 # --- The search ITs / UIITs, their test harness, and the Maven profiles that run them ---COMMENT
MEDIUM…/src/main/resources/ui/playwright/utils/importUtils.ts1054 // one-shot CSS injection is more robust than polling at specific steps.COMMENT
MEDIUM…main/resources/ui/playwright/doc-generator/markdown.js179 // Add explicit anchor div to ensure robust linkingCOMMENT
MEDIUM…/src/main/resources/ui/src/utils/Export/ExportUtils.ts60// that contribute zero pixels is the highest-leverage optimizationCOMMENT
MEDIUM…maWidgets/ManifestJsonWidget/manifest-json-widget.less37 // flex item, so it collapses to its content (~1 line) when empty. AbsolutelyCOMMENT
Modern AI Meta-Vocabulary12 hits · 34 pts
SeverityFileLineSnippetContext
MEDIUMingestion/pyproject.toml342# scaffold below), these libraries stay silent — keeping focus on our ownCOMMENT
MEDIUMingestion/pyproject.toml347# ── Ratchet scaffold: enable subtree-by-subtree promotions later ────────COMMENT
MEDIUM…/utils/dependency_injector/test_dependency_injector.py33# Test classes for dependency injectionCOMMENT
MEDIUM…adata/utils/dependency_injector/dependency_injector.py30 # Use dependency injectionSTRING
MEDIUMingestion/src/metadata/cli/scaffold.py1631# Main scaffold orchestratorSTRING
MEDIUM.github/workflows/ui-checkstyle.yml306 # config, both of which silence the guardrails and neither of whichCOMMENT
MEDIUM.github/workflows/ui-checkstyle.yml347 [ "$ERRORS" -eq 0 ] || sed 's/\x1b\[[0-9;]*m//g' /tmp/pw-lint.json | grep -E '"ruleId"' | head -20 >> /tmp/pCODE
MEDIUM.github/workflows/ui-checkstyle.yml352 OUT=$(sed 's/\x1b\[[0-9;]*m//g' /tmp/pw-guardrails.out | grep -E 'error|Error|not ok|fail|stale' | head -30)CODE
MEDIUMskills/connector-building/GUIDE.md418### "Module not found" after scaffoldCOMMENT
MEDIUMskills/connector-building/examples/dashboard-rest.yaml2# Run: metadata scaffold-connector --name my_dashboard --service-type dashboard ...COMMENT
MEDIUM…s/connector-building/examples/database-sqlalchemy.yaml2# Run: metadata scaffold-connector --name clickhouse --service-type database ...COMMENT
MEDIUMskills/connector-building/examples/pipeline-sdk.yaml2# Run: metadata scaffold-connector --name prefect --service-type pipeline ...COMMENT
AI Structural Patterns24 hits · 22 pts
SeverityFileLineSnippetContext
LOWingestion/tests/unit/utils/test_memory_limit.py377CODE
LOWingestion/src/metadata/ingestion/ometa/client.py246CODE
LOW…tion/src/metadata/ingestion/ometa/mixins/task_mixin.py122CODE
LOW…/metadata/ingestion/ometa/mixins/conversation_mixin.py66CODE
LOW…/metadata/ingestion/ometa/mixins/announcement_mixin.py40CODE
LOW…/metadata/ingestion/source/database/snowflake/utils.py309CODE
LOW…/metadata/ingestion/source/database/snowflake/utils.py341CODE
LOW…/metadata/ingestion/source/database/snowflake/utils.py356CODE
LOW…/metadata/ingestion/source/database/snowflake/utils.py373CODE
LOW…/metadata/ingestion/source/database/snowflake/utils.py390CODE
LOW…gestion/source/database/hive/custom_hive_connection.py47CODE
LOW…etadata/ingestion/source/pipeline/openlineage/utils.py49CODE
LOW…metadata/ingestion/source/dashboard/superset/client.py219CODE
LOW…src/metadata/ingestion/source/metadata/atlas/client.py54CODE
LOW…stion/src/metadata/ingestion/models/custom_pydantic.py130CODE
LOWingestion/src/metadata/data_quality/runner/core.py39CODE
LOW…a_quality/validations/mixins/pandas_validator_mixin.py232CODE
LOWingestion/src/metadata/utils/time_utils.py69CODE
LOWingestion/src/metadata/utils/time_utils.py110CODE
LOW…ion/src/metadata/sdk/data_quality/tests/table_tests.py355CODE
LOWingestion/src/metadata/sdk/api/lineage.py321CODE
LOWingestion/src/metadata/sdk/api/lineage.py344CODE
LOWingestion/src/metadata/sdk/api/lineage.py405CODE
LOW…ow-apis/openmetadata_managed_apis/operations/deploy.py186CODE
Example Usage Blocks10 hits · 15 pts
SeverityFileLineSnippetContext
LOWdocker/development/docker-compose.redis.yml6# Usage:COMMENT
LOWdocker/development/docker-compose.multiserver.yml9# Usage:COMMENT
LOW…ker-compose-quickstart/docker-compose-fuseki-arm64.yml46# Usage:COMMENT
LOW…ompose-quickstart/docker-compose-fuseki-standalone.yml44# Usage:COMMENT
LOW…se-quickstart/docker-compose-opensearch-standalone.yml78# Usage:COMMENT
LOWbin/distributed-test/scripts/gc-reindex-report.sh4# Usage:COMMENT
LOWscripts/reindex-perf-bootstrap.sh10# Usage:COMMENT
LOW…sources/ui/scripts/ui-checkstyle-playwright-changed.sh16# Usage:COMMENT
LOW…src/main/resources/ui/scripts/ui-checkstyle-changed.sh16# Usage:COMMENT
LOW…src/main/resources/ui/scripts/ui-checkstyle-changed.sh16# Usage:COMMENT
Magic Placeholder Names3 hits · 15 pts
SeverityFileLineSnippetContext
HIGHopenmetadata-sdk/README.md30 .apiKey("your-api-key")CODE
HIGH…sources/ui/public/locales/en-US/Dashboard/Lightdash.md25Authorization: Bearer YOUR_API_KEYCODE
HIGH…sources/ui/public/locales/en-US/Dashboard/Lightdash.md27Replace `YOUR_API_KEY` with the actual key provided by your Lightdash instance.CODE
AI Response Leakage1 hit · 8 pts
SeverityFileLineSnippetContext
HIGH…estion/tests/unit/resources/dbt_ingest/dbt_project.yml29# In this example config, we tell dbt to build all models in the example/COMMENT
Synthetic Comment Markers1 hit · 8 pts
SeverityFileLineSnippetContext
HIGH…/org/openmetadata/service/search/SearchIndexUtils.java48 // Bots whose changes count as AI-generated. The agent-app bots are still listed becauseCOMMENT
Slop Phrases3 hits · 6 pts
SeverityFileLineSnippetContext
MEDIUM…ata-ui/src/main/resources/ui/src/utils/TagClassBase.ts247 description: 'This is a sample tag for demonstration purposes',CODE
MEDIUM…urces/ui/src/utils/DataProduct/DataProductClassBase.ts257 description: 'This is a sample data product for demonstration purposes',CODE
MEDIUM…main/resources/ui/src/stories/SlideoutMenu.stories.tsx86 defaultValue="A sample dataset for demonstration purposes."CODE
Overly Generic Function Names5 hits · 5 pts
SeverityFileLineSnippetContext
LOW…unit/topology/pipeline/test_databricks_kafka_parser.py400 def my_function():CODE
LOW…unit/topology/pipeline/test_databricks_kafka_parser.py441 def my_function():CODE
LOW…ts/unit/core/connections/test_connection/test_check.py40 def helper(self):CODE
LOWingestion/src/metadata/pii/scanners/ner_scanner.py128 def process_data(self, row: str, entities_score: Dict[str, StringAnalysis]) -> None: # noqa: UP006CODE
LOW…adata/utils/dependency_injector/dependency_injector.py98 def my_function(db: Inject[Database]):STRING
Cross-Language Confusion (JS/TS)1 hit · 5 pts
SeverityFileLineSnippetContext
HIGH…resources/ui/playwright/e2e/Pages/TaskComments.spec.ts280 print("Hello, World!")CODE
Dead Code2 hits · 4 pts
SeverityFileLineSnippetContext
MEDIUMingestion/tests/unit/topology/dashboard/test_ssrs.py554CODE
MEDIUMingestion/tests/unit/sdk/test_base_entity.py146CODE
TODO Padding1 hit · 2 pts
SeverityFileLineSnippetContext
LOW…ywright/e2e/Features/TestSuitePipelineRedeploy.spec.ts79 // TODO: Add test to verify the re-deployed pipelines for Database, Dashboard and other entitiesCOMMENT