Repository Analysis

OpenLineage/OpenLineage

An Open Standard for lineage metadata collection

5.2 Low AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of OpenLineage/OpenLineage, a Java project with 2,630 GitHub stars. SynthScan v2.0 examined 353,605 lines of code across 2394 source files, recording 1176 pattern matches distributed across 22 syntactic categories. The overall adjusted score of 5.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).

5.2
Adjusted Score
5.2
Raw Score
100%
Time Factor
2026-08-28
Last Push
2.6K
Stars
Java
Language
353.6K
Lines of Code
2.4K
Files
1.2K
Pattern Hits
2026-08-29
Scan Date
0.03
HC Hit Rate

What These Metrics Mean

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

Score History

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

Severity Breakdown

Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.

CRITICAL 31HIGH 39MEDIUM 66LOW 1040

Directory Score Breakdown

This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.

Pattern Findings

The scanner identified 1176 distinct pattern matches across 22 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

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

Hyper-Verbose Identifiers719 hits · 659 pts
SeverityFileLineSnippetContext
LOWproxy/fluentd/lib/fluent/plugin/parser_openlineage.rb93 def rewrite_schema_to_include_facets(schema)CODE
LOWproxy/fluentd/lib/fluent/plugin/parser_openlineage.rb145 def add_ref_as_parent_property(schema, parent, facet_name, property)CODE
LOWproxy/fluentd/lib/fluent/plugin/parser_openlineage.rb156 def find_parent_object_getter(parent)CODE
LOWintegration/dbt/tests/test_main.py45def test_main_strips_openlineage_job_name_before_dbt(job_name_args, monkeypatch):CODE
LOWintegration/dbt/tests/test_main.py110def test_consume_structured_logs(command_line, os_envs, function_kwargs, monkeypatch):CODE
LOWintegration/dbt/tests/test_main.py161def _setup_local_artifacts_mocks(monkeypatch, env):CODE
LOWintegration/dbt/tests/test_main.py183def test_consume_local_artifacts_propagates_root_parent_metadata(monkeypatch):CODE
LOWintegration/dbt/tests/test_main.py215def test_consume_local_artifacts_reads_parent_from_openlineage_context(monkeypatch):CODE
LOWintegration/dbt/tests/test_main.py253def test_consume_local_artifacts_root_when_no_external_parent(monkeypatch):CODE
LOWintegration/dbt/tests/test_main.py278def test_consume_local_artifacts_explicit_root_different_from_parent(monkeypatch):CODE
LOWintegration/dbt/tests/test_main.py316def test_consume_local_artifacts_partial_root_falls_back_to_parent(monkeypatch):CODE
LOW…egration/dbt/tests/integration/test_structured_logs.py10 def test_structured_logs_event_hierarchy(self, dbt_runner, reset_test_server):CODE
LOW…egration/dbt/tests/integration/test_structured_logs.py157 def test_singular_test_data_quality_assertions(self, dbt_runner, reset_test_server):CODE
LOW…egration/dbt/tests/integration/test_structured_logs.py230 def test_singular_test_multi_table_data_quality_assertions(self, dbt_runner, reset_test_server):CODE
LOWintegration/dbt/tests/integration/test_integration.py15 def test_basic_seed_to_staging_pipeline(self, dbt_runner, reset_test_server):CODE
LOWintegration/dbt/tests/integration/test_integration.py43 def test_full_pipeline_lineage(self, dbt_runner, reset_test_server):CODE
LOWintegration/dbt/tests/integration/test_integration.py84 def test_empty_model_execution(self, dbt_runner, reset_test_server):CODE
LOWintegration/dbt/tests/integration/test_integration.py121 def test_local_artifacts_mode(self, dbt_runner, reset_test_server):CODE
LOWintegration/dbt/tests/integration/test_integration.py139 def test_job_name_local_artifacts_mode(self, dbt_runner, reset_test_server):CODE
LOWintegration/dbt/tests/integration/test_integration.py164 def test_event_schema_validation(self, dbt_runner, reset_test_server):CODE
LOWintegration/common/tests/test_utils.py17def test_nullable_chain_fails():CODE
LOWintegration/common/tests/test_utils.py22def test_nullable_chain_works():CODE
LOWintegration/common/tests/test_utils.py30def test_nullable_chain_does_not_mutate_chain():CODE
LOWintegration/common/tests/test_utils.py38def test_parse_single_arg_does_not_exist():CODE
LOWintegration/common/tests/test_utils.py43def test_parse_single_arg_next():CODE
LOWintegration/common/tests/test_utils.py48def test_parse_single_arg_equals():CODE
LOWintegration/common/tests/test_utils.py53def test_parse_single_arg_gets_first_key():CODE
LOWintegration/common/tests/test_utils.py57def test_parse_single_arg_default():CODE
LOWintegration/common/tests/test_utils.py62def test_parse_single_arg_trailing_key_uses_default():CODE
LOWintegration/common/tests/test_utils.py108def test_add_command_line_arg(command_line, arg_name, arg_value, expected_command_line):CODE
LOWintegration/common/tests/test_utils.py137def test_add_or_replace_command_line_option(command_line, option, replace_option, expected_command_line):CODE
LOWintegration/common/tests/test_utils.py167def test_remove_command_line_option(command_line, command_option, expected_command_line):CODE
LOWintegration/common/tests/test_utils.py188def test_remove_command_line_option_with_value(command_line, command_option, expected_command_line):CODE
LOWintegration/common/tests/test_utils.py204def test_has_command_line_option(command_line, command_option, expected):CODE
LOWintegration/common/tests/test_utils.py223def test_incremental_file_reader(incremental_reads, expected_lines):CODE
LOWintegration/common/tests/test_snowflake.py52def test_snowflake_sqlite_account_urls(source, target):CODE
LOWintegration/common/tests/test_dataset.py44def test_dataset_with_db_name(source):CODE
LOWintegration/common/tests/test_dataset.py49def test_dataset_to_openlineage(table_schema):CODE
LOWintegration/common/tests/dbt/test_meta_owner.py33def test_missing_owner_emits_no_facet(processor):CODE
LOWintegration/common/tests/dbt/test_meta_owner.py38def test_string_owner_emits_single(processor):CODE
LOWintegration/common/tests/dbt/test_meta_owner.py53def test_regression_single_element_list(processor):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py93def test_get_parent_run_metadata_from_context_not_set(monkeypatch):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py98def test_get_parent_run_metadata_from_context_malformed_json(monkeypatch, caplog):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py104def test_get_parent_run_metadata_from_context_missing_parent_run_key(monkeypatch):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py347def test_jinja_undefined_variable(jinja_env):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py352def test_jinja_undefined_method(jinja_env):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py357def test_jinja_defined_method(jinja_env):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py364def test_jinja_defined_variable(jinja_env):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py369def test_jinja_undefined_method_with_args(jinja_env):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py46def test_get_parent_run_metadata_from_context_valid(monkeypatch):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py119def test_get_parent_run_metadata_from_context_missing_required_fields(monkeypatch, caplog, parent):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py126def test_get_parent_run_metadata_from_context_without_root_defaults_to_self(monkeypatch):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py146def test_get_parent_run_metadata_from_context_unknown_top_level_keys_ignored(monkeypatch):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py163def test_get_parent_run_metadata_context_takes_precedence_over_legacy(monkeypatch):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py185def test_get_parent_run_metadata_falls_back_to_legacy_when_context_malformed(monkeypatch):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py220def test_dbt_parse_and_compare_event(path, job_name, parent_run_metadata):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py247def test_dbt_parse_dbt_test_event(mock_datetime, mock_uuid, parent_run_metadata, path):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py276def test_dbt_parse_singular_test_event(mock_datetime, mock_uuid, parent_run_metadata):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py317def test_dbt_parse_profile_with_env_vars(mock_uuid, parent_run_metadata):CODE
LOWintegration/common/tests/dbt/test_dbt_local.py400def test_lazy_load_jinja_dict(jinja_env):CODE
659 more matches not shown…
Hallucination Indicators31 hits · 385 pts
SeverityFileLineSnippetContext
CRITICAL…est/java/io/openlineage/hive/InMemoryHiveTestBase.java101 String jdbcDriver = org.apache.derby.jdbc.EmbeddedDriver.class.getName();CODE
CRITICAL…/test/java/io/openlineage/hive/util/HiveUtilsTest.java20 new org.apache.hadoop.hive.metastore.api.Table();CODE
CRITICAL…/test/java/io/openlineage/hive/util/HiveUtilsTest.java34 new org.apache.hadoop.hive.metastore.api.Table();CODE
CRITICAL…/test/java/io/openlineage/hive/util/HiveUtilsTest.java49 new org.apache.hadoop.hive.metastore.api.Table();CODE
CRITICAL…java/io/openlineage/spark/agent/Spark4CompatUtils.java36 org.apache.commons.lang3.reflect.MethodUtils.invokeMethod(queryExecution, "sparkSession");CODE
CRITICAL…nlineage/spark/agent/OpenLineageSparkListenerTest.java186 // org.apache.spark.sql.SparkSession org.apache.spark.sql.execution.QueryExecution.sparkSession()COMMENT
CRITICAL…lineage/spark/agent/lifecycle/RddExecutionContext.java603 path = org.apache.hadoop.mapred.FileOutputFormat.getOutputPath(jobConf);CODE
CRITICAL…lineage/spark/agent/lifecycle/RddExecutionContext.java609 org.apache.hadoop.mapreduce.lib.output.FileOutputFormat.getOutputPath(new Job(jobConf));CODE
CRITICAL…park/agent/lifecycle/Spark34DatasetBuilderFactory.java145 return new io.openlineage.spark33.agent.lifecycle.plan.CreateReplaceDatasetBuilder(context);CODE
CRITICAL…park/agent/lifecycle/Spark32DatasetBuilderFactory.java131 return new io.openlineage.spark33.agent.lifecycle.plan.CreateReplaceDatasetBuilder(context);CODE
CRITICAL…cycle/SparkOpenLineageExtensionVisitorWrapperTest.java71 new io.openlineage.client.utils.DatasetIdentifier.Symlink(CODE
CRITICAL…cycle/SparkOpenLineageExtensionVisitorWrapperTest.java100 new io.openlineage.client.utils.DatasetIdentifier.Symlink(CODE
CRITICAL…nlineage/spark/agent/util/RddDatasetInfoExtractor.java131 org.apache.hadoop.mapreduce.lib.input.FileInputFormat.getInputPaths(CODE
CRITICAL…park/agent/lifecycle/HadoopRDDInputDatasetBuilder.java69 org.apache.hadoop.mapred.FileInputFormat.getInputPaths(CODE
CRITICAL…park/agent/lifecycle/HadoopRDDInputDatasetBuilder.java74 org.apache.hadoop.mapreduce.lib.input.FileInputFormat.getInputPaths(CODE
CRITICAL…e/spark/agent/lifecycle/plan/KustoRelationVisitor.java154 io.openlineage.spark.agent.util.ScalaConversionUtils.fromMap(options);CODE
CRITICAL…spark3/agent/lifecycle/plan/column/VisitorFactory.java43 new io.openlineage.spark3.agent.lifecycle.plan.column.visitors.operator.WindowVisitor(),CODE
CRITICALwebsite/docs/client/java/developing/logging.md251 at io.openlineage.client.transports.HttpTransport.emit(HttpTransport.java:113)CODE
CRITICALwebsite/docs/client/java/developing/logging.md255 at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.javCODE
CRITICALwebsite/docs/client/java/developing/logging.md256 at org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:CODE
CRITICALwebsite/docs/client/java/developing/logging.md257 at org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:393)CODE
CRITICALwebsite/docs/client/java/developing/logging.md258 at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:236)CODE
CRITICALwebsite/docs/client/java/developing/logging.md259 at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186)CODE
CRITICALwebsite/docs/client/java/developing/logging.md260 at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89)CODE
CRITICALwebsite/docs/client/java/developing/logging.md261 at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110)CODE
CRITICALwebsite/docs/client/java/developing/logging.md262 at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)CODE
CRITICALwebsite/docs/client/java/developing/logging.md263 at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)CODE
CRITICALwebsite/docs/client/java/developing/logging.md264 at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108)CODE
CRITICALwebsite/docs/client/java/developing/logging.md265 at io.openlineage.client.transports.HttpTransport.emit(HttpTransport.java:108)CODE
CRITICALwebsite/docs/client/java/developing/logging.md274 at org.apache.http.conn.socket.PlainConnectionSocketFactory.connectSocket(PlainConnectionSocketFactory.java:75)CODE
CRITICALwebsite/docs/client/java/developing/logging.md275 at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.javCODE
Decorative Section Separators44 hits · 171 pts
SeverityFileLineSnippetContext
MEDIUMgenerator/go/render/spec/renderer.go75// ── Internal types ────────────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/spec/renderer.go85// ── Emitters ──────────────────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/spec/renderer.go128 // ── BaseEvent ────────────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/spec/renderer.go155 // ── Typed event structs ──────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/spec/renderer.go206 // ── Emittable marker methods ─────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/spec/renderer.go241// ── Property collection ───────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/spec/renderer.go287// ── Type resolution ───────────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/spec/renderer.go386// ── Helpers ───────────────────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go78 // ── 1. Facet root structs ─────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go83 // ── 2. Enum types + constants ─────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go88 // ── 3. Union interfaces, raw wrappers, and seal methods ───────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go93 // ── 4. Nested concrete helper structs (unique by TypeName) ───────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go120 // ── 1. Container structs ──────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go123 // ── 2. Apply + constructor + With* per facet ──────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go128 // ── 3. Variant constructors for all union types ───────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go138// ── Facet root struct ─────────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go173// ── Nested struct ─────────────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go284// ── Container structs ─────────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go329// ── Apply + constructor + With* ───────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go480// ── OL Go type helpers ────────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go648// ── Nested type collection ────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go924// ── Enum type + constants ─────────────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go952// ── Union interface + raw wrapper ─────────────────────────────────────────────COMMENT
MEDIUMgenerator/go/render/client/facets.go1079// ── Naming / kind helpers ─────────────────────────────────────────────────────COMMENT
MEDIUMclient/python/tests/test_source_code_location.py34# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py36# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py156# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py158# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py172# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py174# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py194# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py196# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py234# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py236# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py273# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py275# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py347# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py349# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py376# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py378# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py543# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py545# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py82# ---------------------------------------------------------------------------COMMENT
MEDIUMclient/python/tests/test_source_code_location.py84# ---------------------------------------------------------------------------COMMENT
Unused Imports145 hits · 128 pts
SeverityFileLineSnippetContext
LOWintegration/common/src/openlineage/common/models.py9CODE
LOWintegration/common/src/openlineage/common/__init__.py4CODE
LOW…common/src/openlineage/common/provider/dbt/__init__.py4CODE
LOW…common/src/openlineage/common/provider/dbt/__init__.py5CODE
LOW…common/src/openlineage/common/provider/dbt/__init__.py6CODE
LOW…common/src/openlineage/common/provider/dbt/__init__.py7CODE
LOW…ommon/src/openlineage/common/provider/dbt/processor.py3CODE
LOW…lineage/common/provider/great_expectations/__init__.py4CODE
LOW…egration/common/src/openlineage/common/sql/__init__.py6CODE
LOW…egration/common/src/openlineage/common/sql/__init__.py6CODE
LOW…egration/common/src/openlineage/common/sql/__init__.py6CODE
LOW…egration/common/src/openlineage/common/sql/__init__.py6CODE
LOW…egration/common/src/openlineage/common/sql/__init__.py6CODE
LOWclient/python/tests/test_composite.py3CODE
LOWclient/python/tests/test_utils.py3CODE
LOWclient/python/tests/conftest.py3CODE
LOWclient/python/tests/test_lineage_facet.py3CODE
LOWclient/python/tests/test_source_code_location.py3CODE
LOWclient/python/tests/test_kafka.py3CODE
LOWclient/python/tests/test_async_http.py3CODE
LOWclient/python/tests/transport.py3CODE
LOWclient/python/tests/test_facet.py3CODE
LOWclient/python/tests/test_http_integration.py3CODE
LOWclient/python/tests/test_factory.py3CODE
LOWclient/python/tests/test_gcplineage.py3CODE
LOWclient/python/tests/test_facet_v2.py3CODE
LOWclient/python/tests/test_http.py3CODE
LOWclient/python/tests/test_amazon_datazone.py4CODE
LOWclient/python/tests/test_datadog.py3CODE
LOWclient/python/tests/test_msk_iam.py3CODE
LOWclient/python/tests/test_events.py3CODE
LOWclient/python/tests/test_client.py3CODE
LOWclient/python/tests/test_uuid.py3CODE
LOWclient/python/tests/test_jwt_token_provider.py3CODE
LOW…nt/python/tests/integration/test_server/test_server.py3CODE
LOWclient/python/tests/generator/test_cli.py3CODE
LOWclient/python/tests/generator/test_base.py3CODE
LOWclient/python/tests/transform/test_transform.py3CODE
LOWclient/python/src/openlineage/client/tags.py3CODE
LOWclient/python/src/openlineage/client/git.py3CODE
LOWclient/python/src/openlineage/client/client.py3CODE
LOWclient/python/src/openlineage/client/serde.py3CODE
LOWclient/python/src/openlineage/client/constants.py3CODE
LOWclient/python/src/openlineage/client/__init__.py3CODE
LOWclient/python/src/openlineage/client/__init__.py7CODE
LOWclient/python/src/openlineage/client/__init__.py7CODE
LOWclient/python/src/openlineage/client/__init__.py8CODE
LOWclient/python/src/openlineage/client/utils.py3CODE
LOWclient/python/src/openlineage/client/filter.py3CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
LOWclient/python/src/openlineage/client/facet_v2.py4CODE
85 more matches not shown…
Magic Placeholder Names22 hits · 128 pts
SeverityFileLineSnippetContext
HIGHwebsite/docs/integrations/feast.md167 api_key: "your-api-key"CODE
HIGHwebsite/docs/integrations/feast.md178export FEAST_OPENLINEAGE_CONSUMER_API_KEY=your-api-keyCODE
HIGHwebsite/docs/integrations/feast.md227OPENLINEAGE_API_KEY = "your-api-key"CODE
HIGHwebsite/docs/integrations/feast.md237spark.openlineage.transport.auth.apiKey=your-api-keyCODE
HIGHwebsite/docs/integrations/feast.md244OPENLINEAGE_API_KEY: "your-api-key"CODE
HIGHwebsite/docs/client/python/configuration.md363OPENLINEAGE__TRANSPORT__AUTH__API_KEY=your-api-keyCODE
HIGHwebsite/docs/client/python/configuration.md390 apiKey: your-api-keyCODE
HIGHwebsite/docs/client/python/configuration.md402 apiKey: your-api-keyCODE
HIGHwebsite/docs/client/python/configuration.md434 "apiKey": "your-api-key",CODE
HIGHwebsite/docs/client/java/partials/java_transport.md302 apiKey: your-api-keyCODE
HIGHwebsite/docs/client/java/partials/java_transport.md314 apiKey: your-api-keyCODE
HIGHwebsite/docs/client/java/partials/java_transport.md343spark.openlineage.transport.auth.apiKey=your-api-keyCODE
HIGHwebsite/docs/client/java/partials/java_transport.md368openlineage.transport.auth.apiKey=your-api-keyCODE
HIGHwebsite/docs/client/java/partials/java_transport.md396jwtTokenProvider.setApiKey("your-api-key");CODE
HIGHclient/go/README.md48 APIKey: "your-api-key",CODE
HIGHclient/go/README.md256 APIKey: "your-api-key", // optionalCODE
HIGHclient/python/tests/test_client.py834 '"auth": {"type": "api_key", "apiKey": "YOUR_API_KEY"}}',CODE
HIGHclient/python/tests/test_client.py845 assert transport.config.auth.api_key == "YOUR_API_KEY"CODE
HIGHclient/python/tests/test_client.py853 "OPENLINEAGE_API_KEY": "YOUR_API_KEY",CODE
HIGHclient/python/tests/test_client.py865 assert transport.config.auth.api_key == "YOUR_API_KEY"CODE
HIGHclient/python/src/openlineage/client/transport/http.py76 "apiKey": "your-api-key",STRING
HIGH…io/openlineage/client/transports/JwtTokenProvider.java56 * apiKey: your-api-keyCOMMENT
AI Response Leakage11 hits · 82 pts
SeverityFileLineSnippetContext
HIGHintegration/common/tests/dbt/snapshot/dbt_project.yml31# In this example config, we tell dbt to build all models in the example/COMMENT
HIGHintegration/common/tests/dbt/alias/dbt_project.yml30# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
HIGHintegration/common/tests/dbt/large/dbt_project.yml31# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
HIGHintegration/common/tests/dbt/fail/dbt_project.yml31# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
HIGHintegration/common/tests/dbt/test/dbt_project.yml31# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
HIGHintegration/common/tests/dbt/catalog/dbt_project.yml31# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
HIGH…tion/common/tests/dbt/no_test_metadata/dbt_project.yml31# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
HIGHintegration/common/tests/dbt/small/dbt_project.yml30# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
HIGHintegration/common/tests/dbt/env_vars/dbt_project.yml31# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
HIGHintegration/common/tests/dbt/profiles/dbt_project.yml31# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
HIGH…gration/common/tests/dbt/compiled_code/dbt_project.yml31# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
Structural Annotation Overuse32 hits · 53 pts
SeverityFileLineSnippetContext
LOW…src/test/java/io/openlineage/spark/agent/AwsUtils.java77 // Step 1: List objects with the specified prefixCOMMENT
LOW…src/test/java/io/openlineage/spark/agent/AwsUtils.java96 // Step 2: Delete objects in batches (up to 1000 per request)COMMENT
LOW…src/test/java/io/openlineage/spark/agent/AwsUtils.java114 // Step 3: Prepare for the next iteration if more objects are availableCOMMENT
LOW…ty/compatibility_test/contributing/new_input_events.md10## Step 1: Create Scenario DirectoryCOMMENT
LOW…ty/compatibility_test/contributing/new_input_events.md18## Step 2: Configure OpenLineage VersionCOMMENT
LOW…ty/compatibility_test/contributing/new_input_events.md28## Step 3: Define MaintainersCOMMENT
LOW…ty/compatibility_test/contributing/new_input_events.md45## Step 4: Add EventsCOMMENT
LOW…bility/compatibility_test/contributing/new_producer.md13## Step 1: Create Producer Directory StructureCOMMENT
LOW…bility/compatibility_test/contributing/new_producer.md20## Step 2: Set Up Runner EnvironmentCOMMENT
LOW…bility/compatibility_test/contributing/new_producer.md33## Step 3: Create Scenarios StructureCOMMENT
LOW…bility/compatibility_test/contributing/new_producer.md40## Step 4: Define MaintainersCOMMENT
LOW…bility/compatibility_test/contributing/new_producer.md57## Step 5: Configure Supported VersionsCOMMENT
LOW…bility/compatibility_test/contributing/new_producer.md70## Step 6: Create GitHub WorkflowCOMMENT
LOW…bility/compatibility_test/contributing/new_producer.md172## Step 7: Update main workflow filesCOMMENT
LOW…bility/compatibility_test/contributing/new_producer.md315## Step 8: Update Release ConfigurationCOMMENT
LOW…bility/compatibility_test/contributing/new_consumer.md12## Step 1: Create Consumer Directory StructureCOMMENT
LOW…bility/compatibility_test/contributing/new_consumer.md19## Step 2: Set Up Consumer InfrastructureCOMMENT
LOW…bility/compatibility_test/contributing/new_consumer.md29## Step 3: Create Field Mapping ConfigurationCOMMENT
LOW…bility/compatibility_test/contributing/new_consumer.md32## Step 4: Define MaintainersCOMMENT
LOW…bility/compatibility_test/contributing/new_consumer.md51## Step 5: Create Consumer WorkflowCOMMENT
LOW…bility/compatibility_test/contributing/new_consumer.md109## Step 6: Update main workflow filesCOMMENT
LOW…bility/compatibility_test/contributing/new_consumer.md196## Step 6: Create Consumer ScenariosCOMMENT
LOW…mpatibility_test/contributing/new_consumer_scenario.md12## Step 1: Create Consumer Scenario DirectoryCOMMENT
LOW…mpatibility_test/contributing/new_consumer_scenario.md20## Step 2: Create configuration fileCOMMENT
LOW…mpatibility_test/contributing/new_consumer_scenario.md45## Step 3: Define MaintainersCOMMENT
LOW…mpatibility_test/contributing/new_consumer_scenario.md64## Step 5: Document the ScenarioCOMMENT
LOW…mpatibility_test/contributing/new_consumer_scenario.md88## Step 8: Create Expected Validation FilesCOMMENT
LOW…mpatibility_test/contributing/new_producer_scenario.md17## Step 1: Create Producer Scenario DirectoryCOMMENT
LOW…mpatibility_test/contributing/new_producer_scenario.md25## Step 2: Configure Test SpecificationsCOMMENT
LOW…mpatibility_test/contributing/new_producer_scenario.md85## Step 3: Define MaintainersCOMMENT
LOW…mpatibility_test/contributing/new_producer_scenario.md103## Step 4: Add Expected EventsCOMMENT
LOW…mpatibility_test/contributing/new_producer_scenario.md115## Step 5: Document the ScenarioCOMMENT
Excessive Try-Catch Wrapping48 hits · 52 pts
SeverityFileLineSnippetContext
LOWintegration/dbt/src/openlineage/dbt/__init__.py236 except Exception as e:CODE
LOWintegration/dbt/src/openlineage/dbt/__init__.py246 except Exception:CODE
LOWintegration/dbt/src/openlineage/dbt/__init__.py410 except Exception as e:CODE
LOWintegration/common/src/openlineage/common/test.py25 except Exception:CODE
LOWintegration/common/src/openlineage/common/test.py34 except Exception:CODE
LOW…ion/common/src/openlineage/common/provider/bigquery.py159 except Exception as e:CODE
LOW…ion/common/src/openlineage/common/provider/bigquery.py250 except Exception as e:CODE
LOW…ion/common/src/openlineage/common/provider/bigquery.py275 except Exception as e:CODE
MEDIUM…ion/common/src/openlineage/common/provider/bigquery.py272def _get_table_safely(self, output_table_name):CODE
LOW…ommon/src/openlineage/common/provider/redshift_data.py55 except Exception as e:CODE
LOW…ommon/src/openlineage/common/provider/redshift_data.py98 except Exception as e:CODE
LOW…ommon/src/openlineage/common/provider/redshift_data.py108 except Exception as e:CODE
MEDIUM…ommon/src/openlineage/common/provider/redshift_data.py105def _get_table_safely(self, output_table_name):CODE
LOW…ommon/src/openlineage/common/provider/dbt/processor.py684 except Exception as e:CODE
LOW…ommon/src/openlineage/common/provider/dbt/processor.py1095 except Exception as error:CODE
LOW…ommon/src/openlineage/common/provider/dbt/processor.py1136 except Exception as error:CODE
LOW…ommon/src/openlineage/common/provider/dbt/processor.py1356 except Exception as e:CODE
MEDIUM…ommon/src/openlineage/common/provider/dbt/processor.py681def to_openlineage_events(self, *args, **kwargs) -> DbtRunResult | None:CODE
LOW…src/openlineage/common/provider/dbt/structured_logs.py940 except Exception:CODE
LOW…src/openlineage/common/provider/dbt/structured_logs.py961 except Exception:CODE
MEDIUMintegration/spark/jar_compare.py366 print(f"Error: {e}", file=sys.stderr)STRING
LOWclient/python/tests/conftest.py184 except Exception as e:CODE
LOWclient/python/tests/conftest.py194 except Exception as e:CODE
MEDIUMclient/python/tests/test_async_http.py442def worker(thread_id):CODE
LOWclient/python/tests/test_async_http.py452 except Exception as e:CODE
LOW…nt/python/tests/integration/test_server/test_server.py301 except Exception as e:CODE
LOW…nt/python/tests/integration/test_server/test_server.py431 except Exception as e:CODE
LOWclient/python/src/openlineage/client/client.py300 except Exception:CODE
LOWclient/python/src/openlineage/client/client.py321 except Exception:CODE
LOWclient/python/src/openlineage/client/client.py601 except Exception:CODE
LOWclient/python/src/openlineage/client/utils.py27 except Exception as e:CODE
LOW…on/src/openlineage/client/transport/amazon_datazone.py65 except Exception as error:CODE
LOWclient/python/src/openlineage/client/transport/file.py262 except Exception as error:CODE
LOWclient/python/src/openlineage/client/transport/http.py149 except Exception as e:CODE
LOWclient/python/src/openlineage/client/transport/http.py204 except Exception as e:CODE
LOWclient/python/src/openlineage/client/transport/http.py260 except Exception as e:CODE
LOWclient/python/src/openlineage/client/transport/http.py367 except Exception as e: # noqa: BLE001CODE
LOW…/python/src/openlineage/client/transport/gcplineage.py150 except Exception as e:CODE
LOW…/python/src/openlineage/client/transport/gcplineage.py164 except Exception as e:CODE
LOW…/python/src/openlineage/client/transport/gcplineage.py208 except Exception as e:CODE
LOW…/python/src/openlineage/client/transport/gcplineage.py218 except Exception as e:CODE
LOW…t/python/src/openlineage/client/transport/composite.py124 except Exception as e: # Handle failureCODE
LOW…t/python/src/openlineage/client/transport/composite.py165 except Exception as e:CODE
LOW…ent/python/src/openlineage/client/transport/datadog.py55 except Exception:CODE
LOW…/python/src/openlineage/client/transport/async_http.py200 except Exception as e:CODE
LOW…/python/src/openlineage/client/transport/async_http.py249 except Exception:CODE
LOW…/python/src/openlineage/client/transport/async_http.py326 except Exception:CODE
LOW…/python/src/openlineage/client/transport/async_http.py432 except Exception as e:CODE
Self-Referential Comments14 hits · 44 pts
SeverityFileLineSnippetContext
MEDIUM…ectations/test_great_expectations_validation_action.py81 # Create a modern GE v3 contextCOMMENT
MEDIUM…ectations/test_great_expectations_validation_action.py167 # Create a modern GE v3 contextCOMMENT
MEDIUM…ectations/test_great_expectations_validation_action.py276 # Create a modern GE v3 contextCOMMENT
MEDIUM…ommon/src/openlineage/common/provider/dbt/processor.py58 # This class represents supported adapters.COMMENT
MEDIUMclient/python/tests/test_async_http.py178 # Create a mock event that's not a RunEventCOMMENT
MEDIUMclient/python/tests/test_http_integration.py68 # Create a complete run lifecycleCOMMENT
MEDIUMclient/python/tests/test_http_integration.py168 # Create a second complete event with different timestampCOMMENT
MEDIUMclient/python/tests/test_factory.py238 # Create a transport with invalid config_classCOMMENT
MEDIUMclient/python/tests/test_gcplineage.py295 # Create a non-RunEventCOMMENT
MEDIUMclient/python/tests/test_file.py140 # Create the file and make it read-onlyCOMMENT
MEDIUMclient/python/tests/test_file.py483 # Create a filesystem that raises an error on openCOMMENT
MEDIUMclient/python/tests/test_datadog.py482 # Create a non-RunEventCOMMENT
MEDIUMclient/python/tests/test_jwt_token_provider.py295 # Create a JWT with exp claimCOMMENT
MEDIUM…/python/src/openlineage/client/transport/async_http.py256 # Create a semaphore to limit concurrent requestsCOMMENT
Over-Commented Block29 hits · 29 pts
SeverityFileLineSnippetContext
LOWrelease.sh1#!/bin/bashCOMMENT
LOW.taskrc.yml1# Make `env:` declared in Taskfiles take precedence over inherited shellCOMMENT
LOWintegration/hive-docker/entrypoint.sh1#!/bin/bashCOMMENT
LOW…ion/flink/flink2/src/test/resources/generate_events.sh21COMMENT
LOW…est/java/io/openlineage/flink/Flink2ContainerTest.java201 List<SchemaDatasetFacetFields> fields = input.get().getFacets().getSchema().getFields();COMMENT
LOWintegration/spark/Taskfile.yml1# Tasks for the OpenLineage Spark integration. Included by the root TaskfileCOMMENT
LOWintegration/spark/docker-compose.yml61 # Enables SQL statement logging (see: https://www.postgresql.org/docs/12/runtime-config-logging.html#GUC-LOG-STATEMECOMMENT
LOWintegration/spark/databricks/upload-to-databricks.sh1#!/bin/bashCOMMENT
LOW…gent/lifecycle/plan/LogicalRelationDatasetBuilder.java221 // This is a fallback that can occur when hadoop configurations cannot beCOMMENT
LOWintegration/spark/cli/configurable-test.sh1#!/usr/bin/env bashCOMMENT
LOWintegration/sql/impl/src/context/mod.rs61// since it's supposed to be opaque blob - so we want to keep input and output info.COMMENT
LOWintegration/sql/iface-py/script/build.sh1#!/usr/bin/env bashCOMMENT
LOW.github/dependabot.yml1# For information about how to configure Dependabot, see: COMMENT
LOW.github/workflows/visual-difference-detection.yml1name: Visual difference detectionCOMMENT
LOW.github/workflows/integration-tests-spark-aws.yml1name: Integration tests for Spark AWSCOMMENT
LOW.github/workflows/integration-tests-spark-azure.yml1name: Integration tests for Spark AzureCOMMENT
LOWdev/java-home.sh1#!/bin/shCOMMENT
LOW.circleci/check-changes.sh81# Collect all the jobs from each workflow except for the "workflow_complete" job andCOMMENT
LOW.circleci/config.yml21 nightly-run:COMMENT
LOWclient/go/pkg/openlineage/context.go61 NewEvent(EventType) *RunEventCOMMENT
LOWclient/go/pkg/openlineage/helpers.go21//COMMENT
LOWclient/python/tests/__init__.py1# Copyright 2018-2026 contributors to the OpenLineage projectCOMMENT
LOWclient/python/tests/generator/__init__.py1# Copyright 2018-2026 contributors to the OpenLineage projectCOMMENT
LOWclient/python/tests/transform/__init__.py1# Copyright 2018-2026 contributors to the OpenLineage projectCOMMENT
LOWclient/python/tests/transform/transformers/__init__.py1# Copyright 2018-2026 contributors to the OpenLineage projectCOMMENT
LOW…ge/client/transport/transform/transformers/__init__.py1# Copyright 2018-2026 contributors to the OpenLineage projectCOMMENT
LOW…ient/python/src/openlineage/client/generator/header.py1# Copyright 2018-2026 contributors to the OpenLineage projectCOMMENT
LOW…nt/python/src/openlineage/client/generator/__init__.py1# Copyright 2018-2026 contributors to the OpenLineage projectCOMMENT
LOWclient/python/src/openlineage/client/naming/__init__.py1# Copyright 2018-2026 contributors to the OpenLineage projectCOMMENT
Deep Nesting29 hits · 28 pts
SeverityFileLineSnippetContext
LOW…egration/dbt/tests/integration/test_structured_logs.py10CODE
LOWintegration/dbt/src/openlineage/dbt/__init__.py194CODE
LOW…mmon/tests/dbt/structured_logs/test_structured_logs.py656CODE
LOWintegration/common/script/match.py9CODE
LOWintegration/common/src/openlineage/common/test.py83CODE
LOWintegration/common/src/openlineage/common/utils.py62CODE
LOW…ion/common/src/openlineage/common/provider/bigquery.py121CODE
LOW…ommon/src/openlineage/common/provider/dbt/processor.py298CODE
LOW…ommon/src/openlineage/common/provider/dbt/processor.py1156CODE
LOW…on/common/src/openlineage/common/provider/dbt/utils.py223CODE
LOW…src/openlineage/common/provider/dbt/structured_logs.py203CODE
LOW…src/openlineage/common/provider/dbt/structured_logs.py260CODE
LOW…src/openlineage/common/provider/dbt/structured_logs.py445CODE
LOW…src/openlineage/common/provider/dbt/structured_logs.py878CODE
LOW…enlineage/common/provider/great_expectations/action.py301CODE
LOW…enlineage/common/provider/great_expectations/action.py477CODE
LOWdev/get_contributor_stats.py107CODE
LOWdev/get_contributor_stats.py125CODE
LOWdev/get_changes.py38CODE
LOWclient/python/tests/test_async_http.py312CODE
LOWclient/python/tests/test_async_http.py434CODE
LOW…nt/python/tests/integration/test_server/test_server.py236CODE
LOW…nt/python/tests/integration/test_server/test_server.py275CODE
LOW…nt/python/tests/integration/test_server/test_server.py306CODE
LOWclient/python/src/openlineage/client/client.py447CODE
LOW…/python/src/openlineage/client/transport/gcplineage.py168CODE
LOW…ent/python/src/openlineage/client/transport/datadog.py150CODE
LOW…/python/src/openlineage/client/transport/async_http.py255CODE
LOW…/python/src/openlineage/client/transport/async_http.py358CODE
Redundant / Tautological Comments14 hits · 23 pts
SeverityFileLineSnippetContext
LOWintegration/dbt/tests/integration/conftest.py61 # Check if there's already a valid SQL wheel with matching version and platformCOMMENT
LOW…on/common/src/openlineage/common/provider/snowflake.py29 # Check if it's organization-account format (contains hyphen)COMMENT
LOWintegration/spark/jar_compare.py187 # Check if files are identicalCOMMENT
LOW.pre_commit/check_version_update_path.sh30# Check if all paths existCOMMENT
LOW.pre_commit/run-spec-snapshot.sh45 # Check if the file is tracked by GitCOMMENT
LOW.pre_commit/run-spec-snapshot.sh48 # Check if the copied file differs from the committed version and is not stagedCOMMENT
LOW.pre_commit/run-spec-snapshot.sh50 # Check if the differences are not already stagedCOMMENT
LOW…nt/python/tests/integration/test_server/test_server.py360 # Check if we should simulate an errorCOMMENT
LOW…nt/python/tests/integration/test_server/test_server.py533 # Check if there are completion events before STARTCOMMENT
LOW…nt/python/tests/integration/test_server/test_server.py537 # Check if there's a START event later in the sequenceCOMMENT
LOWclient/python/src/openlineage/client/transport/file.py92 # Check if fsspec features are requested but not availableCOMMENT
LOW…/python/src/openlineage/client/transport/gcplineage.py137 # Check if event should use async transport based on rulesCOMMENT
LOW…ent/python/src/openlineage/client/transport/datadog.py137 # Check if event has JobTypeJobFacet with integration = "dbt"COMMENT
LOW…/python/src/openlineage/client/transport/async_http.py556 # Check if worker thread is still aliveCOMMENT
Modern Structural Boilerplate18 hits · 18 pts
SeverityFileLineSnippetContext
LOWintegration/common/src/openlineage/common/__init__.py6__all__ = ["__version__"]CODE
LOWintegration/common/src/openlineage/common/utils.py8logger = logging.getLogger(__name__)CODE
LOW…common/src/openlineage/common/provider/dbt/__init__.py9__all__ = [CODE
LOW…lineage/common/provider/great_expectations/__init__.py8__all__ = ["OpenLineageValidationAction"]CODE
LOW…egration/common/src/openlineage/common/sql/__init__.py16__all__ = [CODE
LOWclient/python/tests/conftest.py42def _setup_producer(test_producer) -> None:CODE
LOWclient/python/src/openlineage/client/__init__.py16def set_producer(producer: str) -> None:CODE
LOWclient/python/src/openlineage/client/__init__.py21__all__ = ["OpenLineageClient", "OpenLineageClientOptions", "set_producer", "__version__"]CODE
LOWclient/python/src/openlineage/client/facet.py20def set_producer(producer: str) -> None:CODE
LOWclient/python/src/openlineage/client/facet_v2.py55__all__ = [CODE
LOWclient/python/src/openlineage/client/event_v2.py23__all__ = [CODE
LOW…on/src/openlineage/client/transport/amazon_datazone.py75 def _setup_datazone(self, region: str | None = None, endpoint_url: str | None = None) -> None:CODE
LOW…nt/python/src/openlineage/client/transport/__init__.py49__all__ = [CODE
LOWclient/python/src/openlineage/client/transport/kafka.py189 def _setup_producer(self, config: dict) -> None: # type: ignore[type-arg]CODE
LOW…ent/python/src/openlineage/client/transport/msk_iam.py79 def _setup_producer(self, config: dict) -> None: # type: ignore[type-arg]CODE
LOW…/python/src/openlineage/client/transport/async_http.py244 def _setup_loop(self) -> None:CODE
LOW…src/openlineage/client/transport/transform/__init__.py14__all__ = [CODE
LOWclient/python/src/openlineage/client/generator/base.py45def set_producer(producer: str) -> None:CODE
Cross-File Repetition3 hits · 15 pts
SeverityFileLineSnippetContext
HIGHwebsite/docs/spec/facets/custom-facets.md0create or replace table tmp_demo.user_counts as ( select date_trunc(day, created_at) date, count(id) as user_count from STRING
HIGHwebsite/docs/client/python/usage.md0create or replace table tmp_demo.user_counts as ( select date_trunc(day, created_at) date, count(id) as user_count from STRING
HIGHwebsite/docs/client/python/development/logging.md0create or replace table tmp_demo.user_counts as ( select date_trunc(day, created_at) date, count(id) as user_count from STRING
AI Slop Vocabulary4 hits · 8 pts
SeverityFileLineSnippetContext
MEDIUM…mmon/tests/dbt/structured_logs/test_structured_logs.py1571 # Valid manifest - comprehensive scenarioCOMMENT
LOW…on/common/src/openlineage/common/provider/snowflake.py70 # else - its new hostname, just return itCOMMENT
MEDIUMclient/python/src/openlineage/client/client.py392 # Special case - for seamless switch to async transportCOMMENT
MEDIUM…/python/src/openlineage/client/transport/gcplineage.py113 """Safely run async coroutine in sync context with robust event loop handling."""STRING
Cross-Language Confusion2 hits · 5 pts
SeverityFileLineSnippetContext
HIGHintegration/common/tests/dbt/test_dbt_local.py381 {{ undefined }}STRING
HIGHintegration/common/tests/dbt/test_dbt_local.py392 {{ undefined }}STRING
Docstring Block Structure1 hit · 5 pts
SeverityFileLineSnippetContext
HIGH…rc/openlineage/client/transport/transform/transform.py63Create a TransformConfig instance from a dictionary of parameters. Validates that required fields (`transport` STRING
Verbosity Indicators3 hits · 4 pts
SeverityFileLineSnippetContext
LOW…src/test/java/io/openlineage/spark/agent/AwsUtils.java77 // Step 1: List objects with the specified prefixCOMMENT
LOW…src/test/java/io/openlineage/spark/agent/AwsUtils.java96 // Step 2: Delete objects in batches (up to 1000 per request)COMMENT
LOW…src/test/java/io/openlineage/spark/agent/AwsUtils.java114 // Step 3: Prepare for the next iteration if more objects are availableCOMMENT
Fake / Example Data3 hits · 3 pts
SeverityFileLineSnippetContext
LOW…penlineage/spark/agent/PostgresJDBCSparkQueryTest.java374 "INSERT INTO authors (author_id, author_name) VALUES (1, 'John Doe');");CODE
LOW…penlineage/spark/agent/PostgresJDBCSparkQueryTest.java382 "INSERT INTO authors (author_id, author_name) VALUES (2, 'Jane Doe');");CODE
LOWclient/python/tests/test_http_integration.py448 {"Authorization": "Bearer fake-token", "X-Custom": "value"},CODE
Overly Generic Function Names2 hits · 2 pts
SeverityFileLineSnippetContext
LOWclient/python/tests/generator/test_base.py144def my_function():CODE
LOWclient/python/tests/generator/test_base.py150 assert "def my_function():" in restSTRING
TODO Padding1 hit · 2 pts
SeverityFileLineSnippetContext
LOW…va/io/openlineage/flink/visitor/JdbcSourceVisitor.java54 // TODO: implement namespace resolverCOMMENT
Slop Phrases1 hit · 2 pts
SeverityFileLineSnippetContext
LOWintegration/sql/iface-py/tests/python/sql_tester.py24# via UNIX pipe to the tool. In case of inputing directly, make sure to pressCOMMENT