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.
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).
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.
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.
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.
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.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …main/java/org/openmetadata/schema/utils/JsonUtils.java | 492 | com.github.fge.jsonpatch.JsonPatch.fromJson(patchNode); | CODE |
| CRITICAL⚡ | ingestion/tests/unit/test_ssl_manager.py | 115 | kafka_source_with_ssl.service_connection.schemaRegistrySSL.root.caCertificate.get_secret_value(), | CODE |
| CRITICAL⚡ | ingestion/tests/unit/test_ssl_manager.py | 119 | kafka_source_with_ssl.service_connection.schemaRegistrySSL.root.sslKey.get_secret_value(), | CODE |
| CRITICAL⚡ | ingestion/tests/unit/test_ssl_manager.py | 123 | kafka_source_with_ssl.service_connection.schemaRegistrySSL.root.sslCertificate.get_secret_value(), | CODE |
| CRITICAL⚡ | ingestion/tests/unit/test_ssl_manager.py | 192 | cassandra_source_with_ssl.service_connection.sslConfig.root.caCertificate.get_secret_value(), | CODE |
| CRITICAL⚡ | ingestion/tests/unit/test_ssl_manager.py | 196 | cassandra_source_with_ssl.service_connection.sslConfig.root.sslKey.get_secret_value(), | CODE |
| CRITICAL⚡ | ingestion/tests/unit/test_ssl_manager.py | 200 | cassandra_source_with_ssl.service_connection.sslConfig.root.sslCertificate.get_secret_value(), | CODE |
| CRITICAL | …t/topology/database/test_datalake_azure_blob_client.py | 23 | from azure.core.exceptions import ResourceNotFoundError | CODE |
| CRITICAL | …estion/tests/unit/topology/pipeline/test_airflowapi.py | 37 | from metadata.utils.helpers import datetime_to_ts | CODE |
| CRITICAL⚡ | ingestion/tests/unit/topology/dashboard/test_tableau.py | 521 | self.tableau.config.serviceConnection.root.config.sslConfig.root.sslCertificate.get_secret_value(), | CODE |
| CRITICAL⚡ | ingestion/tests/unit/topology/dashboard/test_tableau.py | 525 | self.tableau.config.serviceConnection.root.config.sslConfig.root.sslKey.get_secret_value(), | CODE |
| CRITICAL⚡ | ingestion/tests/unit/topology/dashboard/test_tableau.py | 529 | self.tableau.config.serviceConnection.root.config.sslConfig.root.caCertificate.get_secret_value(), | CODE |
| CRITICAL⚡ | ingestion/tests/unit/topology/dashboard/test_tableau.py | 547 | self.tableau.config.serviceConnection.root.config.sslConfig.root.caCertificate.get_secret_value(), | CODE |
| CRITICAL⚡ | …n/tests/unit/topology/dashboard/test_tableau_client.py | 128 | self.client.tableau_server.users.get_by_id.assert_not_called() | CODE |
| CRITICAL | ingestion/tests/unit/topology/drive/test_googledrive.py | 223 | mock_client.drive_service.files.return_value.list.assert_called() | CODE |
| CRITICAL | ingestion/tests/unit/topology/drive/test_googledrive.py | 375 | mock_client.drive_service.files.return_value.list.assert_called() | CODE |
| CRITICAL | ingestion/tests/unit/topology/drive/test_googledrive.py | 428 | mock_client.sheets_service.spreadsheets.return_value.get.assert_called_with(spreadsheetId="sheet_001") | CODE |
| CRITICAL | ingestion/tests/integration/conftest.py | 110 | "type": db_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | ingestion/tests/integration/conftest.py | 133 | "type": db_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | ingestion/tests/integration/conftest.py | 332 | "type": db_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | …tion/tests/integration/ometa/test_ometa_service_api.py | 69 | assert service.connection.config.authType.password.get_secret_value() == "openmetadata_password" | CODE |
| CRITICAL | …tion/tests/integration/ometa/test_ometa_service_api.py | 224 | assert service.connection.config.authType.password.get_secret_value() == "tb_pwd" | CODE |
| CRITICAL | …stion/tests/integration/ometa/test_ometa_test_suite.py | 52 | from metadata.utils.helpers import datetime_to_ts | CODE |
| CRITICAL | …ion/tests/integration/ometa/test_ometa_pipeline_api.py | 30 | from metadata.utils.helpers import datetime_to_ts | CODE |
| CRITICAL | ingestion/tests/integration/ometa/test_ometa_patch.py | 55 | from metadata.utils.helpers import find_column_in_table | CODE |
| CRITICAL | …ion/tests/integration/ometa/test_ometa_workflow_api.py | 105 | assert res.request.connection.config.authType.password.get_secret_value() == "password" | CODE |
| CRITICAL | …assification/databases/test_azuresql_temporal_table.py | 226 | "type": db_service.connection.config.type.value.lower(), | STRING |
| CRITICAL | …assification/databases/test_azuresql_temporal_table.py | 246 | "type": db_service.connection.config.type.value.lower(), | STRING |
| CRITICAL | …sification/databases/test_global_sample_data_config.py | 71 | "type": db_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | …sification/databases/test_global_sample_data_config.py | 116 | "type": db_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | …on/auto_classification/databases/test_tag_processor.py | 58 | "type": db_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | …on/auto_classification/databases/test_tag_processor.py | 100 | "type": db_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | ingestion/tests/integration/data_quality/conftest.py | 102 | "type": postgres_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | …ts/integration/data_quality/test_failed_row_samples.py | 263 | "type": postgres_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | …ts/integration/data_quality/test_failed_row_samples.py | 291 | "type": db_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | ingestion/tests/integration/kafka/conftest.py | 122 | "type": db_service.connection.config.type.value.lower(), | STRING |
| CRITICAL | ingestion/tests/integration/sdk/conftest.py | 206 | "type": db_service.connection.config.type.value.lower(), | CODE |
| CRITICAL | …/sources/database/delta_lake/test_deltalake_storage.py | 127 | type=service.connection.config.type.value.lower(), | CODE |
| CRITICAL | …sts/integration/sources/mlmodels/mlflow/test_mlflow.py | 176 | type=service.connection.config.type.value.lower(), | CODE |
| CRITICAL | …tion/tests/integration/profiler/test_nosql_profiler.py | 43 | from metadata.utils.helpers import datetime_to_ts | CODE |
| CRITICAL | …on/src/airflow_provider_openmetadata/lineage/runner.py | 72 | from metadata.utils.helpers import clean_uri, datetime_to_ts # noqa: E402 | CODE |
| CRITICAL | …on/src/airflow_provider_openmetadata/lineage/status.py | 25 | from metadata.utils.helpers import datetime_to_ts | CODE |
| CRITICAL | ingestion/src/metadata/clients/domo_client.py | 34 | from metadata.utils.helpers import clean_uri | CODE |
| CRITICAL | ingestion/src/metadata/parsers/protobuf_parser.py | 30 | from metadata.utils.helpers import snake_to_camel | CODE |
| CRITICAL | …adata/ingestion/source/database/query_parser_source.py | 36 | from metadata.utils.helpers import get_start_and_end, retry_with_docker_host | CODE |
| CRITICAL | …tadata/ingestion/source/database/sql_column_handler.py | 34 | from metadata.utils.helpers import clean_up_starting_ending_double_quotes_in_string | CODE |
| CRITICAL | …/src/metadata/ingestion/source/database/sample_data.py | 191 | from metadata.utils.helpers import get_standard_chart_type | CODE |
| CRITICAL | …metadata/ingestion/source/database/common_db_source.py | 73 | from metadata.utils.helpers import retry_with_docker_host | CODE |
| CRITICAL | …c/metadata/ingestion/source/database/lineage_source.py | 109 | # from metadata.utils.helpers import can_spawn_child_process | COMMENT |
| CRITICAL | …adata/ingestion/source/database/common_nosql_source.py | 57 | from metadata.utils.helpers import retry_with_docker_host | CODE |
| CRITICAL | …a/ingestion/source/database/stored_procedures_mixin.py | 48 | from metadata.utils.helpers import pprint_format_object | CODE |
| CRITICAL | …ata/ingestion/source/database/unitycatalog/metadata.py | 102 | from metadata.utils.helpers import retry_with_docker_host | CODE |
| CRITICAL | …data/ingestion/source/database/unitycatalog/lineage.py | 55 | from metadata.utils.helpers import retry_with_docker_host | CODE |
| CRITICAL⚡ | …c/metadata/ingestion/source/database/dbt/dbt_config.py | 649 | from azure.core.exceptions import AzureError, ClientAuthenticationError # noqa: PLC0415 | CODE |
| CRITICAL | …c/metadata/ingestion/source/database/dbt/dbt_config.py | 54 | from metadata.utils.helpers import clean_uri | CODE |
| CRITICAL | …/metadata/ingestion/source/database/saperp/metadata.py | 58 | from metadata.utils.helpers import clean_up_starting_ending_double_quotes_in_string | CODE |
| CRITICAL | …rc/metadata/ingestion/source/database/saperp/client.py | 31 | from metadata.utils.helpers import clean_uri | CODE |
| CRITICAL | …ta/ingestion/source/database/timescale/query_parser.py | 37 | from metadata.utils.helpers import get_start_and_end | CODE |
| CRITICAL | …c/metadata/ingestion/source/database/oracle/lineage.py | 44 | from metadata.utils.helpers import get_start_and_end | CODE |
| CRITICAL | …etadata/ingestion/source/database/databricks/client.py | 50 | from metadata.utils.helpers import datetime_to_ts | CODE |
| 1064 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | ingestion/operators/docker/exit_handler.py | 470 | def update_pipeline_status_with_diagnostics( | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 370 | def get_or_create_pipeline_status(metadata: OpenMetadata, workflow_config) -> PipelineStatus: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 401 | def gather_failure_diagnostics( | CODE |
| LOW⚡ | ingestion/tests/unit/test_exit_handler.py | 39 | def test_has_diagnostics_with_logs(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_exit_handler.py | 44 | def test_has_diagnostics_with_description(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_exit_handler.py | 49 | def test_has_diagnostics_with_both(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_exit_handler.py | 54 | def test_has_diagnostics_empty(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_exit_handler.py | 64 | def test_summary_with_description(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_exit_handler.py | 314 | def test_creates_step_summary_with_logs(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_exit_handler.py | 323 | def test_creates_step_summary_with_description(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_exit_handler.py | 330 | def test_creates_step_summary_with_both(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_exit_handler.py | 338 | def test_handles_empty_diagnostics(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 80 | def test_in_cluster_config_success(self, mock_client, mock_config): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 92 | def test_fallback_to_kubeconfig(self, mock_client, mock_config): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 104 | def test_returns_none_on_failure(self, mock_config): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 117 | def test_returns_none_with_invalid_params(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 127 | def test_finds_pod_by_job_name_label(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 142 | def test_returns_none_when_no_pods_found(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 153 | def test_handles_api_exceptions_gracefully(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 166 | def test_returns_logs_successfully(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 184 | def test_returns_none_for_invalid_pod(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 196 | def test_handles_api_exceptions_gracefully(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 212 | def test_builds_description_with_status(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 233 | def test_returns_none_for_invalid_pod(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 240 | def test_handles_exceptions_gracefully(self): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 267 | def test_returns_empty_when_pod_not_found(self, mock_find_pod, mock_get_client): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 280 | def test_gathers_all_diagnostics(self, mock_description, mock_logs, mock_find_pod, mock_get_client): | CODE |
| LOW | ingestion/tests/unit/test_exit_handler.py | 297 | def test_continues_on_partial_failure(self, mock_description, mock_logs, mock_find_pod, mock_get_client): | CODE |
| LOW | ingestion/tests/unit/test_version.py | 22 | def test_get_version_from_string(): | CODE |
| LOW | ingestion/tests/unit/test_version.py | 33 | def test_get_client_version_from_string(): | CODE |
| LOW | ingestion/tests/unit/test_column_type_parser.py | 99 | def test_check_datatype_support(self): | CODE |
| LOW | ingestion/tests/unit/test_column_type_parser.py | 137 | def test_superset_parse_array_data_type(): | CODE |
| LOW | …stion/tests/unit/test_workflow_parse_example_config.py | 15 | def test_parse_workflow_config(self): | CODE |
| LOW | ingestion/tests/unit/test_owner_utils.py | 30 | def test_simple_default_owner(self): | CODE |
| LOW | ingestion/tests/unit/test_owner_utils.py | 42 | def test_level_specific_owner(self): | CODE |
| LOW | ingestion/tests/unit/test_owner_utils.py | 70 | def test_specific_entity_mapping(self): | CODE |
| LOW | ingestion/tests/unit/test_owner_utils.py | 110 | def test_simple_name_fallback(self): | CODE |
| LOW | ingestion/tests/unit/test_owner_utils.py | 137 | def test_inheritance_disabled(self): | CODE |
| LOW | ingestion/tests/unit/test_owner_utils.py | 201 | def test_multiple_owners_array(self): | CODE |
| LOW | ingestion/tests/unit/test_owner_utils.py | 238 | def test_multiple_owners_partial_success(self): | CODE |
| LOW | ingestion/tests/unit/test_owner_utils.py | 270 | def test_multiple_owners_all_fail(self): | CODE |
| LOW | ingestion/tests/unit/test_owner_utils.py | 281 | def test_backward_compatibility_single_string(self): | CODE |
| LOW | ingestion/tests/unit/test_owner_utils.py | 293 | def test_multiple_owners_with_fqn(self): | CODE |
| LOW | ingestion/tests/unit/conftest.py | 45 | def register_sqlite_math_functions(): | CODE |
| LOW | ingestion/tests/unit/conftest.py | 84 | def pytest_pycollect_makeitem(collector, name, obj): | CODE |
| LOW⚡ | ingestion/tests/unit/test_ometa_utils.py | 154 | def test_render_query_headers_builds_the_right_string(self) -> None: | CODE |
| LOW⚡ | ingestion/tests/unit/test_ometa_utils.py | 157 | def test_build_entity_reference(self) -> None: | CODE |
| LOW⚡ | ingestion/tests/unit/test_ometa_utils.py | 163 | def test_decode_jwt_token_valid(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_ometa_utils.py | 187 | def test_decode_jwt_token_with_padding(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_ometa_utils.py | 243 | def test_decode_jwt_token_none_input(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_ometa_utils.py | 248 | def test_decode_jwt_token_empty_string(self): | CODE |
| LOW⚡ | ingestion/tests/unit/test_ometa_utils.py | 253 | def test_decode_jwt_token_real_world_example(self): | CODE |
| LOW | ingestion/tests/unit/test_ometa_utils.py | 103 | def test_get_entity_type_camel_case_consistency(self): | CODE |
| LOW | ingestion/tests/unit/test_ometa_utils.py | 203 | def test_decode_jwt_token_invalid_format(self): | CODE |
| LOW | ingestion/tests/unit/test_ometa_utils.py | 221 | def test_decode_jwt_token_invalid_json(self): | CODE |
| LOW | ingestion/tests/unit/test_ometa_utils.py | 232 | def test_decode_jwt_token_empty_payload(self): | CODE |
| LOW | ingestion/tests/unit/test_ometa_utils.py | 276 | def test_get_entity_hierarchy_returns_dict(self): | CODE |
| LOW | ingestion/tests/unit/test_ometa_utils.py | 283 | def test_get_entity_hierarchy_caching(self): | CODE |
| LOW | ingestion/tests/unit/test_ometa_utils.py | 294 | def test_get_entity_hierarchy_database_service_order(self): | CODE |
| LOW | ingestion/tests/unit/test_ometa_utils.py | 317 | def test_get_entity_hierarchy_messaging_service_order(self): | CODE |
| 7667 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …ests/unit/topology/database/test_datalake_s3_client.py | 0 | tests for skip_cold_storage filtering in get_table_names | STRING |
| HIGH | …t/topology/database/test_datalake_azure_blob_client.py | 0 | tests for skip_cold_storage filtering in get_table_names | STRING |
| HIGH | …sts/unit/topology/database/test_datalake_gcs_client.py | 0 | tests for skip_cold_storage filtering in get_table_names | STRING |
| HIGH | …/topology/database/test_databricks_ordinal_position.py | 0 | test that ordinal position is set for a single column | STRING |
| HIGH | …it/topology/database/test_redshift_ordinal_position.py | 0 | test that ordinal position is set for a single column | STRING |
| HIGH | …opology/database/test_unitycatalog_ordinal_position.py | 0 | test that ordinal position is set for a single column | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_looker.py | 0 | test that when includeowners is true, owner information is processed | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_tableau.py | 0 | test that when includeowners is true, owner information is processed | STRING |
| HIGH | …on/tests/unit/topology/dashboard/test_microstrategy.py | 0 | test that when includeowners is true, owner information is processed | STRING |
| HIGH | …gestion/tests/unit/topology/dashboard/test_metabase.py | 0 | test that when includeowners is true, owner information is processed | STRING |
| HIGH | …stion/tests/unit/topology/dashboard/test_quicksight.py | 0 | test that when includeowners is true, owner information is processed | STRING |
| HIGH | …estion/tests/unit/topology/dashboard/test_qliksense.py | 0 | test that when includeowners is true, owner information is processed | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_sigma.py | 0 | test that when includeowners is true, owner information is processed | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_looker.py | 0 | test that when includeowners is false, owner information is not processed | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_tableau.py | 0 | test that when includeowners is false, owner information is not processed | STRING |
| HIGH | …on/tests/unit/topology/dashboard/test_microstrategy.py | 0 | test that when includeowners is false, owner information is not processed | STRING |
| HIGH | …gestion/tests/unit/topology/dashboard/test_metabase.py | 0 | test that when includeowners is false, owner information is not processed | STRING |
| HIGH | …stion/tests/unit/topology/dashboard/test_quicksight.py | 0 | test that when includeowners is false, owner information is not processed | STRING |
| HIGH | …estion/tests/unit/topology/dashboard/test_qliksense.py | 0 | test that when includeowners is false, owner information is not processed | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_sigma.py | 0 | test that when includeowners is false, owner information is not processed | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_looker.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_ssrs.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_tableau.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | …on/tests/unit/topology/dashboard/test_microstrategy.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_grafana.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | …estion/tests/unit/topology/dashboard/test_qlikcloud.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | …gestion/tests/unit/topology/dashboard/test_metabase.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | …stion/tests/unit/topology/dashboard/test_quicksight.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | …on/tests/unit/topology/dashboard/test_domodashboard.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | …estion/tests/unit/topology/dashboard/test_qliksense.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_sigma.py | 0 | verify register_record_chart populates chart_source_state after yield_dashboard_chart. | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_tableau.py | 0 | implements the necessary methods to extract domo dashboard unit test | STRING |
| HIGH | …gestion/tests/unit/topology/dashboard/test_metabase.py | 0 | implements the necessary methods to extract domo dashboard unit test | STRING |
| HIGH | …on/tests/unit/topology/dashboard/test_domodashboard.py | 0 | implements the necessary methods to extract domo dashboard unit test | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_sigma.py | 0 | implements the necessary methods to extract domo dashboard unit test | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_tableau.py | 0 | test that the includeowners flag is properly set in the configuration | STRING |
| HIGH | …on/tests/unit/topology/dashboard/test_microstrategy.py | 0 | test that the includeowners flag is properly set in the configuration | STRING |
| HIGH | …gestion/tests/unit/topology/dashboard/test_metabase.py | 0 | test that the includeowners flag is properly set in the configuration | STRING |
| HIGH | …stion/tests/unit/topology/dashboard/test_quicksight.py | 0 | test that the includeowners flag is properly set in the configuration | STRING |
| HIGH | …estion/tests/unit/topology/dashboard/test_qliksense.py | 0 | test that the includeowners flag is properly set in the configuration | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_sigma.py | 0 | test that the includeowners flag is properly set in the configuration | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_tableau.py | 0 | test that the includeowners flag affects how owner information is processed | STRING |
| HIGH | …on/tests/unit/topology/dashboard/test_microstrategy.py | 0 | test that the includeowners flag affects how owner information is processed | STRING |
| HIGH | …gestion/tests/unit/topology/dashboard/test_metabase.py | 0 | test that the includeowners flag affects how owner information is processed | STRING |
| HIGH | …stion/tests/unit/topology/dashboard/test_quicksight.py | 0 | test that the includeowners flag affects how owner information is processed | STRING |
| HIGH | …estion/tests/unit/topology/dashboard/test_qliksense.py | 0 | test that the includeowners flag affects how owner information is processed | STRING |
| HIGH | ingestion/tests/unit/topology/dashboard/test_sigma.py | 0 | test that the includeowners flag affects how owner information is processed | STRING |
| HIGH | …sts/unit/source/database/databricks/test_connection.py | 0 | mirror ``sqlalchemy.exc.dbapierror``: wraps the driver error on ``.orig``. | STRING |
| HIGH | …ests/unit/source/database/snowflake/test_connection.py | 0 | mirror ``sqlalchemy.exc.dbapierror``: wraps the driver error on ``.orig``. | STRING |
| HIGH | …tests/unit/source/database/redshift/test_connection.py | 0 | mirror ``sqlalchemy.exc.dbapierror``: wraps the driver error on ``.orig``. | STRING |
| HIGH | …tests/unit/source/database/postgres/test_connection.py | 0 | mirror ``sqlalchemy.exc.dbapierror``: wraps the driver error on ``.orig``. | STRING |
| HIGH | …ility/profiler/test_nosql_profiler_processor_status.py | 0 | verify each metric group reports a separate status entry. | STRING |
| HIGH | …servability/profiler/test_profiler_processor_status.py | 0 | verify each metric group reports a separate status entry. | STRING |
| HIGH | …servability/profiler/pandas/test_profiler_interface.py | 0 | verify each metric group reports a separate status entry. | STRING |
| HIGH | ingestion/tests/cli_e2e/test_cli_oracle.py | 0 | 3. 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.py | 0 | 3. delete the new table + deploy marking tables as deleted we will perform the following steps: 1. delete table created | STRING |
| HIGH | ingestion/tests/cli_e2e/base/test_cli_db.py | 0 | 3. delete the new table + deploy marking tables as deleted we will perform the following steps: 1. delete table created | STRING |
| HIGH | ingestion/tests/cli_e2e/test_cli_oracle.py | 0 | 5. vanilla ingestion + exclude schema filter pattern we will perform the following steps: 1. build config file for inges | STRING |
| HIGH | …on/tests/cli_e2e/test_cli_bigquery_multiple_project.py | 0 | 5. vanilla ingestion + exclude schema filter pattern we will perform the following steps: 1. build config file for inges | STRING |
| HIGH | ingestion/tests/cli_e2e/base/test_cli_db.py | 0 | 5. vanilla ingestion + exclude schema filter pattern we will perform the following steps: 1. build config file for inges | STRING |
| 628 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | ingestion/pyproject.toml | 118 | # ─── Selected rule families ────────────────────────────────────────────── | COMMENT |
| MEDIUM | ingestion/pyproject.toml | 155 | # ─── Ignores: justify EVERY one ────────────────────────────────────────── | COMMENT |
| MEDIUM | ingestion/pyproject.toml | 288 | # ── Real-bug catchers held to error ────────────────────────────────────── | COMMENT |
| MEDIUM | ingestion/pyproject.toml | 302 | # ── Cheap promotions: real-bug rules that fire rarely ──────────────────── | COMMENT |
| MEDIUM | ingestion/pyproject.toml | 307 | # ── Stub-gap noise: explicitly off (matches `standard` defaults) ───────── | COMMENT |
| MEDIUM | ingestion/pyproject.toml | 320 | # ── Project-specific waivers ───────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | ingestion/pyproject.toml | 343 | # ── Ratchet scaffold: enable subtree-by-subtree promotions later ──────── | COMMENT |
| MEDIUM | ingestion/noxfile.py | 108 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/noxfile.py | 110 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/noxfile.py | 137 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/noxfile.py | 139 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/noxfile.py | 182 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/noxfile.py | 184 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/noxfile.py | 240 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/noxfile.py | 242 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_status.py | 34 | # ── as_string ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_status.py | 89 | # ── failed / fail_all ──────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_status.py | 104 | # ── calculate_success ──────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_status.py | 128 | # ── warning / filter ───────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_status.py | 138 | # ── truncation of stack traces ─────────────────────────────────── | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_query_parser.py | 418 | # ------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_query_parser.py | 420 | # ------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_scaffold.py | 88 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_scaffold.py | 90 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_scaffold.py | 132 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_scaffold.py | 134 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_scaffold.py | 420 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_scaffold.py | 422 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_scaffold.py | 482 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_scaffold.py | 484 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_scaffold.py | 569 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_scaffold.py | 571 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/tests/unit/test_scaffold.py | 41 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/tests/unit/test_scaffold.py | 43 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/tests/unit/test_scaffold.py | 306 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/tests/unit/test_scaffold.py | 308 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/tests/unit/test_scaffold.py | 551 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/tests/unit/test_scaffold.py | 553 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/test_queue.py | 32 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/topology/database/test_iomete.py | 68 | # ── get_connection: URL construction ───────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/topology/database/test_iomete.py | 146 | # ── IometeSource.create ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_iomete.py | 30 | # ── fixtures ────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_iomete.py | 187 | # ── get_schema_definition ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_iomete.py | 259 | # ── get_database_names ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_iomete.py | 289 | # ── set_inspector ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 144 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 146 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 290 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 292 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 355 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 357 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 740 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 742 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 830 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 832 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 858 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 860 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 992 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …logy/database/test_snowflake_access_history_lineage.py | 994 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …logy/database/test_snowflake_access_history_lineage.py | 44 | # --------------------------------------------------------------------------- | COMMENT |
| 564 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | ingestion/operators/docker/exit_handler.py | 97 | except Exception as in_cluster_error: | CODE |
| LOW⚡ | ingestion/operators/docker/exit_handler.py | 102 | except Exception as kubeconfig_error: | CODE |
| LOW⚡ | ingestion/operators/docker/exit_handler.py | 107 | except Exception as unexpected_error: # noqa: B025 | CODE |
| LOW⚡ | ingestion/operators/docker/exit_handler.py | 301 | except Exception as event_error: | CODE |
| LOW⚡ | ingestion/operators/docker/exit_handler.py | 306 | except Exception as e: | CODE |
| LOW⚡ | ingestion/operators/docker/exit_handler.py | 316 | except Exception as e: | CODE |
| LOW⚡ | ingestion/operators/docker/exit_handler.py | 446 | except Exception as e: | CODE |
| LOW⚡ | ingestion/operators/docker/exit_handler.py | 455 | except Exception as e: | CODE |
| LOW⚡ | ingestion/operators/docker/exit_handler.py | 464 | except Exception as e: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 161 | except Exception as list_error: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 173 | except Exception as pod_error: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 180 | except Exception as e: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 215 | except Exception as e: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 281 | except Exception as container_error: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 284 | except Exception as status_error: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 423 | except Exception as e: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 434 | except Exception as e: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 498 | except Exception as e: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 501 | except Exception as e: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 572 | except Exception as e: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 580 | except Exception as e: | CODE |
| LOW | ingestion/operators/docker/exit_handler.py | 591 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/test_column_type_parser.py | 94 | except Exception as exc: | CODE |
| LOW | …stion/tests/unit/test_workflow_parse_example_config.py | 24 | except Exception as exc: | CODE |
| LOW | ingestion/tests/unit/test_dbt_ingest.py | 285 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/test_parser_connection_fallback.py | 258 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/test_parser_connection_class.py | 117 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/test_parser_connection_module.py | 164 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/test_parser_connection_module.py | 197 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/test_parser_connection_module.py | 229 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/test_parser_connection_module.py | 259 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/test_parser_connection_module.py | 403 | except Exception as e: | CODE |
| LOW | …/tests/unit/topology/database/test_common_db_source.py | 392 | except Exception: | CODE |
| LOW | …/tests/unit/topology/database/test_common_db_source.py | 533 | except Exception: | CODE |
| LOW | …/tests/unit/topology/database/test_common_db_source.py | 559 | except Exception: | CODE |
| LOW | ingestion/tests/unit/topology/pipeline/test_airflow.py | 506 | except Exception: # pylint: disable=broad-exception-caught | CODE |
| LOW | …ests/unit/topology/dashboard/test_looker_multi_repo.py | 340 | except Exception: | CODE |
| LOW⚡ | ingestion/tests/unit/utils/test_datalake.py | 600 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/utils/test_datalake.py | 666 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/utils/test_memory_limit.py | 736 | except Exception as e: | CODE |
| LOW⚡ | …ity/profiler/sqlalchemy/test_sqa_profiler_interface.py | 183 | except Exception as e: | CODE |
| MEDIUM⚡ | …ity/profiler/sqlalchemy/test_sqa_profiler_interface.py | 184 | print(f"Error during table setup: {str(e)}") # noqa: RUF010, T201 | CODE |
| LOW | …ity/profiler/sqlalchemy/test_sqa_profiler_interface.py | 200 | except Exception as e: | CODE |
| MEDIUM | …ity/profiler/sqlalchemy/test_sqa_profiler_interface.py | 201 | print(f"Error during cleanup: {str(e)}") # noqa: RUF010, T201 | CODE |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 284 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 312 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 340 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 388 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 449 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 477 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 505 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 553 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/readers/test_parquet_batches.py | 230 | except Exception as e: | CODE |
| LOW | ingestion/tests/unit/readers/test_s3_n_plus_one.py | 73 | except Exception: | CODE |
| LOW⚡ | ingestion/tests/unit/readers/test_s3_n_plus_one.py | 138 | except Exception: | CODE |
| MEDIUM | …ion/tests/unit/metadata/utils/test_progress_tracker.py | 211 | def increment_many(): | CODE |
| LOW | …ion/tests/unit/metadata/utils/test_progress_tracker.py | 215 | except Exception as e: | CODE |
| LOW | ingestion/tests/cli_e2e/test_cli_oracle.py | 77 | except Exception: | STRING |
| LOW | ingestion/tests/cli_e2e/test_cli_oracle.py | 83 | except Exception: | STRING |
| LOW | ingestion/tests/cli_e2e/base/test_cli.py | 122 | except Exception as exc: | CODE |
| 1706 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | ingestion/tests/unit/test_avro_parser.py | 550 | "default": null, | CODE |
| HIGH⚡ | ingestion/tests/unit/test_avro_parser.py | 698 | self.parse_schema_assert_without_child(UNION_EXAMPLE_1, "UNION<null,int>") | STRING |
| HIGH⚡ | ingestion/tests/unit/test_avro_parser.py | 699 | self.parse_schema_assert_without_child(UNION_EXAMPLE_2, "UNION<null,int,string,boolean>") | STRING |
| HIGH⚡ | ingestion/tests/unit/test_avro_parser.py | 700 | self.parse_schema_assert_one_child(UNION_EXAMPLE_3, "UNION<null,record>") | STRING |
| HIGH⚡ | ingestion/tests/unit/test_avro_parser.py | 701 | self.parse_schema_assert_without_child(UNION_EXAMPLE_4, "UNION<null,record,record>") | STRING |
| HIGH⚡ | ingestion/tests/unit/test_avro_parser.py | 702 | self.parse_schema_assert_without_child(UNION_OF_ARRAY, "UNION<null,ARRAY<int>>") | STRING |
| HIGH⚡ | ingestion/tests/unit/test_avro_parser.py | 704 | self.parse_schema_assert_one_child(UNION_OF_ARRAY_OF_RECORD, "UNION<null,ARRAY<record>>") | STRING |
| HIGH | ingestion/tests/unit/topology/database/test_datalake.py | 148 | {"name":"John","age":16,"sex":"M","address":null}, | CODE |
| HIGH | …tion/tests/unit/topology/pipeline/test_kafkaconnect.py | 741 | # Create CDC topic with only 'before' field having data (after only has null) | COMMENT |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 100 | "deferring_job_definition_id": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 101 | "deferring_environment_id": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 103 | "lifecycle_webhooks_url": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 200 | "should_start_at": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 201 | "trigger": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 202 | "job": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 203 | "environment": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 236 | "git_branch": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 237 | "git_sha": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 238 | "status_message": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 239 | "owner_thread_id": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 240 | "executed_by_thread_id": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 241 | "deferring_run_id": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 243 | "artifact_s3_path": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 252 | "dequeued_at": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 253 | "started_at": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 254 | "finished_at": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 255 | "last_checked_at": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 256 | "last_heartbeat_at": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 257 | "should_start_at": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 258 | "trigger": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 259 | "job": null, | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 260 | "environment": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 88 | "dbt_version": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 89 | "raw_dbt_version": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 137 | "job_completion_trigger_condition": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 140 | "next_run": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 184 | "owner_thread_id": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 186 | "deferring_run_id": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 219 | "retrying_run_id": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 223 | "is_running": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 276 | "retrying_run_id": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 280 | "is_running": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 315 | "rawSql": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 330 | "rawSql": null, | STRING |
| HIGH | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 345 | "rawSql": null, | STRING |
| HIGH⚡ | …stion/tests/unit/topology/pipeline/test_openlineage.py | 812 | """Missing, null, or wrongly typed facet shapes yield an empty list.""" | STRING |
| HIGH⚡ | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 115 | Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [Catalog="DEMO_CATALOG", Dat | CODE |
| HIGH⚡ | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 121 | [Catalog="DEMO_CATALOG", Database=null, EnableAutomaticProxyDiscovery=null]) | CODE |
| HIGH⚡ | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 123 | "select * from PUBLIC.STG_CUSTOMERS", null, [EnableFolding=true]) | CODE |
| HIGH⚡ | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 130 | Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [ Catalog= "DEMO_CATALOG | CODE |
| HIGH⚡ | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 137 | Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [Catalog="DEMO_CATALOG", Dat | CODE |
| HIGH⚡ | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 142 | Source = Value.NativeQuery(Databricks.Catalogs(Databricks_Server, Databricks_HTTP_Path, [Catalog="DEMO_CATALOG", Dat | CODE |
| HIGH | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 174 | "null, [EnableFolding=true])\n" | CODE |
| HIGH | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 195 | "null, [EnableFolding=true])\n" | CODE |
| HIGH | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 219 | "null, [EnableFolding=true])\n" | CODE |
| HIGH | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 242 | "null, [EnableFolding=true]),\n" | CODE |
| HIGH | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 262 | "null, [EnableFolding=true]),\n" | CODE |
| HIGH | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 314 | "null, [EnableFolding=true]),\n" | CODE |
| HIGH | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 509 | "null, [EnableFolding=true])\n" | CODE |
| HIGH | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 749 | test_snowflaek_query_expression = 'let\n Source = Value.NativeQuery(Snowflake.Databases("dummy_host",(Warehou | CODE |
| 62 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …a/ingestion/source/database/my_db/CONNECTOR_CONTEXT.md | 44 | ## Step 1: Read the Reference Connector | COMMENT |
| LOW | …a/ingestion/source/database/my_db/CONNECTOR_CONTEXT.md | 56 | ## Step 2: Implement the Connector Files | COMMENT |
| LOW | …a/ingestion/source/database/my_db/CONNECTOR_CONTEXT.md | 74 | ## Step 3: Register the Connector | COMMENT |
| LOW | …a/ingestion/source/database/my_db/CONNECTOR_CONTEXT.md | 96 | ## Step 4: Code Generation and Formatting | COMMENT |
| LOW | …a/ingestion/source/database/my_db/CONNECTOR_CONTEXT.md | 107 | ## Step 5: Write Tests and Validate | COMMENT |
| LOW | …src/metadata/ingestion/source/database/dbt/metadata.py | 450 | # Step 1: Check if property exists in OpenMetadata | COMMENT |
| LOW | …src/metadata/ingestion/source/database/dbt/metadata.py | 466 | # Step 2: Validate and convert value (single pass) | COMMENT |
| LOW⚡ | …gestion/source/pipeline/databrickspipeline/metadata.py | 896 | # Step 2: Create table-to-table lineage for downstream dependencies | COMMENT |
| LOW | …gestion/source/pipeline/databrickspipeline/metadata.py | 814 | # Step 1: Create Kafka topic -> DLT table lineage | COMMENT |
| LOW⚡ | ingestion/src/metadata/cli/scaffold.py | 1533 | s.append("## Step 4: Code Generation and Formatting") | STRING |
| LOW⚡ | ingestion/src/metadata/cli/scaffold.py | 1546 | s.append("## Step 5: Write Tests and Validate") | STRING |
| LOW | ingestion/src/metadata/cli/scaffold.py | 1381 | s.append("## Step 1: Read the Reference Connector") | STRING |
| LOW | ingestion/src/metadata/cli/scaffold.py | 1406 | s.append("## Step 2: Implement the Connector Files") | STRING |
| LOW | ingestion/src/metadata/cli/scaffold.py | 1509 | s.append("## Step 3: Register the Connector") | STRING |
| LOW | …ta/profiler/metrics/hybrid/cardinality_distribution.py | 92 | # Step 1: Get value counts and ranks | COMMENT |
| LOW | …ta/profiler/metrics/hybrid/cardinality_distribution.py | 120 | # Step 3: Final aggregation with simple GROUP BY | COMMENT |
| LOW | bin/distributed-test/CLUSTER-SIZING-RUNBOOK.md | 37 | ### Step 1: Environment Setup | COMMENT |
| LOW | bin/distributed-test/CLUSTER-SIZING-RUNBOOK.md | 77 | ### Step 2: Find Optimal Concurrency (Optional) | COMMENT |
| LOW | bin/distributed-test/CLUSTER-SIZING-RUNBOOK.md | 95 | ### Step 3: Run Progressive Benchmark | COMMENT |
| LOW | bin/distributed-test/CLUSTER-SIZING-RUNBOOK.md | 165 | ### Step 4: Analyze Results | COMMENT |
| LOW | bin/distributed-test/CLUSTER-SIZING-RUNBOOK.md | 223 | ### Step 5: Apply Recommendations | COMMENT |
| LOW | bin/distributed-test/CLUSTER-SIZING-RUNBOOK.md | 314 | ### Step 6: Re-validate | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4128 | // Step 1: Ingestion creates entities (no tags) | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4133 | // Step 2: User adds tags to entities via PATCH | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4151 | // Step 3: Ingestion re-runs — bulk update with only description changes (no tags in request) | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4158 | // Step 4: Verify tags are still present after re-ingestion | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4178 | // Step 1: Ingestion creates entities (no owners) | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4183 | // Step 2: User adds owners via PATCH | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4194 | // Step 3: Re-ingestion with only description changes | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4201 | // Step 4: Verify owners preserved | COMMENT |
| LOW⚡ | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3060 | // Step 1: Create a dedicated glossary for this test to avoid interference | COMMENT |
| LOW⚡ | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3067 | // Step 2: Create two terms - both should start as APPROVED (default status when no reviewers) | COMMENT |
| LOW⚡ | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3084 | // Step 3: Update the second term to IN_REVIEW status | COMMENT |
| LOW⚡ | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3089 | // Step 4: Search without entityStatus filter - both terms should be returned | COMMENT |
| LOW | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3106 | // Step 5: Search with APPROVED status - only the first term should be returned | COMMENT |
| LOW | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3128 | // Step 6: Search with IN_REVIEW status - only the second term should be returned | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1688 | // Step 1: Get the existing Certification classification (seeded by the system) | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1693 | // Step 2: Create a new tag under Certification | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1703 | // Step 3: Create the DB hierarchy and a DatabaseSchema | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1710 | // Step 4: Apply the certification tag to the DatabaseSchema via setCertification() | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1769 | // Step 6: Rename the certification tag (change its name — this changes the FQN) | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1777 | // Step 7: Wait until certification tagFQN propagates to the entity | COMMENT |
| LOW | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1734 | // Step 5: Verify search finds the schema by the original tag FQN | COMMENT |
| LOW | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1800 | // Step 8: Search must find the schema under the new tag FQN | COMMENT |
| LOW | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1836 | // Step 9: Delete the certification tag and verify the schema no longer has a certification | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 68 | // Step 1: Create two domains - source and target | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 72 | // Step 2: Create a data product in the source domain | COMMENT |
| LOW | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 85 | // Step 3: Create tables with source domain and add them as assets to the data product | COMMENT |
| LOW | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 115 | // Step 4: Change the data product's domain from source to target | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 135 | // Step 5: Verify assets now have target domain via API (database check - THE KEY TEST) | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 139 | // Step 6: Verify assets appear in target domain's /assets endpoint (THE ACTUAL USER ENDPOINT) | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 143 | // Step 7: Verify assets now appear in target domain's search (search index check) | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 146 | // Step 8: Verify assets no longer appear in source domain's search | COMMENT |
| LOW | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 70 | // Step 1: Create a policy that allows VIEW_ALL on entities with PII.Sensitive tag | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 87 | // Step 2: Create a role with that policy | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 96 | // Step 3: Create a team with that role as default | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 106 | // Step 4: Create a user in that team | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 120 | // Step 5: Create database service and schema using factories | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 128 | // Step 6: Create a table WITH the PII.Sensitive tag using fluent API | COMMENT |
| LOW | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 149 | // Step 7: Create a query that references the table (query does NOT have the tag) | COMMENT |
| 287 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | ingestion/tests/unit/test_ometa_utils.py | 165 | # Create a mock JWT payload | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_ometa_utils.py | 177 | # Create a mock JWT token (header.payload.signature) | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_ometa_utils.py | 189 | # Create a payload that will need padding | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_dbt.py | 812 | # Create a mock manifest node with list of owners | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_dbt.py | 829 | # Create a mock manifest node with list of owners | COMMENT |
| MEDIUM | ingestion/tests/unit/test_dbt.py | 736 | # Create a mock manifest node with openmetadata.owner | COMMENT |
| MEDIUM | ingestion/tests/unit/test_dbt.py | 752 | # Create a mock manifest node with old format owner | COMMENT |
| MEDIUM | ingestion/tests/unit/test_dbt.py | 2285 | # Create a mock source node | COMMENT |
| MEDIUM | ingestion/tests/unit/test_db_utils.py | 69 | # Create a mock table entity | COMMENT |
| MEDIUM | ingestion/tests/unit/test_db_utils.py | 81 | # Create a mock source table entity for lineage tests | COMMENT |
| MEDIUM | ingestion/tests/unit/test_db_utils.py | 94 | # Create a mock TableView | COMMENT |
| MEDIUM | ingestion/tests/unit/test_db_utils.py | 278 | # Create a valid AddLineageRequest for the mock | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_lineage_empty_result.py | 28 | # Create an in-memory SQLite database for testing | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/test_lineage_empty_result.py | 31 | # Create a test table | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/topology/test_context_manager.py | 46 | # Create a new thread context based on the main thread | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/topology/test_context_manager.py | 48 | # Create the new thread context based on the main thread one | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/topology/test_context_manager.py | 64 | # Create the new thread context based on the main thread one | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/test_queue.py | 34 | # Create a new QueueItem and add it to the queue | COMMENT |
| MEDIUM | …/tests/unit/topology/database/test_burstiq_metadata.py | 78 | # Create a mock source instance | COMMENT |
| MEDIUM⚡ | …estion/tests/unit/topology/database/test_databricks.py | 834 | # Create a mock inspector | COMMENT |
| MEDIUM⚡ | …estion/tests/unit/topology/database/test_databricks.py | 842 | # Create a mock dialect with get_table_names method | COMMENT |
| MEDIUM⚡ | …estion/tests/unit/topology/database/test_databricks.py | 866 | # Create a mock inspector | COMMENT |
| MEDIUM⚡ | …estion/tests/unit/topology/database/test_databricks.py | 874 | # Create a mock dialect with get_view_names method | COMMENT |
| MEDIUM | …estion/tests/unit/topology/database/test_databricks.py | 899 | # Create a mock dialect instance | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/topology/database/test_sap_hana.py | 191 | # Create a mock engine and connection | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/topology/database/test_sap_hana.py | 201 | # Create a DataSource with DATA_BASE_TABLE type | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_sap_hana.py | 235 | # Create a simple parsed lineage | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_sap_hana.py | 708 | # Create a scenario with circular dependencies | COMMENT |
| MEDIUM | …gestion/tests/unit/topology/database/test_deltalake.py | 134 | # Create the DF as a tmp view to be able to run Spark SQL statements on top | COMMENT |
| MEDIUM | …gestion/tests/unit/topology/database/test_deltalake.py | 139 | # Create a database. We will be ingesting that as a schema | COMMENT |
| MEDIUM | …tion/tests/unit/topology/database/test_athena_utils.py | 72 | # Create a column object that raises AttributeError when accessing parameters | COMMENT |
| MEDIUM | …tion/tests/unit/topology/database/test_athena_utils.py | 107 | # Create a column object without parameters attribute | COMMENT |
| MEDIUM | …tion/tests/unit/topology/database/test_athena_utils.py | 138 | # Create a column object with None parameters | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 458 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 501 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 514 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 530 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 569 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 582 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 622 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 661 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 692 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 722 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 744 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 765 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/database/test_postgres.py | 811 | # Create a mock source config with the required attributes | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/pipeline/test_airflow.py | 453 | # Create a mock serialized DAG result | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/pipeline/test_airflow.py | 492 | # Create a mock serialized DAG result | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/pipeline/test_airflow.py | 773 | # Create a new AirflowSource instance (or use self.airflow if safe) | COMMENT |
| MEDIUM | …tion/tests/unit/topology/pipeline/test_kafkaconnect.py | 360 | # Create a minimal source instance | COMMENT |
| MEDIUM | …tion/tests/unit/topology/pipeline/test_kafkaconnect.py | 545 | # Create a mock source that bypasses __init__ | COMMENT |
| MEDIUM | …tion/tests/unit/topology/pipeline/test_kafkaconnect.py | 551 | # Create a mock Debezium CDC topic with nested envelope structure | COMMENT |
| MEDIUM | …tion/tests/unit/topology/pipeline/test_kafkaconnect.py | 670 | # Create a regular (non-CDC) topic | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/search/test_opensearch.py | 138 | # Create a mock search service. Adjust the serviceType if you have a dedicated type for OpenSearch. | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/dashboard/test_looker.py | 694 | # Create a dashboard with no user_id | STRING |
| MEDIUM | …n/tests/unit/topology/dashboard/test_grafana_simple.py | 29 | # Create a minimal instance just for testing the method | COMMENT |
| MEDIUM | ingestion/tests/unit/topology/dashboard/test_tableau.py | 730 | # Create a mock dashboard with owner information | COMMENT |
| MEDIUM | …estion/tests/unit/topology/dashboard/_test_superset.py | 486 | # Create a dashboard without position_json (Superset 5.0.0 list endpoint) | COMMENT |
| MEDIUM | …estion/tests/unit/topology/dashboard/_test_superset.py | 516 | # Create a dashboard WITH position_json (Superset 4.x list endpoint) | COMMENT |
| MEDIUM | …unit/topology/dashboard/test_looker_extends_lineage.py | 77 | # Create a view that extends another view | COMMENT |
| 92 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | ingestion/operators/docker/exit_handler.py | 119 | CODE | |
| LOW | ingestion/operators/docker/exit_handler.py | 222 | CODE | |
| LOW | …stion/tests/unit/test_workflow_parse_example_config.py | 15 | CODE | |
| LOW | ingestion/tests/unit/test_dbt.py | 2211 | CODE | |
| LOW | ingestion/tests/unit/test_dbt.py | 2281 | CODE | |
| LOW | ingestion/tests/unit/test_dbt.py | 2513 | CODE | |
| LOW | ingestion/tests/unit/test_parser_connection_class.py | 97 | CODE | |
| LOW | ingestion/tests/unit/topology/database/test_sap_hana.py | 373 | CODE | |
| LOW | …tion/tests/unit/topology/database/test_athena_utils.py | 69 | CODE | |
| LOW | …tion/tests/unit/topology/database/test_athena_utils.py | 104 | CODE | |
| LOW | …tion/tests/unit/topology/database/test_athena_utils.py | 135 | CODE | |
| LOW | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 769 | CODE | |
| LOW | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 2044 | CODE | |
| LOW | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 2136 | CODE | |
| LOW | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 2286 | CODE | |
| LOW | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 822 | CODE | |
| LOW | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 2208 | CODE | |
| LOW | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 2340 | CODE | |
| LOW | …sts/unit/topology/pipeline/test_databricks_pipeline.py | 270 | CODE | |
| LOW | …sts/unit/topology/pipeline/test_databricks_pipeline.py | 399 | CODE | |
| LOW | …sts/unit/topology/pipeline/test_databricks_pipeline.py | 313 | CODE | |
| LOW | …sts/unit/topology/pipeline/test_databricks_pipeline.py | 361 | CODE | |
| LOW | …sts/unit/topology/pipeline/test_databricks_pipeline.py | 448 | CODE | |
| LOW | …sts/unit/topology/pipeline/test_databricks_pipeline.py | 494 | CODE | |
| LOW | …sts/unit/topology/dashboard/test_hex_ingestion_flow.py | 108 | CODE | |
| LOW | …sts/unit/topology/dashboard/test_hex_ingestion_flow.py | 243 | CODE | |
| LOW | …sts/unit/topology/dashboard/test_hex_ingestion_flow.py | 382 | CODE | |
| LOW | …sts/unit/topology/dashboard/test_hex_ingestion_flow.py | 431 | CODE | |
| LOW | …sts/unit/topology/dashboard/test_hex_ingestion_flow.py | 532 | CODE | |
| LOW | …sts/unit/topology/dashboard/test_hex_ingestion_flow.py | 580 | CODE | |
| LOW | …estion/tests/unit/topology/dashboard/test_qlikcloud.py | 441 | CODE | |
| LOW | …quality/validations/test_row_count_logic_with_total.py | 8 | CODE | |
| LOW | …lity/validations/test_passed_failed_row_calculation.py | 8 | CODE | |
| LOW | …t/observability/profiler/pandas/test_custom_metrics.py | 163 | CODE | |
| LOW | …t/observability/profiler/pandas/test_custom_metrics.py | 254 | CODE | |
| LOW | …tests/unit/sampler/test_container_sampler_processor.py | 156 | CODE | |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 119 | CODE | |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 234 | CODE | |
| LOW | ingestion/tests/unit/lineage/queries/helpers.py | 401 | CODE | |
| LOW | ingestion/tests/unit/sdk/test_sdk_fluent_api.py | 40 | CODE | |
| LOW | ingestion/tests/cli_e2e/test_cli_tableau.py | 308 | CODE | |
| LOW | ingestion/tests/cli_e2e/test_cli_tableau.py | 361 | CODE | |
| LOW | ingestion/tests/cli_e2e/test_cli_tableau.py | 388 | CODE | |
| LOW | ingestion/tests/cli_e2e/test_cli_tableau.py | 496 | CODE | |
| LOW | ingestion/tests/cli_e2e/common/test_cli_db.py | 115 | CODE | |
| LOW | …/integration/ometa/test_ometa_custom_properties_api.py | 532 | CODE | |
| LOW | …assification/databases/test_azuresql_temporal_table.py | 148 | CODE | |
| LOW | ingestion/tests/integration/fivetran/conftest.py | 249 | CODE | |
| LOW | …stion/tests/integration/data_quality/test_data_diff.py | 610 | CODE | |
| LOW | ingestion/tests/integration/trino/test_classifier.py | 27 | CODE | |
| LOW | ingestion/tests/integration/sftp/conftest.py | 65 | CODE | |
| LOW | …integration/datalake/test_table_rule_library_pandas.py | 40 | CODE | |
| LOW | …tests/integration/datalake/test_rule_library_pandas.py | 50 | CODE | |
| LOW | …/tests/integration/powerbi/test_powerbi_file_client.py | 82 | CODE | |
| LOW | …/tests/integration/sources/mlmodels/mlflow/conftest.py | 77 | CODE | |
| LOW | …sts/integration/sources/mlmodels/mlflow/test_mlflow.py | 70 | CODE | |
| LOW | ingestion/tests/load/test_load.py | 41 | CODE | |
| LOW | ingestion/tests/load/test_resources/all_resources.py | 16 | CODE | |
| LOW | …enmetadata_testutils/pytest_openmetadata/test_utils.py | 7 | CODE | |
| LOW | …ion/src/_openmetadata_testutils/pydantic/test_utils.py | 7 | CODE | |
| 484 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | generate_ts.sh | 1 | #!/bin/bash | COMMENT |
| LOW | ingestion/airflow-constraints-3.2.1.txt | 1 | COMMENT | |
| LOW | ingestion/airflow-constraints-3.2.1.txt | 21 | # | COMMENT |
| LOW | ingestion/pyproject.toml | 341 | allowedUntypedLibraries = [] | COMMENT |
| LOW | ingestion/setup.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/ingestion_dependency.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | ingestion/noxfile.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/conftest.py | 1 | import math | COMMENT |
| LOW | ingestion/tests/unit/test_usage_filter.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/test_usage_log.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …gestion/tests/unit/topology/database/test_snowflake.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/topology/database/test_datalake.py | 1 | # pylint: disable=line-too-long | COMMENT |
| LOW | …estion/tests/unit/topology/database/test_databricks.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/topology/database/test_bigquery.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/topology/pipeline/test_nifi.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/topology/pipeline/test_airbyte.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/topology/pipeline/test_spline.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/topology/pipeline/test_dbtcloud.py | 2381 | COMMENT | |
| LOW | …it/topology/dashboard/test_dashboard_group_progress.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/topology/drive/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/pii/algorithms/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/pii/algorithms/data/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …ests/unit/source/database/deltalake/test_connection.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …n/tests/unit/source/database/saperp/test_connection.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …/tests/unit/source/database/burstiq/test_connection.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …tion/tests/unit/source/database/sas/test_connection.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …sts/unit/source/database/salesforce/test_connection.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …s/unit/source/database/domodatabase/test_connection.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/pipeline/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …estion/tests/unit/source/pipeline/fivetran/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/pipeline/nifi/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/pipeline/flink/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …gestion/tests/unit/source/pipeline/dagster/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …gestion/tests/unit/source/pipeline/airflow/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …ts/unit/source/pipeline/databrickspipeline/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …estion/tests/unit/source/pipeline/dbtcloud/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …on/tests/unit/source/pipeline/kafkaconnect/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/pipeline/spline/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …ion/tests/unit/source/pipeline/openlineage/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …gestion/tests/unit/source/pipeline/airbyte/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …on/tests/unit/source/pipeline/gluepipeline/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …on/tests/unit/source/pipeline/domopipeline/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/mlmodel/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/mlmodel/mlflow/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …estion/tests/unit/source/mlmodel/sagemaker/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/mcp/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/storage/s3/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/storage/gcs/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …estion/tests/unit/source/search/opensearch/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …ion/tests/unit/source/search/elasticsearch/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/dashboard/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/dashboard/ssrs/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …/tests/unit/source/dashboard/microstrategy/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …ion/tests/unit/source/dashboard/quicksight/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …tion/tests/unit/source/dashboard/qlikcloud/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …gestion/tests/unit/source/dashboard/looker/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | …estion/tests/unit/source/dashboard/tableau/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/dashboard/hex/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| LOW | ingestion/tests/unit/source/dashboard/mode/__init__.py | 1 | # Copyright 2025 Collate | COMMENT |
| 389 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …src/metadata/ingestion/source/database/dbt/metadata.py | 450 | # Step 1: Check if property exists in OpenMetadata | COMMENT |
| LOW | …src/metadata/ingestion/source/database/dbt/metadata.py | 466 | # Step 2: Validate and convert value (single pass) | COMMENT |
| LOW⚡ | …gestion/source/pipeline/databrickspipeline/metadata.py | 896 | # Step 2: Create table-to-table lineage for downstream dependencies | COMMENT |
| LOW | …gestion/source/pipeline/databrickspipeline/metadata.py | 814 | # Step 1: Create Kafka topic -> DLT table lineage | COMMENT |
| LOW⚡ | ingestion/src/metadata/cli/scaffold.py | 1533 | s.append("## Step 4: Code Generation and Formatting") | STRING |
| LOW⚡ | ingestion/src/metadata/cli/scaffold.py | 1546 | s.append("## Step 5: Write Tests and Validate") | STRING |
| LOW | ingestion/src/metadata/cli/scaffold.py | 1381 | s.append("## Step 1: Read the Reference Connector") | STRING |
| LOW | ingestion/src/metadata/cli/scaffold.py | 1406 | s.append("## Step 2: Implement the Connector Files") | STRING |
| LOW | ingestion/src/metadata/cli/scaffold.py | 1509 | s.append("## Step 3: Register the Connector") | STRING |
| LOW | …ta/profiler/metrics/hybrid/cardinality_distribution.py | 92 | # Step 1: Get value counts and ranks | COMMENT |
| LOW | …ta/profiler/metrics/hybrid/cardinality_distribution.py | 120 | # Step 3: Final aggregation with simple GROUP BY | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4128 | // Step 1: Ingestion creates entities (no tags) | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4133 | // Step 2: User adds tags to entities via PATCH | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4151 | // Step 3: Ingestion re-runs — bulk update with only description changes (no tags in request) | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4158 | // Step 4: Verify tags are still present after re-ingestion | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4178 | // Step 1: Ingestion creates entities (no owners) | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4183 | // Step 2: User adds owners via PATCH | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4194 | // Step 3: Re-ingestion with only description changes | COMMENT |
| LOW⚡ | …/test/java/org/openmetadata/it/tests/BaseEntityIT.java | 4201 | // Step 4: Verify owners preserved | COMMENT |
| LOW⚡ | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3060 | // Step 1: Create a dedicated glossary for this test to avoid interference | COMMENT |
| LOW⚡ | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3067 | // Step 2: Create two terms - both should start as APPROVED (default status when no reviewers) | COMMENT |
| LOW⚡ | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3084 | // Step 3: Update the second term to IN_REVIEW status | COMMENT |
| LOW⚡ | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3089 | // Step 4: Search without entityStatus filter - both terms should be returned | COMMENT |
| LOW | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3106 | // Step 5: Search with APPROVED status - only the first term should be returned | COMMENT |
| LOW | …/org/openmetadata/it/tests/GlossaryTermResourceIT.java | 3128 | // Step 6: Search with IN_REVIEW status - only the second term should be returned | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1688 | // Step 1: Get the existing Certification classification (seeded by the system) | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1693 | // Step 2: Create a new tag under Certification | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1703 | // Step 3: Create the DB hierarchy and a DatabaseSchema | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1710 | // Step 4: Apply the certification tag to the DatabaseSchema via setCertification() | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1769 | // Step 6: Rename the certification tag (change its name — this changes the FQN) | COMMENT |
| LOW⚡ | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1777 | // Step 7: Wait until certification tagFQN propagates to the entity | COMMENT |
| LOW | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1734 | // Step 5: Verify search finds the schema by the original tag FQN | COMMENT |
| LOW | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1800 | // Step 8: Search must find the schema under the new tag FQN | COMMENT |
| LOW | …test/java/org/openmetadata/it/tests/TagResourceIT.java | 1836 | // Step 9: Delete the certification tag and verify the schema no longer has a certification | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 68 | // Step 1: Create two domains - source and target | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 72 | // Step 2: Create a data product in the source domain | COMMENT |
| LOW | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 85 | // Step 3: Create tables with source domain and add them as assets to the data product | COMMENT |
| LOW | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 115 | // Step 4: Change the data product's domain from source to target | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 135 | // Step 5: Verify assets now have target domain via API (database check - THE KEY TEST) | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 139 | // Step 6: Verify assets appear in target domain's /assets endpoint (THE ACTUAL USER ENDPOINT) | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 143 | // Step 7: Verify assets now appear in target domain's search (search index check) | COMMENT |
| LOW⚡ | …penmetadata/it/tests/DataProductDomainMigrationIT.java | 146 | // Step 8: Verify assets no longer appear in source domain's search | COMMENT |
| LOW | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 70 | // Step 1: Create a policy that allows VIEW_ALL on entities with PII.Sensitive tag | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 87 | // Step 2: Create a role with that policy | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 96 | // Step 3: Create a team with that role as default | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 106 | // Step 4: Create a user in that team | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 120 | // Step 5: Create database service and schema using factories | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 128 | // Step 6: Create a table WITH the PII.Sensitive tag using fluent API | COMMENT |
| LOW | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 149 | // Step 7: Create a query that references the table (query does NOT have the tag) | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 169 | // Step 8: Verify the test user CAN view the table (due to tag-based policy) | COMMENT |
| LOW⚡ | …org/openmetadata/it/tests/QueryVisibilityPolicyIT.java | 178 | // Step 9: Verify the test user CAN view queries for that table | COMMENT |
| LOW⚡ | …java/org/openmetadata/it/tests/GlossaryResourceIT.java | 1025 | // Step 1: Create a glossary with initial version 0.1 | COMMENT |
| LOW⚡ | …java/org/openmetadata/it/tests/GlossaryResourceIT.java | 1030 | // Step 2: Prepare CSV content with multiple glossary terms | COMMENT |
| LOW⚡ | …java/org/openmetadata/it/tests/GlossaryResourceIT.java | 1033 | // Step 3: Import CSV using SYNC method (now also creates version history!) | COMMENT |
| LOW⚡ | …java/org/openmetadata/it/tests/GlossaryResourceIT.java | 1051 | // Step 4: Verify version incremented to 0.2 | COMMENT |
| LOW⚡ | …java/org/openmetadata/it/tests/GlossaryResourceIT.java | 1059 | // Step 5: Retrieve version history | COMMENT |
| LOW⚡ | …java/org/openmetadata/it/tests/GlossaryResourceIT.java | 1066 | // Step 6: Get version 0.2 and verify it has change description | COMMENT |
| LOW⚡ | …java/org/openmetadata/it/tests/GlossaryResourceIT.java | 1071 | // Step 7: Verify change description contains 'bulkImport' field change | COMMENT |
| LOW⚡ | …java/org/openmetadata/it/tests/GlossaryResourceIT.java | 1077 | // Step 8: Verify bulkImport field has statistics | COMMENT |
| LOW | …java/org/openmetadata/it/tests/GlossaryResourceIT.java | 1088 | // Step 9: Verify glossary terms were actually created | COMMENT |
| 204 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | ingestion/tests/unit/test_dbt.py | 1752 | self.assertTrue(validate_email_format("user@example.com")) | CODE |
| LOW⚡ | ingestion/tests/unit/test_dbt.py | 1902 | is_valid, error, value = validate_custom_property_value("testProp", "email", None, "user@example.com") | CODE |
| LOW⚡ | ingestion/tests/unit/test_dbt.py | 1904 | self.assertEqual(value, "user@example.com") | CODE |
| LOW⚡ | …ts/unit/topology/database/test_databricks_ownership.py | 215 | assert resolver.get_owner_ref("user@example.com") == "email-ref" | CODE |
| LOW⚡ | …ts/unit/topology/database/test_databricks_ownership.py | 228 | assert resolver.get_owner_ref("user@example.com") == "owner-ref" | CODE |
| LOW⚡ | …/unit/topology/database/test_databricks_get_columns.py | 133 | ("Owner", "user@example.com", None), | CODE |
| LOW | …nit/topology/database/test_bigquery_test_connection.py | 39 | "projectId": "placeholder", | CODE |
| LOW | …nit/topology/database/test_bigquery_test_connection.py | 42 | "clientEmail": "user@example.com", | CODE |
| LOW⚡ | …/database/test_redshift_incremental_table_processor.py | 136 | "COMMENT ON VIEW {table_name} IS 'lorem ipsum'", | CODE |
| LOW⚡ | …/database/test_redshift_incremental_table_processor.py | 140 | " \tCOMMENT \n ON VIEW {table_name}\n\t\n IS 'lorem ipsum'", | CODE |
| LOW | …s/unit/topology/pipeline/test_openlineage_ownership.py | 76 | user = build_user("jdoe", "John Doe") | CODE |
| LOW | ingestion/tests/unit/topology/search/test_opensearch.py | 59 | "securityConfig": {"jwtToken": "eyJraWQiOiJ...dummy_token..."}, | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_grafana.py | 247 | updatedBy="admin@example.com", | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_grafana.py | 248 | createdBy="admin@example.com", | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_grafana.py | 601 | "updatedBy": "user@example.com", | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_grafana.py | 602 | "createdBy": "admin@example.com", | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_grafana.py | 668 | updatedBy="user@example.com", | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_grafana.py | 669 | createdBy="admin@example.com", | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 573 | "displayName": "John Doe", | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 594 | "displayName": "John Doe", | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 603 | root=[EntityReference(id=uuid.uuid4(), name="John Doe", type="user")] | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 682 | displayName="Jane Doe", | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 854 | self.assertEqual(owner_ref.root[0].name, "John Doe") | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 870 | self.assertEqual(owner_ref.root[0].name, "John Doe") | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 1004 | return EntityReferenceList(root=[EntityReference(id=uuid.uuid4(), name="John Doe", type="user")]) | CODE |
| LOW | ingestion/tests/unit/topology/dashboard/test_powerbi.py | 1019 | self.assertIn("John Doe", owner_names) | CODE |
| LOW | ingestion/tests/unit/topology/drive/test_googledrive.py | 138 | owners=[GoogleDriveOwner(displayName="John Doe")], | CODE |
| LOW | ingestion/tests/unit/pii/test_ner_scanner.py | 33 | "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Nam consequat quam sagittis convallis cursus." | CODE |
| LOW | ingestion/tests/unit/pii/test_ner_scanner.py | 33 | "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Nam consequat quam sagittis convallis cursus." | CODE |
| LOW | ingestion/tests/unit/pii/test_ner_scanner.py | 106 | '{"email": "johndoe@example.com", "address": {"street": "123 Main St"}}', | CODE |
| LOW | …t/resources/datasets/databricks_pipeline_resource.json | 136 | "name": "John Doe" | CODE |
| LOW | …sts/unit/source/database/test_json_schema_extractor.py | 410 | json_values = [{"user-name": "John", "email@domain": "test@test.com"}] | CODE |
| LOW | …tests/unit/source/database/bigquery/test_connection.py | 43 | "projectId": "placeholder", | CODE |
| LOW | …tests/unit/source/database/bigquery/test_connection.py | 46 | "clientEmail": "user@example.com", | CODE |
| LOW | ingestion/tests/unit/source/messaging/test_pubsub.py | 245 | privateKey="fake-key", | CODE |
| LOW | …tion/tests/unit/observability/data_quality/conftest.py | 124 | fullname="John Doe", | CODE |
| LOW | …tion/tests/unit/observability/data_quality/conftest.py | 148 | fullname="John Doe", | CODE |
| LOW | …bservability/data_quality/test_validations_datalake.py | 45 | "John Doe", | CODE |
| LOW | …bservability/data_quality/test_validations_datalake.py | 71 | "John Doe", | CODE |
| LOW | …servability/profiler/custom_types/test_custom_types.py | 54 | fullname="John Doe", | CODE |
| LOW | …servability/profiler/custom_types/test_custom_types.py | 70 | fullname="John Doe", | CODE |
| LOW⚡ | …ity/profiler/sqlalchemy/test_sqa_profiler_interface.py | 188 | User(name="John", fullname="John Doe", nickname="johnny b goode", age=30), | CODE |
| LOW | …/unit/observability/profiler/sqlalchemy/test_sample.py | 160 | fullname="John Doe", | CODE |
| LOW | …/unit/observability/profiler/sqlalchemy/test_sample.py | 174 | fullname="John Doe", | CODE |
| LOW | …/unit/observability/profiler/sqlalchemy/test_sample.py | 320 | fullname="John Doe", | CODE |
| LOW | …unit/observability/profiler/sqlalchemy/test_metrics.py | 114 | fullname="John Doe", | CODE |
| LOW | …unit/observability/profiler/sqlalchemy/test_metrics.py | 136 | fullname="John Doe", | CODE |
| LOW | …nit/observability/profiler/sqlalchemy/test_profiler.py | 129 | User(name="John", fullname="John Doe", nickname="johnny b goode", age=30), | CODE |
| LOW | …/unit/observability/profiler/sqlalchemy/test_runner.py | 121 | fullname="John Doe", | CODE |
| LOW | …/unit/observability/profiler/sqlalchemy/test_runner.py | 135 | fullname="John Doe", | CODE |
| LOW | …ts/unit/observability/profiler/pandas/test_profiler.py | 305 | # Test with fullname column - it has repeated values ("John Doe", "Jone Doe" appear twice each) | COMMENT |
| LOW | ingestion/tests/unit/sdk/test_table_entity.py | 291 | rows=[["1", "user@example.com"]], | CODE |
| LOW | ingestion/tests/unit/sdk/test_table_entity.py | 300 | self.assertEqual(result.rows[0][1], "user@example.com") | CODE |
| LOW | ingestion/tests/unit/sdk/test_user_entity.py | 36 | displayName="John Doe", | CODE |
| LOW | ingestion/tests/unit/sdk/test_user_entity.py | 44 | expected_user.displayName = "John Doe" | CODE |
| LOW | ingestion/tests/unit/sdk/test_sdk_entities.py | 143 | displayName="John Doe", | CODE |
| LOW | ingestion/tests/unit/sdk/test_improved_entities.py | 349 | create_request = CreateUserRequest(name="john.doe", email="john.doe@company.com", displayName="John Doe") | CODE |
| LOW | ingestion/tests/unit/sdk/test_dashboard_entity.py | 197 | displayName="John Doe", | CODE |
| LOW | ingestion/tests/unit/sdk/test_dashboard_entity.py | 212 | self.assertEqual(result.owner.displayName, "John Doe") | CODE |
| LOW | ingestion/tests/unit/readers/test_dsv_reader.py | 260 | 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… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | ingestion/tests/unit/conftest.py | 12 | CODE | |
| LOW | …ts/unit/topology/database/test_vertica_type_mapping.py | 24 | CODE | |
| LOW | ingestion/tests/unit/topology/database/test_postgres.py | 862 | CODE | |
| LOW | ingestion/tests/unit/topology/database/test_postgres.py | 873 | CODE | |
| LOW | …profiler/sqlalchemy/azuresql/test_azuresql_sampling.py | 8 | CODE | |
| LOW | ingestion/tests/integration/sdk/test_sdk_integration.py | 8 | CODE | |
| LOW | ingestion/scripts/debug_tag_processor.py | 46 | CODE | |
| LOW | …estion/src/_openmetadata_testutils/helpers/__init__.py | 1 | CODE | |
| LOW | …/src/airflow_provider_openmetadata/lineage/callback.py | 27 | CODE | |
| LOW | …on/src/airflow_provider_openmetadata/lineage/status.py | 28 | CODE | |
| LOW | …on/src/airflow_provider_openmetadata/lineage/status.py | 29 | CODE | |
| LOW | …on/src/airflow_provider_openmetadata/lineage/status.py | 30 | CODE | |
| LOW | …on/src/airflow_provider_openmetadata/lineage/status.py | 31 | CODE | |
| LOW | ingestion/src/metadata/pii/algorithms/tag_scoring.py | 16 | CODE | |
| LOW | ingestion/src/metadata/ingestion/ometa/task_models.py | 19 | CODE | |
| LOW | …on/src/metadata/ingestion/ometa/announcement_models.py | 15 | CODE | |
| LOW | …tion/src/metadata/ingestion/ometa/mixins/feed_mixin.py | 15 | CODE | |
| LOW | …/metadata/ingestion/ometa/mixins/data_insight_mixin.py | 17 | CODE | |
| LOW | …/metadata/ingestion/ometa/mixins/announcement_mixin.py | 15 | CODE | |
| LOW | …ion/src/metadata/ingestion/ometa/mixins/patch_mixin.py | 58 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/registry.py | 32 | CODE | |
| LOW | …tion/src/metadata/ingestion/progress/runner_tracker.py | 35 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 23 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 23 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 23 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 28 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 28 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 28 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 28 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 34 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 34 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 34 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 34 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 34 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 41 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 41 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 41 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 46 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 46 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/modes.py | 24 | CODE | |
| LOW | ingestion/src/metadata/ingestion/progress/_render.py | 22 | CODE | |
| LOW | …/metadata/ingestion/source/database/glue/connection.py | 18 | CODE | |
| LOW | …a/ingestion/source/database/unitycatalog/connection.py | 15 | CODE | |
| LOW | …tadata/ingestion/source/database/timescale/__init__.py | 1 | CODE | |
| LOW | …data/ingestion/source/database/databricks/ownership.py | 15 | CODE | |
| LOW | …ata/ingestion/source/database/databricks/connection.py | 16 | CODE | |
| LOW | …adata/ingestion/source/database/bigquery/connection.py | 16 | CODE | |
| LOW | …data/ingestion/source/database/snowflake/connection.py | 16 | CODE | |
| LOW | …adata/ingestion/source/database/redshift/connection.py | 16 | CODE | |
| LOW | …adata/ingestion/source/database/postgres/connection.py | 16 | CODE | |
| LOW | …etadata/ingestion/source/database/cassandra/helpers.py | 15 | CODE | |
| LOW | …metadata/ingestion/source/database/mysql/connection.py | 16 | CODE | |
| LOW | …/metadata/ingestion/source/database/hive/connection.py | 191 | CODE | |
| LOW | …/metadata/ingestion/source/database/hive/connection.py | 217 | CODE | |
| LOW | …/database/hive/metastore_dialects/postgres/__init__.py | 17 | CODE | |
| LOW | …rce/database/hive/metastore_dialects/mysql/__init__.py | 17 | CODE | |
| LOW | …metadata/ingestion/source/database/mssql/connection.py | 16 | CODE | |
| LOW | …etadata/ingestion/source/database/athena/connection.py | 16 | CODE | |
| LOW | …/src/metadata/ingestion/source/pipeline/nifi/client.py | 34 | CODE | |
| LOW | …on/src/metadata/ingestion/source/mcp/mcp/connection.py | 19 | CODE | |
| 185 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | ingestion/tests/unit/test_owner_config.py | 129 | Unwrap OwnerValue Pydantic model to get actual value. OwnerValue wraps the actual values in nested root attrib | STRING |
| HIGH | …ion/src/metadata/ingestion/ometa/mixins/table_mixin.py | 453 | Get profile data Args: fqn (str): fullyQualifiedName start_ts (int): start timestamp | STRING |
| HIGH | …estion/src/metadata/ingestion/ometa/mixins/es_mixin.py | 346 | Paginate through the ES results, ignoring individual errors. Args: entity: The entity type | STRING |
| HIGH | …etadata/ingestion/source/database/bigquery/metadata.py | 275 | Get the project ID from the service connection or ADC. Args: service_connection: Optional | STRING |
| HIGH | …adata/ingestion/source/pipeline/kafkaconnect/client.py | 40 | Parse CDC topic names to extract database and table information. Common CDC topic naming patterns: - Debez | STRING |
| HIGH | …ta/ingestion/source/dashboard/hex/warehouse_queries.py | 209 | 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.py | 50 | Parse OpenAPI schema from HTTP response. Supports both JSON and YAML formats. Args: response: HTTP | STRING |
| HIGH | ingestion/src/metadata/ingestion/sink/metadata_rest.py | 969 | Generic dispatcher for ingesting sample data for any classifiable entity. Uses singledispatchmethod for | STRING |
| HIGH | …metadata/data_quality/validations/base_test_handler.py | 298 | Execute dimensional validation query for a single dimension column Must be implemented by child classes to supp | STRING |
| HIGH | …metadata/data_quality/validations/base_test_handler.py | 320 | Evaluate the test condition based on computed metrics This is the core logic that determines if the test passes | STRING |
| HIGH | …metadata/data_quality/validations/base_test_handler.py | 352 | Format 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.py | 123 | Run the metric query against the column Args: runner (QueryRunner): runner object witj sqlalchemy s | STRING |
| HIGH | …data_quality/validations/mixins/sqa_validator_mixin.py | 163 | compute row count for between tests Args: runner (QueryRunner): runner column (Column): | STRING |
| HIGH | …column/base/columnRuleLibrarySqlExpressionValidator.py | 63 | Compile SQL expression template using Jinja2. Replaces: - {{ column_name }} with the actual column name | STRING |
| HIGH | …data_quality/validations/table/sqlalchemy/tableDiff.py | 132 | Compile 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.py | 59 | Compile SQL expression template using Jinja2. Replaces: - {{ table_name }} with the actual table path | STRING |
| HIGH | ingestion/src/metadata/utils/credentials.py | 267 | Get Azure access token using the provided Azure configuration. Args: azure_config: Azure configuration | STRING |
| HIGH | ingestion/src/metadata/utils/helpers.py | 276 | Remove start and ending double quotes in a string Args: string (str): a string Raises: TypeErr | STRING |
| HIGH | …adata/utils/dependency_injector/dependency_injector.py | 328 | 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.py | 239 | Safely fetch entity by name with exception handling. Args: entity_type: Entity class to fetch | STRING |
| HIGH | …c/metadata/sdk/data_quality/workflow_config_builder.py | 265 | Safely fetch entity by ID with exception handling. Args: entity_type: Entity class to fetch | STRING |
| HIGH | ingestion/src/metadata/sdk/data_quality/runner.py | 123 | Initialize runner for a specific table FQN. Args: table_fqn: Fully qualified name of the table (e.g | STRING |
| HIGH | ingestion/src/metadata/sdk/data_quality/runner.py | 219 | Add multiple test definitions at once. Args: *test_definitions: Variable number of test definition | STRING |
| HIGH | …src/metadata/sdk/data_quality/dataframes/validators.py | 119 | Whether the validator requires a whole table to return appropriate results Examples: - `columnValuesToBeUni | STRING |
| HIGH | …data/sdk/data_quality/dataframes/validation_results.py | 119 | Merge multiple ValidationResult objects into one. Aggregates results from multiple validation runs, useful when | STRING |
| HIGH | ingestion/src/metadata/great_expectations/action1xx.py | 160 | Return run meta and check instance of data_asset Args: data_asset: data assets of the checkpoint ru | STRING |
| HIGH | ingestion/src/metadata/great_expectations/action1xx.py | 247 | Get execution engine used to run the expectation Args: data_asset: data assets of the checkpoint ru | STRING |
| HIGH | ingestion/src/metadata/great_expectations/action.py | 191 | Return run meta and check instance of data_asset Args: data_asset: data assets of the checkpoint ru | STRING |
| HIGH | ingestion/src/metadata/great_expectations/action.py | 288 | Get execution engine used to run the expectation Args: data_asset: data assets of the checkpoint ru | STRING |
| HIGH | …c/metadata/profiler/metrics/system/snowflake/system.py | 128 | Resolve the fully qualified name of the table from snowflake based on the following logic: 1. If the schema is p | STRING |
| HIGH | …c/metadata/profiler/metrics/system/snowflake/system.py | 164 | Get 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.py | 124 | create class method is used to dispatch the profiler protocol to the correct object based on the service connect | STRING |
| HIGH | ingestion/src/metadata/profiler/processor/core.py | 195 | Check if the profile data are empty. if empty then raise else return Args: profile (CreateTableProf | STRING |
| HIGH | ingestion/src/metadata/profiler/adaptors/factory.py | 54 | Create a client instance of the type of the given source client. Args: interface_type (str | STRING |
| HIGH | …on/src/metadata/profiler/orm/functions/unique_count.py | 30 | Get dialect-specific expressions for unique count computation. This centralizes all dialect-specific logic for | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | generate_ts.sh | 25 | # Check if a file path is provided | COMMENT |
| LOW | ingestion/noxfile.py | 31 | # 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.py | 51 | # Check if this is a non-current Iceberg column | COMMENT |
| LOW | ingestion/tests/unit/topology/database/test_glue.py | 248 | # Check if this is a non-current Iceberg column | COMMENT |
| LOW⚡ | …nit/topology/dashboard/test_looker_standalone_views.py | 126 | # Check if this is the last explore | COMMENT |
| LOW | …/utils/dependency_injector/test_dependency_injector.py | 256 | # Increment counter | COMMENT |
| LOW | ingestion/tests/cli_e2e/test_cli_tableau.py | 507 | # Check if field type matches expected | COMMENT |
| LOW | …on/src/airflow_provider_openmetadata/lineage/status.py | 83 | # Check if we already have a pipelineStatus for | COMMENT |
| LOW | …airflow_provider_openmetadata/lineage/config/loader.py | 52 | # Check if value is a literal string `true` | COMMENT |
| LOW | …estion/src/metadata/pii/scanners/custom_ner_scanner.py | 161 | # Check if confidence meets threshold | COMMENT |
| LOW | …ion/src/metadata/ingestion/ometa/mixins/patch_mixin.py | 816 | # Check if domains are already the same, skip if identical | COMMENT |
| LOW⚡ | …/src/metadata/ingestion/source/database/sample_data.py | 871 | # Check if service already exists | COMMENT |
| LOW | …c/metadata/ingestion/source/database/lineage_source.py | 224 | # Check if the process has timed out | COMMENT |
| LOW | …rc/metadata/ingestion/source/database/glue/metadata.py | 367 | # Check if this is an Iceberg table | COMMENT |
| LOW | …rc/metadata/ingestion/source/database/glue/metadata.py | 392 | # Check if this is a non-current Iceberg column | COMMENT |
| LOW⚡ | …rc/metadata/ingestion/source/database/glue/metadata.py | 409 | # Check if this is a non-current Iceberg column | COMMENT |
| LOW | …ata/ingestion/source/database/unitycatalog/metadata.py | 602 | # Check if the referred table exists in OpenMetadata before adding constraint | COMMENT |
| LOW | …src/metadata/ingestion/source/database/dbt/metadata.py | 490 | # Check if conversion failed (converted_value is None) | COMMENT |
| LOW | …rc/metadata/ingestion/source/database/dbt/dbt_utils.py | 189 | # Check if columns match exactly | COMMENT |
| LOW | …etadata/ingestion/source/database/databricks/client.py | 191 | # Check if queries executed successfully by fetching results | COMMENT |
| LOW | …etadata/ingestion/source/database/bigquery/metadata.py | 222 | # Check if the engine is established before setting project IDs | COMMENT |
| LOW | …ource/database/redshift/incremental_table_processor.py | 149 | # Check if Schema is present | COMMENT |
| LOW | …data/ingestion/source/database/saphana/cdata_parser.py | 415 | # Check if we've already processed this node | COMMENT |
| LOW | …src/metadata/ingestion/source/database/athena/utils.py | 147 | # Check if this is an Iceberg table | COMMENT |
| LOW | …src/metadata/ingestion/source/database/athena/utils.py | 176 | # Check if this is a non-current Iceberg column | COMMENT |
| LOW | …ta/ingestion/source/pipeline/airflow/lineage_parser.py | 274 | # Check if we can properly build the OMEntity class | COMMENT |
| LOW | …tadata/ingestion/source/pipeline/airflow/api/client.py | 65 | # Check if this is MWAA (AWS credentials) | COMMENT |
| LOW⚡ | …gestion/source/pipeline/databrickspipeline/metadata.py | 905 | # Check if source is a view/table that reads from S3 | COMMENT |
| LOW | …gestion/source/pipeline/databrickspipeline/metadata.py | 367 | # Check if it's a Databricks or Unity Catalog service | COMMENT |
| LOW | …gestion/source/pipeline/databrickspipeline/metadata.py | 787 | # Check if we have anything to process | COMMENT |
| LOW | …ion/source/pipeline/databrickspipeline/kafka_parser.py | 410 | # Check if it reads from Kafka | COMMENT |
| LOW | …ion/source/pipeline/databrickspipeline/kafka_parser.py | 422 | # Check if it reads from S3 | COMMENT |
| LOW | …ion/source/pipeline/databrickspipeline/kafka_parser.py | 472 | # Check if snapshot table is built | COMMENT |
| LOW | …ata/ingestion/source/pipeline/kafkaconnect/metadata.py | 258 | # Check if any broker hostname matches | COMMENT |
| LOW | …ata/ingestion/source/pipeline/kafkaconnect/metadata.py | 675 | # Check if this is a Debezium CDC envelope structure | COMMENT |
| LOW | …ata/ingestion/source/pipeline/kafkaconnect/metadata.py | 687 | # Check if schemaText has CDC envelope fields | COMMENT |
| LOW | …ata/ingestion/source/pipeline/kafkaconnect/metadata.py | 760 | # Check if it's a direct field | COMMENT |
| LOW | …ata/ingestion/source/pipeline/kafkaconnect/metadata.py | 764 | # Check if it's a child field (nested - one level deep) | COMMENT |
| LOW | …ata/ingestion/source/pipeline/kafkaconnect/metadata.py | 798 | # Check if this is a CDC envelope field | COMMENT |
| LOW | …ata/ingestion/source/pipeline/kafkaconnect/metadata.py | 1590 | # Check if this is a container dataset (storage sink) | COMMENT |
| LOW | …ata/ingestion/source/pipeline/kafkaconnect/metadata.py | 1618 | # Check if we have any topics to process | COMMENT |
| LOW | …adata/ingestion/source/pipeline/kafkaconnect/client.py | 67 | # Check if topic starts with the server name prefix | COMMENT |
| LOW | …adata/ingestion/source/pipeline/kafkaconnect/client.py | 82 | # Check if topic exactly matches server name (edge case) | COMMENT |
| LOW | …adata/ingestion/source/pipeline/kafkaconnect/client.py | 321 | # Check if this is Confluent Cloud format (array of {config, value}) | COMMENT |
| LOW | …n/src/metadata/ingestion/source/storage/s3/metadata.py | 809 | # Check if custom console endpoint URL is configured (for external S3-compatible storage) | COMMENT |
| LOW | …n/src/metadata/ingestion/source/storage/s3/metadata.py | 833 | # Check if custom console endpoint URL is configured (for external S3-compatible storage) | COMMENT |
| LOW | …/src/metadata/ingestion/source/storage/gcs/metadata.py | 135 | # Check if we have entries in the manifest file belonging to this bucket | COMMENT |
| LOW | …metadata/ingestion/source/dashboard/looker/metadata.py | 497 | # Check if filtered | COMMENT |
| LOW | …adata/ingestion/source/dashboard/looker/bulk_parser.py | 100 | # Check if any suffix is in our extension list | COMMENT |
| LOW | …c/metadata/ingestion/source/dashboard/looker/parser.py | 162 | # Check if any suffix is in our extension list | COMMENT |
| LOW⚡ | …rc/metadata/ingestion/source/dashboard/hex/metadata.py | 255 | # Check if we have lineage data for this project | COMMENT |
| LOW | …/src/metadata/ingestion/source/dashboard/hex/client.py | 63 | # Check if we got a successful response with data | COMMENT |
| LOW | …/metadata/ingestion/source/dashboard/grafana/client.py | 111 | # Check if we need to fetch more pages | COMMENT |
| LOW⚡ | …/metadata/ingestion/source/dashboard/grafana/client.py | 148 | # Check if we need to fetch more pages | COMMENT |
| LOW | …etadata/ingestion/source/dashboard/powerbi/metadata.py | 1197 | # Check if source expression references a dataset expression | COMMENT |
| LOW | …etadata/ingestion/source/dashboard/powerbi/metadata.py | 1218 | # Check if this is a direct BigQuery connection | COMMENT |
| LOW | …etadata/ingestion/source/dashboard/powerbi/metadata.py | 1378 | # Check if schema has a parent (database) | COMMENT |
| LOW | …ion/src/metadata/ingestion/source/api/rest/metadata.py | 333 | # Check if type exists in DataTypeTopic enum | COMMENT |
| LOW | …ion/src/metadata/ingestion/source/api/rest/metadata.py | 523 | # Check if it's `object` type field | COMMENT |
| LOW | …etadata/ingestion/source/drive/googledrive/metadata.py | 456 | # Check if parent directory was included (if it has a parent) | COMMENT |
| 30 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …on/tests/cli_e2e/test_cli_bigquery_multiple_project.py | 61 | def update_table_row(self) -> None: | STRING |
| LOW | ingestion/tests/cli_e2e/test_cli_redshift.py | 108 | def update_table_row(self) -> None: | STRING |
| LOW | ingestion/tests/cli_e2e/test_cli_bigquery.py | 94 | def update_table_row(self) -> None: | STRING |
| LOW | ingestion/tests/cli_e2e/test_cli_snowflake.py | 172 | def update_table_row(self) -> None: | STRING |
| LOW | ingestion/tests/cli_e2e/base/test_cli_db.py | 432 | def update_table_row() -> None: | CODE |
| LOW⚡ | ingestion/tests/cli_e2e/base/test_cli.py | 77 | def set_ingestion_bot_jwt_token(cls) -> None: | CODE |
| LOW | ingestion/tests/integration/conftest.py | 165 | logger = logging.getLogger(__name__) | CODE |
| LOW | ingestion/tests/integration/ometa/conftest.py | 62 | logger = logging.getLogger(__name__) | CODE |
| LOW | …assification/databases/test_azuresql_temporal_table.py | 104 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ests/integration/orm_profiler/test_orm_profiler_e2e.py | 52 | logger = logging.getLogger(__name__) | CODE |
| LOW | ingestion/tests/integration/data_quality/conftest.py | 27 | __all__ = [ | CODE |
| LOW | ingestion/tests/load/test_resources/all_resources.py | 13 | logger = logging.getLogger(__name__) | CODE |
| LOW | …estion/src/_openmetadata_testutils/helpers/__init__.py | 3 | __all__ = ["xfail_param"] | CODE |
| LOW | …on/src/airflow_provider_openmetadata/lineage/runner.py | 25 | logger = logging.getLogger(__name__) | CODE |
| LOW | …/src/airflow_provider_openmetadata/lineage/operator.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | ingestion/src/metadata/pii/algorithms/presidio_utils.py | 110 | def set_presidio_logger_level(log_level: int | str = logging.ERROR) -> None: | CODE |
| LOW | …stion/src/metadata/ingestion/ometa/mixins/csv_mixin.py | 17 | logger = logging.getLogger(__name__) | CODE |
| LOW | ingestion/src/metadata/ingestion/progress/registry.py | 139 | def set_total(self, type_: str, total: Optional[int]) -> None: # noqa: UP045 | CODE |
| LOW | ingestion/src/metadata/ingestion/progress/registry.py | 146 | def set_reconcilable(self, type_: str) -> None: | CODE |
| LOW | ingestion/src/metadata/ingestion/progress/__init__.py | 51 | __all__ = [ | CODE |
| LOW | ingestion/src/metadata/ingestion/progress/modes.py | 45 | def set_total(self, entity_type: str, total: Optional[int]) -> None: # noqa: UP045 | CODE |
| LOW | …etadata/ingestion/source/database/sqlalchemy_source.py | 54 | def set_inspector(self, database_name: str) -> None: | CODE |
| LOW | …metadata/ingestion/source/database/common_db_source.py | 138 | def set_inspector(self, database_name: str) -> None: | CODE |
| LOW | …/metadata/ingestion/source/database/presto/metadata.py | 131 | def set_inspector(self, database_name: str) -> None: | CODE |
| LOW⚡ | …etadata/ingestion/source/database/bigtable/metadata.py | 179 | def _set_nested(dct: dict, keys: List[str], value: any) -> None: # noqa: UP006 | CODE |
| LOW⚡ | …ata/ingestion/source/database/unitycatalog/metadata.py | 270 | def _set_incremental_table_processor(self, catalog: str) -> None: | CODE |
| LOW | …e/database/unitycatalog/incremental_table_processor.py | 56 | def set_table_map(self, catalog: str, start_timestamp: int) -> None: | CODE |
| LOW | …c/metadata/ingestion/source/database/trino/metadata.py | 253 | def set_inspector(self, database_name: str) -> None: | CODE |
| LOW | …metadata/ingestion/source/database/trino/connection.py | 237 | def set_basic_auth(connection: TrinoConnectionConfig, connection_args: ConnectionArguments) -> None: | CODE |
| LOW | …metadata/ingestion/source/database/trino/connection.py | 265 | def set_jwt_auth(connection: TrinoConnectionConfig, connection_args: ConnectionArguments) -> None: | CODE |
| LOW | …metadata/ingestion/source/database/trino/connection.py | 288 | def set_azure_auth(connection: TrinoConnectionConfig, connection_args: ConnectionArguments) -> None: | CODE |
| LOW | …metadata/ingestion/source/database/trino/connection.py | 308 | def set_oauth2_auth(connection: TrinoConnectionConfig, connection_args: ConnectionArguments) -> None: | CODE |
| LOW | …tadata/ingestion/source/database/timescale/__init__.py | 3 | __all__ = ["TimescaleSource"] | CODE |
| LOW | …adata/ingestion/source/database/databricks/metadata.py | 879 | def set_inspector(self, database_name: str) -> None: | CODE |
| LOW | …ta/ingestion/source/database/snowflake/query_parser.py | 88 | def set_session_query_tag(self) -> None: | CODE |
| LOW⚡ | …tadata/ingestion/source/database/snowflake/metadata.py | 301 | def set_partition_details(self) -> None: | CODE |
| LOW⚡ | …tadata/ingestion/source/database/snowflake/metadata.py | 308 | def set_schema_description_map(self) -> None: | CODE |
| LOW⚡ | …tadata/ingestion/source/database/snowflake/metadata.py | 314 | def set_database_description_map(self) -> None: | CODE |
| LOW⚡ | …tadata/ingestion/source/database/snowflake/metadata.py | 321 | def set_external_location_map(self, database_name: str) -> None: | CODE |
| LOW⚡ | …tadata/ingestion/source/database/snowflake/metadata.py | 329 | def set_schema_tags_map(self, database_name: str) -> None: | CODE |
| LOW | …tadata/ingestion/source/database/snowflake/metadata.py | 282 | def set_session_query_tag(self) -> None: | CODE |
| LOW | …tadata/ingestion/source/database/snowflake/metadata.py | 360 | def set_database_tags_map(self, database_name: str) -> None: | CODE |
| LOW | …etadata/ingestion/source/database/redshift/metadata.py | 274 | def set_external_location_map(self, database_name: str) -> None: | CODE |
| LOW⚡ | …etadata/ingestion/source/database/postgres/metadata.py | 151 | def set_schema_description_map(self) -> None: | CODE |
| LOW | …/database/hive/metastore_dialects/postgres/__init__.py | 20 | __all__ = ["HivePostgresMetaStoreDialect"] | CODE |
| LOW | …rce/database/hive/metastore_dialects/mysql/__init__.py | 20 | __all__ = ["HiveMysqlMetaStoreDialect"] | CODE |
| LOW | …tadata/ingestion/source/database/cockroach/metadata.py | 106 | def set_schema_description_map(self) -> None: | CODE |
| LOW | …metadata/ingestion/source/database/vertica/metadata.py | 283 | def set_schema_description_map(self) -> None: | CODE |
| LOW⚡ | …c/metadata/ingestion/source/database/mssql/metadata.py | 128 | def set_schema_description_map(self) -> None: | CODE |
| LOW⚡ | …c/metadata/ingestion/source/database/mssql/metadata.py | 134 | def set_database_description_map(self) -> None: | CODE |
| LOW⚡ | …c/metadata/ingestion/source/database/mssql/metadata.py | 140 | def set_stored_procedure_description_map(self) -> None: | CODE |
| LOW | …/metadata/ingestion/source/database/iomete/metadata.py | 54 | def set_inspector(self, database_name: str) -> None: | CODE |
| LOW | …on/src/metadata/ingestion/source/mcp/mcp/connection.py | 21 | __all__ = ["get_connection", "test_connection"] | CODE |
| LOW | …/ingestion/source/dashboard/powerbi/workspace_state.py | 121 | def set_filtered_datamodels(self, datamodels: list[DataModelLike]) -> None: | CODE |
| LOW | ingestion/src/metadata/ingestion/models/topology.py | 202 | def update_context_name(self, stage: NodeStage, right: C) -> None: | CODE |
| LOW | ingestion/src/metadata/ingestion/models/topology.py | 217 | def update_context_value(self, stage: NodeStage, value: Any) -> None: | CODE |
| LOW | …/metadata/ingestion/connections/strategies/__init__.py | 19 | __all__ = ["ClientStrategy", "BasicAuthStrategy", "AzureAdStrategy"] | CODE |
| LOW | ingestion/src/metadata/ingestion/diagnostics/kernel.py | 37 | def set_handler(handler: DiagnosticsHandler | None) -> None: | CODE |
| LOW | …/metadata/core/connections/test_connection/__init__.py | 33 | __all__ = [ | CODE |
| LOW | …alidations/column/sqlalchemy/columnValuesToBeUnique.py | 45 | logger = logging.getLogger(__name__) | CODE |
| 29 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | ingestion/tests/unit/test_dbt_ingest.py | 252 | """Test comprehensive URL validation scenarios including valid and invalid URLs""" | STRING |
| MEDIUM | ingestion/tests/unit/test_dbt_ingest.py | 512 | """Integration test using actual test resources with comprehensive validation""" | STRING |
| MEDIUM⚡ | ingestion/tests/unit/test_dbt.py | 1748 | # New comprehensive tests for custom property validation | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/models/test_custom_pydantic.py | 265 | # Additional comprehensive tests for enhanced functionality | COMMENT |
| MEDIUM | ingestion/tests/unit/models/test_custom_pydantic.py | 384 | # Test with comprehensive table properties | COMMENT |
| MEDIUM⚡ | ingestion/tests/unit/models/test_custom_pydantic.py | 267 | """Extended test suite for comprehensive validation of custom Pydantic functionality.""" | STRING |
| MEDIUM | ingestion/tests/unit/models/test_custom_pydantic.py | 422 | """Test comprehensive DashboardDataModel scenarios.""" | STRING |
| MEDIUM | ingestion/tests/unit/models/test_custom_pydantic.py | 451 | """Test comprehensive CreateRequest scenarios.""" | STRING |
| MEDIUM | ingestion/tests/unit/models/test_custom_pydantic.py | 638 | """Test comprehensive table constraints scenarios.""" | STRING |
| MEDIUM | …ts/unit/lineage/queries/test_complex_query_patterns.py | 2370 | """Test 5-level star schema joins with comprehensive column lineage""" | STRING |
| MEDIUM | …ts/unit/lineage/queries/test_complex_query_patterns.py | 4053 | """Test 3-branch UNION ALL with comprehensive column mapping""" | STRING |
| MEDIUM | …ts/unit/lineage/queries/test_complex_query_patterns.py | 4929 | """Test UNION with subqueries and joins - comprehensive lineage""" | STRING |
| MEDIUM⚡ | ingestion/tests/cli_e2e/test_cli_tableau.py | 205 | """Test comprehensive metadata ingestion validation - runs after base ingestion""" | STRING |
| MEDIUM⚡ | ingestion/tests/cli_e2e/test_cli_tableau.py | 220 | """Test comprehensive lineage validation - Enable actual lineage testing""" | STRING |
| MEDIUM | …sts/integration/airflow/test_airflow_api_connection.py | 548 | """Test comprehensive DAG metadata extraction with Airflow 3.x data.""" | STRING |
| MEDIUM | …etadata/ingestion/source/database/bigquery/metadata.py | 230 | # Upon invoking the set_project_id method, we retrieve a comprehensive | COMMENT |
| LOW | …metadata/ingestion/source/database/snowflake/models.py | 77 | # If removing the () leaves us with nothing, then just return the parenthesis | COMMENT |
| LOW | …metadata/ingestion/source/database/redshift/queries.py | 584 | # For now, we just use the number of queries as a placeholder until we figure out | STRING |
| MEDIUM | ingestion/src/metadata/ingestion/models/topology.py | 252 | # We can leverage this to guarantee we keep track of the MainThread ID. | COMMENT |
| MEDIUM | ingestion/src/metadata/ingestion/models/topology.py | 278 | """Cleans the TopologyContext of a given thread in order to lower the Memory Profile.""" | STRING |
| LOW | ingestion/src/metadata/utils/uuid_encoder.py | 27 | # if the obj is uuid, we simply return the value of uuid | COMMENT |
| MEDIUM | ingestion/src/metadata/utils/datalake/datalake_utils.py | 214 | """A column parser object. This serves as a Creator class for the appropriate column parser object parser | STRING |
| MEDIUM | …enmetadata/it/tests/AsyncSearchIndexConsistencyIT.java | 78 | // write returns. We still poll with Awaitility to stay robust to Elasticsearch's own refresh | COMMENT |
| MEDIUM | …va/org/openmetadata/playwright/ui/pages/TablePage.java | 17 | // name testid is always present. We accept either so the locator is robust across both. | COMMENT |
| MEDIUM | …ations/template/handlebars/helpers/TextDiffHelper.java | 110 | // Compute token diff with LCS (simple, robust, dependency-free) | COMMENT |
| MEDIUM | …/openmetadata/operator/controller/OMJobReconciler.java | 159 | // Check if main pod already exists (using selectors for robust discovery) | COMMENT |
| LOW | scripts/reindex-perf-bootstrap.sh | 92 | # Fallback: just use the admin JWT directly. It has all permissions in the dev profile. | COMMENT |
| MEDIUM | .github/workflows/java-playwright-external.yml | 25 | # The harness switches to external mode automatically when OM_URL + OM_ADMIN_TOKEN are set (see | COMMENT |
| MEDIUM | .github/workflows/java-playwright-external.yml | 199 | # Credentials so the harness can re-login and auto-renew the token on long runs. | COMMENT |
| MEDIUM | .github/workflows/java-playwright-external.yml | 357 | # Credentials so the harness can re-login and auto-renew the token on long runs. | COMMENT |
| MEDIUM | .github/workflows/java-playwright-external.yml | 492 | # Credentials so the harness can re-login and auto-renew the token on long runs. | COMMENT |
| MEDIUM | .github/workflows/java-playwright-nightly.yml | 92 | # --- The search ITs / UIITs, their test harness, and the Maven profiles that run them --- | COMMENT |
| MEDIUM | …main/resources/ui/playwright/doc-generator/markdown.js | 179 | // Add explicit anchor div to ensure robust linking | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | ingestion/pyproject.toml | 338 | # scaffold below), these libraries stay silent — keeping focus on our own | COMMENT |
| MEDIUM⚡ | ingestion/pyproject.toml | 343 | # ── Ratchet scaffold: enable subtree-by-subtree promotions later ──────── | COMMENT |
| MEDIUM | …/utils/dependency_injector/test_dependency_injector.py | 33 | # Test classes for dependency injection | COMMENT |
| MEDIUM | …adata/utils/dependency_injector/dependency_injector.py | 30 | # Use dependency injection | STRING |
| MEDIUM⚡ | ingestion/src/metadata/cli/scaffold.py | 1631 | # Main scaffold orchestrator | STRING |
| MEDIUM | skills/connector-building/GUIDE.md | 418 | ### "Module not found" after scaffold | COMMENT |
| MEDIUM | skills/connector-building/examples/dashboard-rest.yaml | 2 | # Run: metadata scaffold-connector --name my_dashboard --service-type dashboard ... | COMMENT |
| MEDIUM | …s/connector-building/examples/database-sqlalchemy.yaml | 2 | # Run: metadata scaffold-connector --name clickhouse --service-type database ... | COMMENT |
| MEDIUM | skills/connector-building/examples/pipeline-sdk.yaml | 2 | # Run: metadata scaffold-connector --name prefect --service-type pipeline ... | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | ingestion/tests/unit/utils/test_memory_limit.py | 377 | CODE | |
| LOW | …tion/src/metadata/ingestion/ometa/mixins/task_mixin.py | 122 | CODE | |
| LOW | …tion/src/metadata/ingestion/ometa/mixins/feed_mixin.py | 43 | CODE | |
| LOW | …/metadata/ingestion/ometa/mixins/announcement_mixin.py | 40 | CODE | |
| LOW | …/metadata/ingestion/source/database/snowflake/utils.py | 278 | CODE | |
| LOW | …/metadata/ingestion/source/database/snowflake/utils.py | 310 | CODE | |
| LOW | …/metadata/ingestion/source/database/snowflake/utils.py | 325 | CODE | |
| LOW | …/metadata/ingestion/source/database/snowflake/utils.py | 342 | CODE | |
| LOW | …gestion/source/database/hive/custom_hive_connection.py | 16 | CODE | |
| LOW | …etadata/ingestion/source/pipeline/openlineage/utils.py | 49 | CODE | |
| LOW | …metadata/ingestion/source/dashboard/superset/client.py | 215 | CODE | |
| LOW | …src/metadata/ingestion/source/metadata/atlas/client.py | 54 | CODE | |
| LOW | …stion/src/metadata/ingestion/models/custom_pydantic.py | 86 | CODE | |
| LOW | ingestion/src/metadata/data_quality/runner/core.py | 39 | CODE | |
| LOW | …a_quality/validations/mixins/pandas_validator_mixin.py | 232 | CODE | |
| LOW | ingestion/src/metadata/utils/time_utils.py | 69 | CODE | |
| LOW | ingestion/src/metadata/utils/time_utils.py | 110 | CODE | |
| LOW | …ion/src/metadata/sdk/data_quality/tests/table_tests.py | 355 | CODE | |
| LOW | ingestion/src/metadata/sdk/api/lineage.py | 321 | CODE | |
| LOW | ingestion/src/metadata/sdk/api/lineage.py | 344 | CODE | |
| LOW | ingestion/src/metadata/sdk/api/lineage.py | 405 | CODE | |
| LOW | …ow-apis/openmetadata_managed_apis/operations/deploy.py | 187 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | docker/development/docker-compose.redis.yml | 6 | # Usage: | COMMENT |
| LOW | docker/development/docker-compose.multiserver.yml | 9 | # Usage: | COMMENT |
| LOW | …ker-compose-quickstart/docker-compose-fuseki-arm64.yml | 46 | # Usage: | COMMENT |
| LOW | …ompose-quickstart/docker-compose-fuseki-standalone.yml | 44 | # Usage: | COMMENT |
| LOW | …se-quickstart/docker-compose-opensearch-standalone.yml | 78 | # Usage: | COMMENT |
| LOW | bin/distributed-test/scripts/gc-reindex-report.sh | 4 | # Usage: | COMMENT |
| LOW | scripts/reindex-perf-bootstrap.sh | 10 | # Usage: | COMMENT |
| LOW | …sources/ui/scripts/ui-checkstyle-playwright-changed.sh | 16 | # Usage: | COMMENT |
| LOW | …src/main/resources/ui/scripts/ui-checkstyle-changed.sh | 16 | # Usage: | COMMENT |
| LOW | …src/main/resources/ui/scripts/ui-checkstyle-changed.sh | 16 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | openmetadata-sdk/README.md | 30 | .apiKey("your-api-key") | CODE |
| HIGH | …sources/ui/public/locales/en-US/Dashboard/Lightdash.md | 25 | Authorization: Bearer YOUR_API_KEY | CODE |
| HIGH | …sources/ui/public/locales/en-US/Dashboard/Lightdash.md | 27 | Replace `YOUR_API_KEY` with the actual key provided by your Lightdash instance. | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …estion/tests/unit/resources/dbt_ingest/dbt_project.yml | 29 | # In this example config, we tell dbt to build all models in the example/ | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …ata-ui/src/main/resources/ui/src/utils/TagClassBase.ts | 247 | description: 'This is a sample tag for demonstration purposes', | CODE |
| MEDIUM | …urces/ui/src/utils/DataProduct/DataProductClassBase.ts | 257 | description: 'This is a sample data product for demonstration purposes', | CODE |
| MEDIUM | …main/resources/ui/src/stories/SlideoutMenu.stories.tsx | 86 | defaultValue="A sample dataset for demonstration purposes." | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …unit/topology/pipeline/test_databricks_kafka_parser.py | 400 | def my_function(): | CODE |
| LOW | …unit/topology/pipeline/test_databricks_kafka_parser.py | 441 | def my_function(): | CODE |
| LOW⚡ | …ts/unit/core/connections/test_connection/test_check.py | 40 | def helper(self): | CODE |
| LOW | ingestion/src/metadata/pii/scanners/ner_scanner.py | 135 | def process_data(self, row: str, entities_score: Dict[str, StringAnalysis]) -> None: # noqa: UP006 | CODE |
| LOW | …adata/utils/dependency_injector/dependency_injector.py | 97 | def my_function(db: Inject[Database]): | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …resources/ui/playwright/e2e/Pages/TaskComments.spec.ts | 278 | print("Hello, World!") | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | ingestion/tests/unit/topology/dashboard/test_ssrs.py | 554 | CODE | |
| MEDIUM | ingestion/tests/unit/sdk/test_base_entity.py | 146 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ywright/e2e/Features/TestSuitePipelineRedeploy.spec.ts | 79 | // TODO: Add test to verify the re-deployed pipelines for Database, Dashboard and other entities | COMMENT |