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.2 Low AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of open-metadata/OpenMetadata, a TypeScript project with 14,471 GitHub stars. SynthScan v2.0 examined 2,998,684 lines of code across 13360 source files, recording 14638 pattern matches distributed across 27 syntactic categories. The overall adjusted score of 10.2 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.2
Adjusted Score
10.2
Raw Score
100%
Time Factor
2026-07-14
Last Push
14.5K
Stars
TypeScript
Language
3.0M
Lines of Code
13.4K
Files
14.6K
Pattern Hits
2026-07-14
Scan Date
0.15
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 1124HIGH 850MEDIUM 865LOW 11799

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 14638 distinct pattern matches across 27 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.

Hallucination Indicators1124 hits · 11656 pts
SeverityFileLineSnippetContext
CRITICAL…main/java/org/openmetadata/schema/utils/JsonUtils.java492 com.github.fge.jsonpatch.JsonPatch.fromJson(patchNode);CODE
CRITICALingestion/tests/unit/test_ssl_manager.py115 kafka_source_with_ssl.service_connection.schemaRegistrySSL.root.caCertificate.get_secret_value(),CODE
CRITICALingestion/tests/unit/test_ssl_manager.py119 kafka_source_with_ssl.service_connection.schemaRegistrySSL.root.sslKey.get_secret_value(),CODE
CRITICALingestion/tests/unit/test_ssl_manager.py123 kafka_source_with_ssl.service_connection.schemaRegistrySSL.root.sslCertificate.get_secret_value(),CODE
CRITICALingestion/tests/unit/test_ssl_manager.py192 cassandra_source_with_ssl.service_connection.sslConfig.root.caCertificate.get_secret_value(),CODE
CRITICALingestion/tests/unit/test_ssl_manager.py196 cassandra_source_with_ssl.service_connection.sslConfig.root.sslKey.get_secret_value(),CODE
CRITICALingestion/tests/unit/test_ssl_manager.py200 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.py37from metadata.utils.helpers import datetime_to_tsCODE
CRITICALingestion/tests/unit/topology/dashboard/test_tableau.py521 self.tableau.config.serviceConnection.root.config.sslConfig.root.sslCertificate.get_secret_value(),CODE
CRITICALingestion/tests/unit/topology/dashboard/test_tableau.py525 self.tableau.config.serviceConnection.root.config.sslConfig.root.sslKey.get_secret_value(),CODE
CRITICALingestion/tests/unit/topology/dashboard/test_tableau.py529 self.tableau.config.serviceConnection.root.config.sslConfig.root.caCertificate.get_secret_value(),CODE
CRITICALingestion/tests/unit/topology/dashboard/test_tableau.py547 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.py110 "type": db_service.connection.config.type.value.lower(),CODE
CRITICALingestion/tests/integration/conftest.py133 "type": db_service.connection.config.type.value.lower(),CODE
CRITICALingestion/tests/integration/conftest.py332 "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.py71 "type": db_service.connection.config.type.value.lower(),CODE
CRITICAL…sification/databases/test_global_sample_data_config.py116 "type": db_service.connection.config.type.value.lower(),CODE
CRITICAL…on/auto_classification/databases/test_tag_processor.py58 "type": db_service.connection.config.type.value.lower(),CODE
CRITICAL…on/auto_classification/databases/test_tag_processor.py100 "type": db_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.py176 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.py34from metadata.utils.helpers import clean_up_starting_ending_double_quotes_in_stringCODE
CRITICAL…/src/metadata/ingestion/source/database/sample_data.py191from metadata.utils.helpers import get_standard_chart_typeCODE
CRITICAL…metadata/ingestion/source/database/common_db_source.py73from 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.py57from 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.py102from metadata.utils.helpers import retry_with_docker_hostCODE
CRITICAL…data/ingestion/source/database/unitycatalog/lineage.py55from metadata.utils.helpers import retry_with_docker_hostCODE
CRITICAL…c/metadata/ingestion/source/database/dbt/dbt_config.py649 from azure.core.exceptions import AzureError, ClientAuthenticationError # noqa: PLC0415CODE
CRITICAL…c/metadata/ingestion/source/database/dbt/dbt_config.py54from metadata.utils.helpers import clean_uriCODE
CRITICAL…/metadata/ingestion/source/database/saperp/metadata.py58from metadata.utils.helpers import clean_up_starting_ending_double_quotes_in_stringCODE
CRITICAL…rc/metadata/ingestion/source/database/saperp/client.py31from metadata.utils.helpers import clean_uriCODE
CRITICAL…ta/ingestion/source/database/timescale/query_parser.py37from metadata.utils.helpers import get_start_and_endCODE
CRITICAL…c/metadata/ingestion/source/database/oracle/lineage.py44from metadata.utils.helpers import get_start_and_endCODE
CRITICAL…etadata/ingestion/source/database/databricks/client.py50from metadata.utils.helpers import datetime_to_tsCODE
1064 more matches not shown…
Hyper-Verbose Identifiers7727 hits · 7726 pts
SeverityFileLineSnippetContext
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.py99 def test_check_datatype_support(self):CODE
LOWingestion/tests/unit/test_column_type_parser.py137def test_superset_parse_array_data_type():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/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.py154 def test_render_query_headers_builds_the_right_string(self) -> None:CODE
LOWingestion/tests/unit/test_ometa_utils.py157 def test_build_entity_reference(self) -> None:CODE
LOWingestion/tests/unit/test_ometa_utils.py163 def test_decode_jwt_token_valid(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py187 def test_decode_jwt_token_with_padding(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py243 def test_decode_jwt_token_none_input(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py248 def test_decode_jwt_token_empty_string(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py253 def test_decode_jwt_token_real_world_example(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py103 def test_get_entity_type_camel_case_consistency(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py203 def test_decode_jwt_token_invalid_format(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py221 def test_decode_jwt_token_invalid_json(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py232 def test_decode_jwt_token_empty_payload(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py276 def test_get_entity_hierarchy_returns_dict(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py283 def test_get_entity_hierarchy_caching(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py294 def test_get_entity_hierarchy_database_service_order(self):CODE
LOWingestion/tests/unit/test_ometa_utils.py317 def test_get_entity_hierarchy_messaging_service_order(self):CODE
7667 more matches not shown…
Cross-File Repetition688 hits · 3440 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…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
HIGHingestion/tests/cli_e2e/test_cli_oracle.py03. delete the new table + deploy marking tables as deleted we will perform the following steps: 1. delete table created STRING
HIGH…on/tests/cli_e2e/test_cli_bigquery_multiple_project.py03. delete the new table + deploy marking tables as deleted we will perform the following steps: 1. delete table created STRING
HIGHingestion/tests/cli_e2e/base/test_cli_db.py03. delete the new table + deploy marking tables as deleted we will perform the following steps: 1. delete table created STRING
HIGHingestion/tests/cli_e2e/test_cli_oracle.py05. vanilla ingestion + exclude schema filter pattern we will perform the following steps: 1. build config file for ingesSTRING
HIGH…on/tests/cli_e2e/test_cli_bigquery_multiple_project.py05. vanilla ingestion + exclude schema filter pattern we will perform the following steps: 1. build config file for ingesSTRING
HIGHingestion/tests/cli_e2e/base/test_cli_db.py05. vanilla ingestion + exclude schema filter pattern we will perform the following steps: 1. build config file for ingesSTRING
628 more matches not shown…
Decorative Section Separators624 hits · 2040 pts
SeverityFileLineSnippetContext
MEDIUMingestion/pyproject.toml118# ─── Selected rule families ──────────────────────────────────────────────COMMENT
MEDIUMingestion/pyproject.toml155# ─── Ignores: justify EVERY one ──────────────────────────────────────────COMMENT
MEDIUMingestion/pyproject.toml288# ── Real-bug catchers held to error ──────────────────────────────────────COMMENT
MEDIUMingestion/pyproject.toml302# ── Cheap promotions: real-bug rules that fire rarely ────────────────────COMMENT
MEDIUMingestion/pyproject.toml307# ── Stub-gap noise: explicitly off (matches `standard` defaults) ─────────COMMENT
MEDIUMingestion/pyproject.toml320# ── Project-specific waivers ─────────────────────────────────────────────COMMENT
MEDIUMingestion/pyproject.toml343# ── 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.py182# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/noxfile.py184# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/noxfile.py240# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/noxfile.py242# ---------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_status.py34 # ── as_string ────────────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/test_status.py89 # ── failed / fail_all ────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/test_status.py104 # ── calculate_success ────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/test_status.py128 # ── warning / filter ─────────────────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/test_status.py138 # ── truncation of stack traces ───────────────────────────────────COMMENT
MEDIUMingestion/tests/unit/test_query_parser.py418 # -------------------------------------------------------------------------COMMENT
MEDIUMingestion/tests/unit/test_query_parser.py420 # -------------------------------------------------------------------------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
MEDIUM…logy/database/test_snowflake_access_history_lineage.py44# ---------------------------------------------------------------------------COMMENT
564 more matches not shown…
Excessive Try-Catch Wrapping1766 hits · 1756 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.py94except 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…/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
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
MEDIUM…ion/tests/unit/metadata/utils/test_progress_tracker.py211def increment_many():CODE
LOW…ion/tests/unit/metadata/utils/test_progress_tracker.py215 except Exception as e:CODE
LOWingestion/tests/cli_e2e/test_cli_oracle.py77 except Exception:STRING
LOWingestion/tests/cli_e2e/test_cli_oracle.py83 except Exception:STRING
LOWingestion/tests/cli_e2e/base/test_cli.py122 except Exception as exc:CODE
1706 more matches not shown…
Cross-Language Confusion122 hits · 623 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.py148 {"name":"John","age":16,"sex":"M","address":null},CODE
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.py100 "deferring_job_definition_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py101 "deferring_environment_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py103 "lifecycle_webhooks_url": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py200 "should_start_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py201 "trigger": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py202 "job": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py203 "environment": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py236 "git_branch": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py237 "git_sha": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py238 "status_message": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py239 "owner_thread_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py240 "executed_by_thread_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py241 "deferring_run_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py243 "artifact_s3_path": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py252 "dequeued_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py253 "started_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py254 "finished_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py255 "last_checked_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py256 "last_heartbeat_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py257 "should_start_at": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py258 "trigger": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py259 "job": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py260 "environment": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py88 "dbt_version": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py89 "raw_dbt_version": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py137 "job_completion_trigger_condition": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py140 "next_run": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py184 "owner_thread_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py186 "deferring_run_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py219 "retrying_run_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py223 "is_running": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py276 "retrying_run_id": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py280 "is_running": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py315 "rawSql": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py330 "rawSql": null,STRING
HIGHingestion/tests/unit/topology/pipeline/test_dbtcloud.py345 "rawSql": null,STRING
HIGH…stion/tests/unit/topology/pipeline/test_openlineage.py812 """Missing, null, or wrongly typed facet shapes yield an empty list."""STRING
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py115 Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [Catalog="DEMO_CATALOG", DatCODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py121 [Catalog="DEMO_CATALOG", Database=null, EnableAutomaticProxyDiscovery=null])CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py123 "select * from PUBLIC.STG_CUSTOMERS", null, [EnableFolding=true])CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py130 Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [ Catalog= "DEMO_CATALOGCODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py137 Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [Catalog="DEMO_CATALOG", DatCODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py142 Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [Catalog="DEMO_CATALOG", DatCODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py174 "null, [EnableFolding=true])\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py195 "null, [EnableFolding=true])\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py219 "null, [EnableFolding=true])\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py242 "null, [EnableFolding=true]),\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py262 "null, [EnableFolding=true]),\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py314 "null, [EnableFolding=true]),\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py509 "null, [EnableFolding=true])\n"CODE
HIGHingestion/tests/unit/topology/dashboard/test_powerbi.py749 test_snowflaek_query_expression = 'let\n Source = Value.NativeQuery(Snowflake.Databases("dummy_host",(WarehouCODE
62 more matches not shown…
Structural Annotation Overuse347 hits · 514 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.py450 # Step 1: Check if property exists in OpenMetadataCOMMENT
LOW…src/metadata/ingestion/source/database/dbt/metadata.py466 # Step 2: Validate and convert value (single pass)COMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py896 # Step 2: Create table-to-table lineage for downstream dependenciesCOMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py814 # 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.java4128 // Step 1: Ingestion creates entities (no tags)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4133 // Step 2: User adds tags to entities via PATCHCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4151 // Step 3: Ingestion re-runs — bulk update with only description changes (no tags in request)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4158 // Step 4: Verify tags are still present after re-ingestionCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4178 // Step 1: Ingestion creates entities (no owners)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4183 // Step 2: User adds owners via PATCHCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4194 // Step 3: Re-ingestion with only description changesCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4201 // Step 4: Verify owners preservedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3060 // Step 1: Create a dedicated glossary for this test to avoid interferenceCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3067 // Step 2: Create two terms - both should start as APPROVED (default status when no reviewers)COMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3084 // Step 3: Update the second term to IN_REVIEW statusCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3089 // Step 4: Search without entityStatus filter - both terms should be returnedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3106 // Step 5: Search with APPROVED status - only the first term should be returnedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3128 // Step 6: Search with IN_REVIEW status - only the second term should be returnedCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1688 // Step 1: Get the existing Certification classification (seeded by the system)COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1693 // Step 2: Create a new tag under CertificationCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1703 // Step 3: Create the DB hierarchy and a DatabaseSchemaCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1710 // Step 4: Apply the certification tag to the DatabaseSchema via setCertification()COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1769 // Step 6: Rename the certification tag (change its name — this changes the FQN)COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1777 // Step 7: Wait until certification tagFQN propagates to the entityCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1734 // Step 5: Verify search finds the schema by the original tag FQNCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1800 // Step 8: Search must find the schema under the new tag FQNCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1836 // 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.java70 // Step 1: Create a policy that allows VIEW_ALL on entities with PII.Sensitive tagCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java87 // Step 2: Create a role with that policyCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java96 // Step 3: Create a team with that role as defaultCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java106 // Step 4: Create a user in that teamCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java120 // Step 5: Create database service and schema using factoriesCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java128 // Step 6: Create a table WITH the PII.Sensitive tag using fluent APICOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java149 // Step 7: Create a query that references the table (query does NOT have the tag)COMMENT
287 more matches not shown…
Self-Referential Comments152 hits · 493 pts
SeverityFileLineSnippetContext
MEDIUMingestion/tests/unit/test_ometa_utils.py165 # Create a mock JWT payloadCOMMENT
MEDIUMingestion/tests/unit/test_ometa_utils.py177 # Create a mock JWT token (header.payload.signature)COMMENT
MEDIUMingestion/tests/unit/test_ometa_utils.py189 # Create a payload that will need paddingCOMMENT
MEDIUMingestion/tests/unit/test_dbt.py812 # Create a mock manifest node with list of ownersCOMMENT
MEDIUMingestion/tests/unit/test_dbt.py829 # Create a mock manifest node with list of ownersCOMMENT
MEDIUMingestion/tests/unit/test_dbt.py736 # Create a mock manifest node with openmetadata.ownerCOMMENT
MEDIUMingestion/tests/unit/test_dbt.py752 # Create a mock manifest node with old format ownerCOMMENT
MEDIUMingestion/tests/unit/test_dbt.py2285 # 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.py773 # 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.py138# Create a mock search service. Adjust the serviceType if you have a dedicated type for OpenSearch.COMMENT
MEDIUMingestion/tests/unit/topology/dashboard/test_looker.py694 # 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.py730 # 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
92 more matches not shown…
Deep Nesting544 hits · 449 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.py2211CODE
LOWingestion/tests/unit/test_dbt.py2281CODE
LOWingestion/tests/unit/test_dbt.py2513CODE
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.py769CODE
LOWingestion/tests/unit/topology/pipeline/test_dbtcloud.py2044CODE
LOWingestion/tests/unit/topology/pipeline/test_dbtcloud.py2136CODE
LOWingestion/tests/unit/topology/pipeline/test_dbtcloud.py2286CODE
LOWingestion/tests/unit/topology/pipeline/test_dbtcloud.py822CODE
LOWingestion/tests/unit/topology/pipeline/test_dbtcloud.py2208CODE
LOWingestion/tests/unit/topology/pipeline/test_dbtcloud.py2340CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py270CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py399CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py313CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py361CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py448CODE
LOW…sts/unit/topology/pipeline/test_databricks_pipeline.py494CODE
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
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.py308CODE
LOWingestion/tests/cli_e2e/test_cli_tableau.py361CODE
LOWingestion/tests/cli_e2e/test_cli_tableau.py388CODE
LOWingestion/tests/cli_e2e/test_cli_tableau.py496CODE
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.py610CODE
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
LOW…/tests/integration/powerbi/test_powerbi_file_client.py82CODE
LOW…/tests/integration/sources/mlmodels/mlflow/conftest.py77CODE
LOW…sts/integration/sources/mlmodels/mlflow/test_mlflow.py70CODE
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
484 more matches not shown…
Over-Commented Block449 hits · 437 pts
SeverityFileLineSnippetContext
LOWgenerate_ts.sh1#!/bin/bashCOMMENT
LOWingestion/airflow-constraints-3.2.1.txt1COMMENT
LOWingestion/airflow-constraints-3.2.1.txt21#COMMENT
LOWingestion/pyproject.toml341allowedUntypedLibraries = []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_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
LOWingestion/tests/unit/topology/pipeline/test_dbtcloud.py2381COMMENT
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…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
LOWingestion/tests/unit/source/dashboard/hex/__init__.py1# Copyright 2025 CollateCOMMENT
LOWingestion/tests/unit/source/dashboard/mode/__init__.py1# Copyright 2025 CollateCOMMENT
389 more matches not shown…
Verbosity Indicators264 hits · 390 pts
SeverityFileLineSnippetContext
LOW…src/metadata/ingestion/source/database/dbt/metadata.py450 # Step 1: Check if property exists in OpenMetadataCOMMENT
LOW…src/metadata/ingestion/source/database/dbt/metadata.py466 # Step 2: Validate and convert value (single pass)COMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py896 # Step 2: Create table-to-table lineage for downstream dependenciesCOMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py814 # 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.java4128 // Step 1: Ingestion creates entities (no tags)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4133 // Step 2: User adds tags to entities via PATCHCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4151 // Step 3: Ingestion re-runs — bulk update with only description changes (no tags in request)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4158 // Step 4: Verify tags are still present after re-ingestionCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4178 // Step 1: Ingestion creates entities (no owners)COMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4183 // Step 2: User adds owners via PATCHCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4194 // Step 3: Re-ingestion with only description changesCOMMENT
LOW…/test/java/org/openmetadata/it/tests/BaseEntityIT.java4201 // Step 4: Verify owners preservedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3060 // Step 1: Create a dedicated glossary for this test to avoid interferenceCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3067 // Step 2: Create two terms - both should start as APPROVED (default status when no reviewers)COMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3084 // Step 3: Update the second term to IN_REVIEW statusCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3089 // Step 4: Search without entityStatus filter - both terms should be returnedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3106 // Step 5: Search with APPROVED status - only the first term should be returnedCOMMENT
LOW…/org/openmetadata/it/tests/GlossaryTermResourceIT.java3128 // Step 6: Search with IN_REVIEW status - only the second term should be returnedCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1688 // Step 1: Get the existing Certification classification (seeded by the system)COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1693 // Step 2: Create a new tag under CertificationCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1703 // Step 3: Create the DB hierarchy and a DatabaseSchemaCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1710 // Step 4: Apply the certification tag to the DatabaseSchema via setCertification()COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1769 // Step 6: Rename the certification tag (change its name — this changes the FQN)COMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1777 // Step 7: Wait until certification tagFQN propagates to the entityCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1734 // Step 5: Verify search finds the schema by the original tag FQNCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1800 // Step 8: Search must find the schema under the new tag FQNCOMMENT
LOW…test/java/org/openmetadata/it/tests/TagResourceIT.java1836 // 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.java70 // Step 1: Create a policy that allows VIEW_ALL on entities with PII.Sensitive tagCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java87 // Step 2: Create a role with that policyCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java96 // Step 3: Create a team with that role as defaultCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java106 // Step 4: Create a user in that teamCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java120 // Step 5: Create database service and schema using factoriesCOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java128 // Step 6: Create a table WITH the PII.Sensitive tag using fluent APICOMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java149 // Step 7: Create a query that references the table (query does NOT have the tag)COMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java169 // Step 8: Verify the test user CAN view the table (due to tag-based policy)COMMENT
LOW…org/openmetadata/it/tests/QueryVisibilityPolicyIT.java178 // Step 9: Verify the test user CAN view queries for that tableCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1025 // Step 1: Create a glossary with initial version 0.1COMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1030 // Step 2: Prepare CSV content with multiple glossary termsCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1033 // Step 3: Import CSV using SYNC method (now also creates version history!)COMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1051 // Step 4: Verify version incremented to 0.2COMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1059 // Step 5: Retrieve version historyCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1066 // Step 6: Get version 0.2 and verify it has change descriptionCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1071 // Step 7: Verify change description contains 'bulkImport' field changeCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1077 // Step 8: Verify bulkImport field has statisticsCOMMENT
LOW…java/org/openmetadata/it/tests/GlossaryResourceIT.java1088 // Step 9: Verify glossary terms were actually createdCOMMENT
204 more matches not shown…
Fake / Example Data282 hits · 296 pts
SeverityFileLineSnippetContext
LOWingestion/tests/unit/test_dbt.py1752 self.assertTrue(validate_email_format("user@example.com"))CODE
LOWingestion/tests/unit/test_dbt.py1902 is_valid, error, value = validate_custom_property_value("testProp", "email", None, "user@example.com")CODE
LOWingestion/tests/unit/test_dbt.py1904 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.py59 "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.py573 "displayName": "John Doe",CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py594 "displayName": "John Doe",CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py603 root=[EntityReference(id=uuid.uuid4(), name="John Doe", type="user")]CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py682 displayName="Jane Doe",CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py854 self.assertEqual(owner_ref.root[0].name, "John Doe")CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py870 self.assertEqual(owner_ref.root[0].name, "John Doe")CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py1004 return EntityReferenceList(root=[EntityReference(id=uuid.uuid4(), name="John Doe", type="user")])CODE
LOWingestion/tests/unit/topology/dashboard/test_powerbi.py1019 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.py33 "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Nam consequat quam sagittis convallis cursus."CODE
LOWingestion/tests/unit/pii/test_ner_scanner.py33 "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Nam consequat quam sagittis convallis cursus."CODE
LOWingestion/tests/unit/pii/test_ner_scanner.py106 '{"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…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…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/sdk/test_table_entity.py291 rows=[["1", "user@example.com"]],CODE
LOWingestion/tests/unit/sdk/test_table_entity.py300 self.assertEqual(result.rows[0][1], "user@example.com")CODE
LOWingestion/tests/unit/sdk/test_user_entity.py36 displayName="John Doe",CODE
LOWingestion/tests/unit/sdk/test_user_entity.py44 expected_user.displayName = "John Doe"CODE
LOWingestion/tests/unit/sdk/test_sdk_entities.py143 displayName="John Doe",CODE
LOWingestion/tests/unit/sdk/test_improved_entities.py349 create_request = CreateUserRequest(name="john.doe", email="john.doe@company.com", displayName="John Doe")CODE
LOWingestion/tests/unit/sdk/test_dashboard_entity.py197 displayName="John Doe",CODE
LOWingestion/tests/unit/sdk/test_dashboard_entity.py212 self.assertEqual(result.owner.displayName, "John Doe")CODE
LOWingestion/tests/unit/readers/test_dsv_reader.py260 csv_content = 'id,name,address,notes\n1,"John Doe","123 Main St, City, State","Active customer"\n2,"Jane Smith",CODE
222 more matches not shown…
Unused Imports245 hits · 232 pts
SeverityFileLineSnippetContext
LOWingestion/tests/unit/conftest.py12CODE
LOW…ts/unit/topology/database/test_vertica_type_mapping.py24CODE
LOWingestion/tests/unit/topology/database/test_postgres.py862CODE
LOWingestion/tests/unit/topology/database/test_postgres.py873CODE
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…tion/src/metadata/ingestion/ometa/mixins/feed_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.py58CODE
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…/metadata/ingestion/source/database/glue/connection.py18CODE
LOW…a/ingestion/source/database/unitycatalog/connection.py15CODE
LOW…tadata/ingestion/source/database/timescale/__init__.py1CODE
LOW…data/ingestion/source/database/databricks/ownership.py15CODE
LOW…ata/ingestion/source/database/databricks/connection.py16CODE
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
LOW…etadata/ingestion/source/database/cassandra/helpers.py15CODE
LOW…metadata/ingestion/source/database/mysql/connection.py16CODE
LOW…/metadata/ingestion/source/database/hive/connection.py191CODE
LOW…/metadata/ingestion/source/database/hive/connection.py217CODE
LOW…/database/hive/metastore_dialects/postgres/__init__.py17CODE
LOW…rce/database/hive/metastore_dialects/mysql/__init__.py17CODE
LOW…metadata/ingestion/source/database/mssql/connection.py16CODE
LOW…etadata/ingestion/source/database/athena/connection.py16CODE
LOW…/src/metadata/ingestion/source/pipeline/nifi/client.py34CODE
LOW…on/src/metadata/ingestion/source/mcp/mcp/connection.py19CODE
185 more matches not shown…
Docstring Block Structure35 hits · 175 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.py275 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.py969 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.py132Compile 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.py276Remove start and ending double quotes in a string Args: string (str): a string Raises: TypeErrSTRING
HIGH…adata/utils/dependency_injector/dependency_injector.py328 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/action1xx.py160Return run meta and check instance of data_asset Args: data_asset: data assets of the checkpoint ruSTRING
HIGHingestion/src/metadata/great_expectations/action1xx.py247Get execution engine used to run the expectation Args: data_asset: data assets of the checkpoint ruSTRING
HIGHingestion/src/metadata/great_expectations/action.py191Return run meta and check instance of data_asset Args: data_asset: data assets of the checkpoint ruSTRING
HIGHingestion/src/metadata/great_expectations/action.py288Get execution engine used to run the expectation Args: data_asset: data assets of the checkpoint ruSTRING
HIGH…c/metadata/profiler/metrics/system/snowflake/system.py128Resolve 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.py164Get 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.py30 Get dialect-specific expressions for unique count computation. This centralizes all dialect-specific logic forSTRING
Redundant / Tautological Comments90 hits · 140 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.py248 # 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
LOWingestion/tests/cli_e2e/test_cli_tableau.py507 # Check if field type matches expectedCOMMENT
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.py816 # Check if domains are already the same, skip if identicalCOMMENT
LOW…/src/metadata/ingestion/source/database/sample_data.py871 # 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.py367 # Check if this is an Iceberg tableCOMMENT
LOW…rc/metadata/ingestion/source/database/glue/metadata.py392 # Check if this is a non-current Iceberg columnCOMMENT
LOW…rc/metadata/ingestion/source/database/glue/metadata.py409 # Check if this is a non-current Iceberg columnCOMMENT
LOW…ata/ingestion/source/database/unitycatalog/metadata.py602 # Check if the referred table exists in OpenMetadata before adding constraintCOMMENT
LOW…src/metadata/ingestion/source/database/dbt/metadata.py490 # Check if conversion failed (converted_value is None)COMMENT
LOW…rc/metadata/ingestion/source/database/dbt/dbt_utils.py189 # Check if columns match exactlyCOMMENT
LOW…etadata/ingestion/source/database/databricks/client.py191 # Check if queries executed successfully by fetching resultsCOMMENT
LOW…etadata/ingestion/source/database/bigquery/metadata.py222 # 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.py147 # Check if this is an Iceberg tableCOMMENT
LOW…src/metadata/ingestion/source/database/athena/utils.py176 # Check if this is a non-current Iceberg columnCOMMENT
LOW…ta/ingestion/source/pipeline/airflow/lineage_parser.py274 # Check if we can properly build the OMEntity classCOMMENT
LOW…tadata/ingestion/source/pipeline/airflow/api/client.py65 # Check if this is MWAA (AWS credentials)COMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py905 # Check if source is a view/table that reads from S3COMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py367 # Check if it's a Databricks or Unity Catalog serviceCOMMENT
LOW…gestion/source/pipeline/databrickspipeline/metadata.py787 # 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.py258 # Check if any broker hostname matchesCOMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py675 # Check if this is a Debezium CDC envelope structureCOMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py687 # Check if schemaText has CDC envelope fieldsCOMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py760 # Check if it's a direct fieldCOMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py764 # Check if it's a child field (nested - one level deep)COMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py798 # Check if this is a CDC envelope fieldCOMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py1590 # Check if this is a container dataset (storage sink)COMMENT
LOW…ata/ingestion/source/pipeline/kafkaconnect/metadata.py1618 # 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.py321 # Check if this is Confluent Cloud format (array of {config, value})COMMENT
LOW…n/src/metadata/ingestion/source/storage/s3/metadata.py809 # Check if custom console endpoint URL is configured (for external S3-compatible storage)COMMENT
LOW…n/src/metadata/ingestion/source/storage/s3/metadata.py833 # 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.py497 # 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.py1197 # Check if source expression references a dataset expressionCOMMENT
LOW…etadata/ingestion/source/dashboard/powerbi/metadata.py1218 # Check if this is a direct BigQuery connectionCOMMENT
LOW…etadata/ingestion/source/dashboard/powerbi/metadata.py1378 # Check if schema has a parent (database)COMMENT
LOW…ion/src/metadata/ingestion/source/api/rest/metadata.py333 # Check if type exists in DataTypeTopic enumCOMMENT
LOW…ion/src/metadata/ingestion/source/api/rest/metadata.py523 # Check if it's `object` type fieldCOMMENT
LOW…etadata/ingestion/source/drive/googledrive/metadata.py456 # Check if parent directory was included (if it has a parent)COMMENT
30 more matches not shown…
Modern Structural Boilerplate89 hits · 93 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.py108 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.py165logger = 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…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.py110def 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.py139 def set_total(self, type_: str, total: Optional[int]) -> None: # noqa: UP045CODE
LOWingestion/src/metadata/ingestion/progress/registry.py146 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.py138 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.py270 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.py253 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.py879 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.py301 def set_partition_details(self) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py308 def set_schema_description_map(self) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py314 def set_database_description_map(self) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py321 def set_external_location_map(self, database_name: str) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py329 def set_schema_tags_map(self, database_name: str) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py282 def set_session_query_tag(self) -> None:CODE
LOW…tadata/ingestion/source/database/snowflake/metadata.py360 def set_database_tags_map(self, database_name: str) -> None:CODE
LOW…etadata/ingestion/source/database/redshift/metadata.py274 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__.py33__all__ = [CODE
LOW…alidations/column/sqlalchemy/columnValuesToBeUnique.py45logger = logging.getLogger(__name__)CODE
29 more matches not shown…
AI Slop Vocabulary33 hits · 68 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.py1748 # 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.py2370 """Test 5-level star schema joins with comprehensive column lineage"""STRING
MEDIUM…ts/unit/lineage/queries/test_complex_query_patterns.py4053 """Test 3-branch UNION ALL with comprehensive column mapping"""STRING
MEDIUM…ts/unit/lineage/queries/test_complex_query_patterns.py4929 """Test UNION with subqueries and joins - comprehensive lineage"""STRING
MEDIUMingestion/tests/cli_e2e/test_cli_tableau.py205 """Test comprehensive metadata ingestion validation - runs after base ingestion"""STRING
MEDIUMingestion/tests/cli_e2e/test_cli_tableau.py220 """Test comprehensive lineage validation - Enable actual lineage testing"""STRING
MEDIUM…sts/integration/airflow/test_airflow_api_connection.py548 """Test comprehensive DAG metadata extraction with Airflow 3.x data."""STRING
MEDIUM…etadata/ingestion/source/database/bigquery/metadata.py230 # 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.py584# 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-external.yml25# The harness switches to external mode automatically when OM_URL + OM_ADMIN_TOKEN are set (seeCOMMENT
MEDIUM.github/workflows/java-playwright-external.yml199 # Credentials so the harness can re-login and auto-renew the token on long runs.COMMENT
MEDIUM.github/workflows/java-playwright-external.yml357 # Credentials so the harness can re-login and auto-renew the token on long runs.COMMENT
MEDIUM.github/workflows/java-playwright-external.yml492 # Credentials so the harness can re-login and auto-renew the token on long runs.COMMENT
MEDIUM.github/workflows/java-playwright-nightly.yml92 # --- The search ITs / UIITs, their test harness, and the Maven profiles that run them ---COMMENT
MEDIUM…main/resources/ui/playwright/doc-generator/markdown.js179 // Add explicit anchor div to ensure robust linkingCOMMENT
Modern AI Meta-Vocabulary9 hits · 26 pts
SeverityFileLineSnippetContext
MEDIUMingestion/pyproject.toml338# scaffold below), these libraries stay silent — keeping focus on our ownCOMMENT
MEDIUMingestion/pyproject.toml343# ── 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
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 Patterns22 hits · 22 pts
SeverityFileLineSnippetContext
LOWingestion/tests/unit/utils/test_memory_limit.py377CODE
LOW…tion/src/metadata/ingestion/ometa/mixins/task_mixin.py122CODE
LOW…tion/src/metadata/ingestion/ometa/mixins/feed_mixin.py43CODE
LOW…/metadata/ingestion/ometa/mixins/announcement_mixin.py40CODE
LOW…/metadata/ingestion/source/database/snowflake/utils.py278CODE
LOW…/metadata/ingestion/source/database/snowflake/utils.py310CODE
LOW…/metadata/ingestion/source/database/snowflake/utils.py325CODE
LOW…/metadata/ingestion/source/database/snowflake/utils.py342CODE
LOW…gestion/source/database/hive/custom_hive_connection.py16CODE
LOW…etadata/ingestion/source/pipeline/openlineage/utils.py49CODE
LOW…metadata/ingestion/source/dashboard/superset/client.py215CODE
LOW…src/metadata/ingestion/source/metadata/atlas/client.py54CODE
LOW…stion/src/metadata/ingestion/models/custom_pydantic.py86CODE
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.py187CODE
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
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.py135 def process_data(self, row: str, entities_score: Dict[str, StringAnalysis]) -> None: # noqa: UP006CODE
LOW…adata/utils/dependency_injector/dependency_injector.py97 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.ts278 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