Repository Analysis

feldera/feldera

The Feldera Incremental Computation Engine

7.0 Low AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of feldera/feldera, a Rust project with 2,032 GitHub stars. SynthScan v2.0 examined 887,622 lines of code across 3165 source files, recording 3817 pattern matches distributed across 24 syntactic categories. The overall adjusted score of 7.0 places this repository in the Low AI signal band.

The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).

7.0
Adjusted Score
7.0
Raw Score
100%
Time Factor
2026-08-09
Last Push
2.0K
Stars
Rust
Language
887.6K
Lines of Code
3.2K
Files
3.8K
Pattern Hits
2026-08-09
Scan Date
0.06
HC Hit Rate

What These Metrics Mean

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

Score History

Longitudinal tracking requires multiple scan runs. Once this repository is re-scanned after new commits land, this chart will visualise how the synthetic code signal evolves over time — enabling you to detect whether AI authorship is growing, stabilising, or being actively corrected by human engineers.

No multi-scan history yet — run the scanner again to build trend data.

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 9HIGH 194MEDIUM 541LOW 3073

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 3817 distinct pattern matches across 24 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.

Decorative Section Separators508 hits · 2058 pts
SeverityFileLineSnippetContext
MEDIUMbenchmark/flink-kafka/nexmark.yaml19#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml21#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml28#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml30#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml40#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml44#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml54#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml56#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml62#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml64#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml69#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/nexmark.yaml71#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml26#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml28#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml35#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml37#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml47#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml49#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml54#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml56#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml77#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml79#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml92#==============================================================================COMMENT
MEDIUMbenchmark/flink-kafka/flink-conf.yaml94#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-rocksdb.yaml27#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-rocksdb.yaml29#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-rocksdb.yaml36#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-rocksdb.yaml38#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-rocksdb.yaml49#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-rocksdb.yaml51#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml19#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml21#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml28#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml30#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml42#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml46#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml56#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml58#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml64#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml66#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml71#==============================================================================COMMENT
MEDIUMbenchmark/flink/nexmark.yaml73#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-hashmap.yaml27#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-hashmap.yaml29#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-hashmap.yaml36#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-hashmap.yaml38#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-hashmap.yaml49#==============================================================================COMMENT
MEDIUMbenchmark/flink/flink-conf-hashmap.yaml51#==============================================================================COMMENT
MEDIUMcrates/sqllib/src/lib.rs261 // ── helpers ────────────────────────────────────────────────────────────COMMENT
MEDIUMcrates/sqllib/src/lib.rs272 // ── combination generator ───────────────────────────────────────────────COMMENT
MEDIUMcrates/sqllib/src/lib.rs392 // ── Recursive step ─────────────────────────────────────────────────────COMMENT
MEDIUMcrates/sqllib/src/lib.rs412 // ── Base: all non-nullable — skip ──────────────────────────────────────COMMENT
MEDIUMcrates/sqllib/src/lib.rs418 // ── Base: ≥1 nullable, no const generics, wrap in Some() ──────────────COMMENT
MEDIUMcrates/sqllib/src/lib.rs434 // ── Base: ≥1 nullable, const generics present, wrap in Some() ─────────COMMENT
MEDIUMcrates/sqllib/src/lib.rs450 // ── Base: ≥1 nullable, no const generics, direct return ───────────────COMMENT
MEDIUMcrates/sqllib/src/lib.rs466 // ── Base: ≥1 nullable, const generics present, direct return ──────────COMMENT
MEDIUMcrates/sqllib/src/string_interner.rs244// ┌──────────┐ ┌────────────────────────┐COMMENT
MEDIUMcrates/sqllib/src/string_interner.rs246// │ ┌───┐ │ ┌───────┐by_id │ │COMMENT
MEDIUMcrates/sqllib/src/string_interner.rs247// │ │Z-1├───┼──────►│gather ├─────►│ INTERNED_STRINGS_BY_ID │COMMENT
MEDIUMcrates/sqllib/src/string_interner.rs248// │ └──┬┘ │ └───────┘ │ CURRENT_STEP │COMMENT
448 more matches not shown…
Over-Commented Block1695 hits · 1526 pts
SeverityFileLineSnippetContext
LOWCargo.toml121# - 5b35c098 "delta-rs: round-robin pre-split unpartitioned scans intoCOMMENT
LOWbenchmark/flink-kafka/nexmark.yaml1################################################################################COMMENT
LOWbenchmark/flink-kafka/nexmark.yaml21#==============================================================================COMMENT
LOWbenchmark/flink-kafka/flink-conf.yaml1################################################################################COMMENT
LOWbenchmark/flink-kafka/run-nexmark.sh1#!/usr/bin/env bashCOMMENT
LOWbenchmark/flink-kafka/config.sh1#!/usr/bin/env bashCOMMENT
LOWbenchmark/flink/flink-conf-rocksdb.yaml1################################################################################COMMENT
LOWbenchmark/flink/nexmark.yaml1################################################################################COMMENT
LOWbenchmark/flink/nexmark.yaml41COMMENT
LOWbenchmark/flink/run.sh1#!/usr/bin/env bashCOMMENT
LOWbenchmark/flink/config.sh1#!/usr/bin/env bashCOMMENT
LOWbenchmark/flink/flink-conf-hashmap.yaml1################################################################################COMMENT
LOWbenchmark/feldera-sql/run.py1#! /usr/bin/python3COMMENT
LOWsql-to-dbsp-compiler/temp/src/stubs.rs1// Compiler-generated file.COMMENT
LOW…g/dbsp/sqlCompiler/compiler/sql/tools/TableParser.java501 }COMMENT
LOW…lCompiler/compiler/sql/simple/ArrayFunctionsTests.java1121 select array_insert(array(1, 2, 3), 3, cast(null as tinyint));COMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1161 // Before this step: waterline = minimum, table is empty.COMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1201 // ts | uid |COMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1301 a | 2 | 2020-01-01 11:50:00 | 2020-01-01 12:05:00 | 1""");COMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1361 // ----+-----+COMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1541 2 | 200 | 1""");COMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1581 // Before this step, table contents:COMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1621 2 | 1000 | 0 | 1COMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1701 ts | v | weightCOMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1721 // 0 | 1 | GC'dCOMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1741 ts | v | weightCOMMENT
LOW…sqlCompiler/compiler/sql/streaming/StreamingTests.java1801 // id | ts | extra |COMMENT
LOW…iler/compiler/sql/postgres/PostgresTimestampTests.java41import org.junit.Test;COMMENT
LOW…iler/compiler/sql/postgres/PostgresTimestampTests.java221 }COMMENT
LOW…iler/compiler/sql/postgres/PostgresTimestampTests.java581 // interval,COMMENT
LOW…lCompiler/compiler/sql/postgres/PostgresDateTests.java141 new DBSPZSetExpression(Linq.map(results,COMMENT
LOW…lCompiler/compiler/sql/postgres/PostgresDateTests.java161 //COMMENT
LOW…lCompiler/compiler/sql/postgres/PostgresDateTests.java181 // Two daysCOMMENT
LOW…lCompiler/compiler/sql/postgres/PostgresBoolTests.java61 // ERROR: invalid input syntax for type boolean: "test"COMMENT
LOW…piler/compiler/sql/postgres/PostgresIntervalTests.java81 //"SELECT INTERVAL '1.5' MONTHS AS \"One month 15 days\";\n" +COMMENT
LOW…ava/org/dbsp/sqlCompiler/ir/expression/DBSPOpcode.java101 // Yet another way to compare, used in controlled filters after a waterlineCOMMENT
LOW…ler/circuit/operator/DBSPConcreteAsofJoinOperator.java61 // join: F,COMMENT
LOW…qlCompiler/compiler/visitors/inner/ExpressionsCSE.java41// |t_1: &Tup3<i32?, i32?, i32?>|COMMENT
LOW…piler/visitors/monotone/MonotoneTransferFunctions.java301 new DBSPLetStatement(expression.parameters[0].getName(),COMMENT
LOW…er/compiler/frontend/aggregates/LeadLagAggregates.java81 inputVar.deref().applyClone());COMMENT
LOW…compiler/frontend/calciteCompiler/ConvertletTable.java341COMMENT
LOW…compiler/frontend/calciteCompiler/ConvertletTable.java1881COMMENT
LOW…compiler/frontend/calciteCompiler/ConvertletTable.java2001 private static class GreatestConvertlet implements SqlRexConvertlet {COMMENT
LOW…compiler/frontend/calciteCompiler/ConvertletTable.java2061 // toCOMMENT
LOW…compiler/frontend/calciteCompiler/ConvertletTable.java2141 // valueCOMMENT
LOW…compiler/frontend/calciteCompiler/ConvertletTable.java2161 // THEN start + length(value) + 1COMMENT
LOW…compiler/frontend/calciteCompiler/ConvertletTable.java2481 @Override public RexNode convertCall(SqlRexContext cx, SqlCall call) {COMMENT
LOW…piler/compiler/backend/rust/BaseRustCodeGenerator.java81 #![allow(non_snake_case)]COMMENT
LOWsql-to-dbsp-compiler/slt/skip.txt1// This file contains a list of buggy tests to skipCOMMENT
LOWcrates/sqllib/src/casts.rs981 Exact(usize),COMMENT
LOWcrates/sqllib/src/lib.rs241///COMMENT
LOWcrates/sqllib/src/lib.rs381/// State carried through `@step`:COMMENT
LOWcrates/sqllib/src/lib.rs761 Some([<$func_name _ $short_name _ $short_name>] $(:: < $($var),* >)? (arg0, arg1))COMMENT
LOWcrates/sqllib/src/lib.rs1401#[doc(hidden)]COMMENT
LOWcrates/sqllib/src/lib.rs1421/// initializers we actually always use static constant values to, butCOMMENT
LOWcrates/sqllib/src/lib.rs1441/// catalog: &mut Catalog,COMMENT
LOWcrates/sqllib/src/string_interner.rs101 /// from the list strings pinned >= 2 steps ago.COMMENT
LOWcrates/sqllib/src/string_interner.rs121COMMENT
LOWcrates/sqllib/src/string_interner.rs241/// is going to schedule the interner circuit to run before all existing inputs.COMMENT
LOWcrates/sqllib/src/flat_variant.rs1//! FlatVariant: a flat-buffer implementation of the SQL VARIANT type.COMMENT
1635 more matches not shown…
Cross-File Repetition158 hits · 790 pts
SeverityFileLineSnippetContext
HIGH…ava/org/dbsp/sqlCompiler/compiler/sql/ParserTests.java0create table t(x int); create view v as select /*+ broadcast(t), shard(s) */ * from t join t as s using (x);STRING
HIGH…er/compiler/sql/simple/IncrementalRegressionTests.java0create table t(x int); create view v as select /*+ broadcast(t), shard(s) */ * from t join t as s using (x);STRING
HIGH…org/dbsp/sqlCompiler/compiler/sql/MultiCrateTests.java0create table t(x int); create view v as select /*+ broadcast(t), shard(s) */ * from t join t as s using (x);STRING
HIGH…/sqlCompiler/compiler/sql/simple/Regression2Tests.java0create table t(x int); create view v as select /*+ broadcast(t), shard(s) */ * from t join t as s using (x);STRING
HIGH…org/dbsp/sqlCompiler/compiler/sql/MultiCrateTests.java0declare recursive view v(v int); create view v (v0) as select distinct v from v union select 1;STRING
HIGH…/compiler/sql/recursive/IncrementalRecursiveTests.java0declare recursive view v(v int); create view v (v0) as select distinct v from v union select 1;STRING
HIGH…sqlCompiler/compiler/sql/recursive/RecursiveTests.java0declare recursive view v(v int); create view v (v0) as select distinct v from v union select 1;STRING
HIGH…dbsp/sqlCompiler/compiler/sql/simple/TinyintTests.java0select x, x::int2 as int2_value from (values (-2.9::float8), (-2.5::float8), (-1.5::float8), (-0.5::float8), (0.0::floatSTRING
HIGH…lCompiler/compiler/sql/postgres/PostgresInt4Tests.java0select x, x::int2 as int2_value from (values (-2.9::float8), (-2.5::float8), (-1.5::float8), (-0.5::float8), (0.0::floatSTRING
HIGH…lCompiler/compiler/sql/postgres/PostgresInt2Tests.java0select x, x::int2 as int2_value from (values (-2.9::float8), (-2.5::float8), (-1.5::float8), (-0.5::float8), (0.0::floatSTRING
HIGH…dbsp/sqlCompiler/compiler/sql/simple/TinyintTests.java0select x, x::int2 as int2_value from (values (-2.9::numeric(2, 1)), (-2.5::numeric(2, 1)), (-1.5::numeric(2, 1)), (-0.5:STRING
HIGH…lCompiler/compiler/sql/postgres/PostgresInt4Tests.java0select x, x::int2 as int2_value from (values (-2.9::numeric(2, 1)), (-2.5::numeric(2, 1)), (-1.5::numeric(2, 1)), (-0.5:STRING
HIGH…lCompiler/compiler/sql/postgres/PostgresInt2Tests.java0select x, x::int2 as int2_value from (values (-2.9::numeric(2, 1)), (-2.5::numeric(2, 1)), (-1.5::numeric(2, 1)), (-0.5:STRING
HIGH…untime_aggtest/aggregate_tests5/test_arg_max_append.py0create materialized view un_int_arg_max_value as select arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) asSTRING
HIGH…/tests/runtime_aggtest/aggregate_tests/test_arg_max.py0create materialized view un_int_arg_max_value as select arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) asSTRING
HIGH…untime_aggtest/aggregate_tests3/test_un_int_arg_max.py0create materialized view un_int_arg_max_value as select arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) asSTRING
HIGH…aggtest/aggregate_tests6/test_un_int_arg_max_append.py0create materialized view un_int_arg_max_value as select arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) asSTRING
HIGH…untime_aggtest/aggregate_tests5/test_arg_max_append.py0create materialized view un_int_arg_max_gby as select id, arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) STRING
HIGH…/tests/runtime_aggtest/aggregate_tests/test_arg_max.py0create materialized view un_int_arg_max_gby as select id, arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) STRING
HIGH…untime_aggtest/aggregate_tests3/test_un_int_arg_max.py0create materialized view un_int_arg_max_gby as select id, arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) STRING
HIGH…aggtest/aggregate_tests6/test_un_int_arg_max_append.py0create materialized view un_int_arg_max_gby as select id, arg_max(c1, c2) as c1, arg_max(c2, c1) as c2, arg_max(c3, c4) STRING
HIGH…untime_aggtest/aggregate_tests5/test_arg_max_append.py0create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as cSTRING
HIGH…/tests/runtime_aggtest/aggregate_tests/test_arg_max.py0create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as cSTRING
HIGH…untime_aggtest/aggregate_tests5/test_arg_min_append.py0create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as cSTRING
HIGH…/tests/runtime_aggtest/aggregate_tests/test_arg_min.py0create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as cSTRING
HIGH…untime_aggtest/aggregate_tests3/test_un_int_arg_min.py0create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as cSTRING
HIGH…aggtest/aggregate_tests6/test_un_int_arg_min_append.py0create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as cSTRING
HIGH…untime_aggtest/aggregate_tests3/test_un_int_arg_max.py0create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as cSTRING
HIGH…aggtest/aggregate_tests6/test_un_int_arg_max_append.py0create materialized view un_int_arg_min_distinct as select arg_min(distinct c1, c2) as c1, arg_min(distinct c2, c1) as cSTRING
HIGH…untime_aggtest/aggregate_tests5/test_arg_max_append.py0create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, STRING
HIGH…/tests/runtime_aggtest/aggregate_tests/test_arg_max.py0create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, STRING
HIGH…untime_aggtest/aggregate_tests5/test_arg_min_append.py0create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, STRING
HIGH…/tests/runtime_aggtest/aggregate_tests/test_arg_min.py0create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, STRING
HIGH…untime_aggtest/aggregate_tests3/test_un_int_arg_min.py0create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, STRING
HIGH…aggtest/aggregate_tests6/test_un_int_arg_min_append.py0create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, STRING
HIGH…untime_aggtest/aggregate_tests3/test_un_int_arg_max.py0create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, STRING
HIGH…aggtest/aggregate_tests6/test_un_int_arg_max_append.py0create materialized view un_int_arg_min_distinct_gby as select id, arg_min(distinct c1, c2) as c1, arg_min(distinct c2, STRING
HIGH…untime_aggtest/aggregate_tests5/test_arg_max_append.py0create materialized view un_int_arg_max_where_gby as select id, arg_max(c1, c2) filter(where c4>13450) as f_c1, arg_max(STRING
HIGH…/tests/runtime_aggtest/aggregate_tests/test_arg_max.py0create materialized view un_int_arg_max_where_gby as select id, arg_max(c1, c2) filter(where c4>13450) as f_c1, arg_max(STRING
HIGH…untime_aggtest/aggregate_tests3/test_un_int_arg_max.py0create materialized view un_int_arg_max_where_gby as select id, arg_max(c1, c2) filter(where c4>13450) as f_c1, arg_max(STRING
HIGH…aggtest/aggregate_tests6/test_un_int_arg_max_append.py0create materialized view un_int_arg_max_where_gby as select id, arg_max(c1, c2) filter(where c4>13450) as f_c1, arg_max(STRING
HIGH…ime_aggtest/aggregate_tests5/test_atbl_charn_append.py0create materialized view atbl_charn as select id, cast(c1 as char(7)) as f_c1, cast(c2 as char(7)) as f_c2 from varchar_STRING
HIGH…ts/runtime_aggtest/aggregate_tests2/test_atbl_charn.py0create materialized view atbl_charn as select id, cast(c1 as char(7)) as f_c1, cast(c2 as char(7)) as f_c2 from varchar_STRING
HIGH…s/runtime_aggtest/aggregate_tests4/test_atbl_charn4.py0create materialized view atbl_charn as select id, cast(c1 as char(7)) as f_c1, cast(c2 as char(7)) as f_c2 from varchar_STRING
HIGH…ts/runtime_aggtest/aggregate_tests5/test_max_append.py0create materialized view un_int_max_gby as select id, max(c1) as c1, max(c2) as c2, max(c3) as c3, max(c4) as c4, max(c5STRING
HIGH…thon/tests/runtime_aggtest/aggregate_tests/test_max.py0create materialized view un_int_max_gby as select id, max(c1) as c1, max(c2) as c2, max(c3) as c3, max(c4) as c4, max(c5STRING
HIGH…ts/runtime_aggtest/aggregate_tests3/test_un_int_max.py0create materialized view un_int_max_gby as select id, max(c1) as c1, max(c2) as c2, max(c3) as c3, max(c4) as c4, max(c5STRING
HIGH…ime_aggtest/aggregate_tests6/test_un_int_max_append.py0create materialized view un_int_max_gby as select id, max(c1) as c1, max(c2) as c2, max(c3) as c3, max(c4) as c4, max(c5STRING
HIGH…ts/runtime_aggtest/aggregate_tests5/test_max_append.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…thon/tests/runtime_aggtest/aggregate_tests/test_max.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…ts/runtime_aggtest/aggregate_tests5/test_min_append.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…thon/tests/runtime_aggtest/aggregate_tests/test_min.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…ts/runtime_aggtest/aggregate_tests3/test_un_int_min.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…ime_aggtest/aggregate_tests6/test_un_int_min_append.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…ts/runtime_aggtest/aggregate_tests3/test_un_int_sum.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…time_aggtest/aggregate_tests3/test_un_int_count_col.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…ts/runtime_aggtest/aggregate_tests3/test_un_int_avg.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…ts/runtime_aggtest/aggregate_tests3/test_un_int_max.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…ime_aggtest/aggregate_tests6/test_un_int_max_append.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
HIGH…ime_aggtest/aggregate_tests3/test_un_int_stddev_pop.py0create materialized view un_int_avg_distinct as select avg(distinct c1) as c1, avg(distinct c2) as c2, avg(distinct c3) STRING
98 more matches not shown…
Hyper-Verbose Identifiers575 hits · 585 pts
SeverityFileLineSnippetContext
LOWpython/tests/utils.py480def ensure_delta_spark_fixture(CODE
LOWpython/tests/unit/test_stats.py17def test_commit_progress_absent_when_no_transaction():CODE
LOWpython/tests/unit/test_stats.py22def test_commit_progress_parsed_into_object():CODE
LOWpython/tests/unit/test_stats.py39def test_commit_progress_str_matches_rust_display_format():CODE
LOWpython/tests/unit/test_stats.py55def test_progress_summary_falls_back_to_record_counts_outside_transaction():CODE
LOWpython/tests/unit/test_stats.py60def test_progress_summary_prefers_commit_progress_during_transaction():CODE
LOWpython/tests/unit/test_tags.py6def test_display_name_strips_color_suffix():CODE
LOWpython/tests/unit/test_tags.py26def test_normalize_sorts_lexicographically():CODE
LOWpython/tests/unit/test_tags.py30def test_normalize_is_idempotent():CODE
LOWpython/tests/unit/test_tags.py39def test_normalize_collapses_color_variants_keeping_last():CODE
LOWpython/tests/unit/test_tags.py47def test_normalize_preserves_color_of_survivor():CODE
LOWpython/tests/unit/test_tags.py53def test_normalize_distinct_names_with_colors_all_kept():CODE
LOWpython/tests/unit/test_tags.py62def test_normalize_accepts_any_iterable():CODE
LOWpython/tests/unit/test_long_operation_warning.py33 def test_no_warning_before_threshold(self, caplog):CODE
LOWpython/tests/unit/test_long_operation_warning.py39 def test_warning_after_threshold(self, caplog):CODE
LOWpython/tests/unit/test_long_operation_warning.py46 def test_threshold_doubles_after_each_warning(self, caplog):CODE
LOWpython/tests/unit/test_long_operation_warning.py56 def test_done_is_noop_if_never_warned(self, caplog):CODE
LOWpython/tests/unit/test_long_operation_warning.py63 def test_done_logs_if_previously_warned(self, caplog):CODE
LOWpython/tests/unit/test_long_operation_warning.py71 def test_done_without_done_message_is_silent(self, caplog):CODE
LOWpython/tests/unit/test_long_operation_warning.py86 def test_uses_configured_level(self, caplog):CODE
LOWpython/tests/unit/test_long_operation_warning.py93 def test_default_level_is_visible_at_info(self, caplog):CODE
LOWpython/tests/unit/test_github_oidc_token_retry.py56 def test_does_not_retry_non_transient_status(self):CODE
LOWpython/tests/unit/test_github_oidc_token_retry.py73 def test_exhausts_retries_and_raises(self):CODE
LOWpython/tests/unit/test_github_oidc_token_retry.py89 def test_retries_on_connection_error(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py132 def test_status_codes_are_coerced_to_frozenset(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py137 def test_config_default_retry_config(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py140 def test_config_uses_custom_retry_config(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py227 def test_timeout_exhausts_raises_timeout_error(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py234 def test_get_connection_error_then_success(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py244 def test_get_connection_error_exhausts_raises_wrapped(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py253 def test_post_connection_error_is_not_retried(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py262 def test_post_marked_idempotent_retries_connection_error(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py271 def test_get_marked_not_idempotent_skips_connection_error_retry(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py303 def test_no_retries_when_max_retries_zero(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py310 def test_custom_retry_config_uses_its_limit(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py319 def test_deadline_lifts_attempt_cap(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py328 def test_deadline_expiry_stops_retrying(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py494 def test_stop_pipeline_posts_idempotent(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py499 def test_pause_pipeline_posts_idempotent(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py504 def test_delete_pipeline_deletes_idempotent(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py511 def test_passes_retry_config_through(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py172 def test_other_retryable_statuses(self, status):CODE
LOWpython/tests/unit/test_httprequests_retry.py206 def test_timeout_then_success(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py215 def test_connect_timeout_is_retried(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py347 def test_retry_after_header_is_honored(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py362 def test_retry_after_capped_at_max_backoff(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py378 def test_retry_after_http_date_is_parsed(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py397 def test_backoff_grows_as_documented(self):CODE
LOWpython/tests/unit/test_httprequests_retry.py415 def test_jitter_adds_uniform_extra(self):CODE
LOWpython/tests/unit/test_query_as_arrow.py38 def test_non_empty_result_yields_correct_data(self, client: FelderaClient):CODE
LOWpython/tests/unit/test_query_as_arrow.py52 def test_http_called_with_correct_params(self, client: FelderaClient):CODE
LOWpython/tests/unit/test_query_as_arrow.py69 def test_empty_result_yields_no_batches(self, client: FelderaClient):CODE
LOWpython/tests/unit/test_query_as_arrow.py86 def test_response_closed_after_full_consumption(self, client: FelderaClient):CODE
LOWpython/tests/unit/test_query_as_arrow.py98 def test_query_arrow_delegates_to_client(self):CODE
LOWpython/tests/unit/test_callable_api_key.py72 def test_static_key_used_verbatim(self):CODE
LOWpython/tests/unit/test_callable_api_key.py75 def test_callable_invoked_and_stripped(self):CODE
LOWpython/tests/unit/test_callable_api_key.py78 def test_non_str_callable_raises(self):CODE
LOWpython/tests/unit/test_callable_api_key.py82 def test_callable_invoked_per_request(self):CODE
LOWpython/tests/unit/test_callable_api_key.py121 def test_cluster_health_probe_sends_bearer(self):CODE
LOWpython/tests/platform/test_output_buffer_checkpoint.py35def test_output_buffer_does_not_stall_checkpoint(pipeline_name):CODE
515 more matches not shown…
Unused Imports444 hits · 373 pts
SeverityFileLineSnippetContext
LOWcrates/iceberg/src/test/create_test_table_s3.py7CODE
LOWcrates/iceberg/src/test/create_test_table_s3.py7CODE
LOWpython/tests/__init__.py4CODE
LOWpython/tests/__init__.py4CODE
LOWpython/tests/__init__.py4CODE
LOWpython/tests/__init__.py4CODE
LOWpython/tests/__init__.py4CODE
LOWpython/tests/__init__.py4CODE
LOWpython/tests/__init__.py4CODE
LOWpython/tests/__init__.py13CODE
LOWpython/tests/__init__.py13CODE
LOWpython/tests/__init__.py13CODE
LOWpython/tests/__init__.py13CODE
LOWpython/tests/__init__.py13CODE
LOWpython/tests/__init__.py13CODE
LOWpython/tests/__init__.py13CODE
LOWpython/tests/utils.py15CODE
LOWpython/tests/stop_ci_run_pipelines.py28CODE
LOWpython/tests/runtime_aggtest/illarg_tests/main.py3CODE
LOWpython/tests/runtime_aggtest/illarg_tests/main.py6CODE
LOWpython/tests/runtime_aggtest/illarg_tests/main.py7CODE
LOWpython/tests/runtime_aggtest/illarg_tests/main.py8CODE
LOWpython/tests/runtime_aggtest/illarg_tests/main.py9CODE
LOWpython/tests/runtime_aggtest/illarg_tests/main.py10CODE
LOWpython/tests/runtime_aggtest/illarg_tests/main.py11CODE
LOWpython/tests/runtime_aggtest/illarg_tests/main.py12CODE
LOWpython/tests/runtime_aggtest/illarg_tests/main.py13CODE
LOWpython/tests/runtime_aggtest/illarg_tests/main.py14CODE
LOW…n/tests/runtime_aggtest/aggregate_tests5/test_table.py1CODE
LOW…n/tests/runtime_aggtest/aggregate_tests5/test_table.py2CODE
LOW…n/tests/runtime_aggtest/aggregate_tests5/test_table.py3CODE
LOW…n/tests/runtime_aggtest/aggregate_tests5/test_table.py4CODE
LOW…n/tests/runtime_aggtest/aggregate_tests5/test_table.py5CODE
LOW…n/tests/runtime_aggtest/aggregate_tests5/test_table.py6CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py4CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py7CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py8CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py9CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py10CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py11CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py12CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py13CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py14CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py15CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py16CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py17CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py18CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py19CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py20CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py21CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py22CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py23CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py24CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py25CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py26CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py27CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py28CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py29CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py30CODE
LOWpython/tests/runtime_aggtest/aggregate_tests5/main.py31CODE
384 more matches not shown…
Cross-Language Confusion31 hits · 195 pts
SeverityFileLineSnippetContext
HIGH…s/runtime_aggtest/illarg_tests/test_str_bin_type_fn.py626 bin || bin AS bin,CODE
HIGH…s/runtime_aggtest/illarg_tests/test_str_bin_type_fn.py627 str || str AS strCODE
HIGH…s/runtime_aggtest/illarg_tests/test_str_bin_type_fn.py637 intt || intt AS inttCODE
HIGH…s/runtime_aggtest/illarg_tests/test_str_bin_type_fn.py647 roww || roww AS rowwCODE
HIGH…ts/runtime_aggtest/illarg_tests/test_str_unicode_fn.py385 str || str AS strCODE
HIGH…sts/runtime_aggtest/variant_tests/dtype_and_variant.py790 "roww_varnt": '{"int":null,"var":null}',CODE
HIGH…/unsigned_int_tests/test_un_int_supported_functions.py632 tiny_int || tiny_int AS tiny_int,CODE
HIGH…/unsigned_int_tests/test_un_int_supported_functions.py633 small_int || small_int AS small_int,CODE
HIGH…/unsigned_int_tests/test_un_int_supported_functions.py634 intt || intt AS intt,CODE
HIGH…/unsigned_int_tests/test_un_int_supported_functions.py635 big_int || big_int AS big_intCODE
HIGHpython/tests/platform/test_ingress_formats.py609 "CREATE TABLE t1(id bigint not null, s varchar not null); "CODE
HIGHpython/tests/platform/test_ingress_formats.py661 "id1 bigint not null,"CODE
HIGHpython/tests/platform/test_ingress_formats.py662 "id2 bigint not null,"CODE
HIGHpython/tests/platform/test_ingress_formats.py663 "str1 varchar not null,"CODE
HIGHpython/tests/platform/test_ingress_formats.py665 "int1 bigint not null,"CODE
HIGHpython/tests/platform/test_ingress_formats.py809 # Expect 3 events: delete (id2=1 id1=2 old str2=foo), delete (id1=3...), insert (id1=2 updated str2 null)COMMENT
HIGHpython/tests/platform/test_ingress_formats.py382 '{"id":1,"v":{"name":"Bob","scores":[1,2.5,null],"ok":true}}\n'CODE
HIGHpython/tests/platform/test_ingress_formats.py386 '{"id":5,"v":null}',CODE
HIGHpython/tests/platform/test_ingress_formats.py483 'CREATE TABLE t1("c1" integer not null,"C2" bool not null,"😁❤" varchar not null,'CODE
HIGHpython/tests/platform/test_ingress_formats.py484 "\"αβγ\" boolean not null, ΔΘ boolean not null) WITH ('materialized'='true');"CODE
HIGHpython/tests/platform/test_ingress_formats.py506 sql = "CREATE TABLE t1(id bigint not null, s varchar not null, primary key(id)) "CODE
HIGHpython/tests/platform/test_ingress_formats.py553 'CREATE TABLE "TaBle1"(id bigint not null);'CODE
HIGHpython/tests/platform/test_ingress_formats.py801 '{"update":{"id1":2,"id2":1,"str2":null}},'CODE
HIGHpython/tests/runtime/test_postprocessor.py126 result.push(b'\n');CODE
HIGHpython/tests/runtime/test_clock_advance.py10* `advance(null)`: advance by one `clock_resolution`,STRING
HIGHpython/tests/runtime/test_clock_advance.py39# Clock resolution configured below; `advance(null)` moves NOW() by this much.COMMENT
HIGHpython/tests/runtime/test_clock_advance.py71 # and `advance(null)` moves NOW() by exactly this much.COMMENT
HIGHpython/tests/runtime/test_clock_advance.py92 # advance(null) advances by exactly one clock_resolution.COMMENT
HIGHpython/tests/runtime/test_adhoc_queries.py28 CREATE TABLE not_materialized(id bigint not null);CODE
HIGHpython/tests/runtime/test_adhoc_queries.py282 """CREATE TABLE "TaBle1"(id bigint not null) WITH ('materialized' = 'true');"""STRING
HIGHscripts/dummy_oidc.py605 # answering null, so drop the empty entries.COMMENT
Structural Annotation Overuse91 hits · 138 pts
SeverityFileLineSnippetContext
LOW…iler/compiler/frontend/aggregates/RangeAggregates.java108 // NOTE: This function requires the arguments to be positiveCOMMENT
LOWcrates/dbsp/src/operator/integral_weight_validator.rs104 // Step 0: insert key 42 with weight +1 → weight 1.COMMENT
LOWcrates/dbsp/src/operator/integral_weight_validator.rs105 // Step 1: delete key 42 with weight -2 → weight -1 (panic).COMMENT
LOWcrates/dbsp/src/operator/dynamic/input.rs1745 // Step 2: repeat with one more additional key.COMMENT
LOWcrates/dbsp/src/operator/dynamic/group/row_number.rs485 // Step 1: Compute R0 and R1.COMMENT
LOWcrates/dbsp/src/operator/dynamic/group/row_number.rs507 // Step 2: Recompute all row numbers from the current position onward.COMMENT
LOWcrates/dbsp/src/operator/dynamic/group/rank.rs581 // Step 1: Compute R0 and R1.COMMENT
LOWcrates/dbsp/src/operator/dynamic/group/rank.rs591 // Step 2: Find the first value with rank R0 and step forward from it to computeCOMMENT
LOWcrates/dbsp/src/operator/dynamic/group/rank.rs625 // Step 3: Recompute all ranks from the current position onward.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1222 // Step 0: add edges 1->2, 2->3; mark 2 as key point.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1227 // Step 1: extend chain with 3->4; mark 3 as key point.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1229 // Step 2: extend chain with 4->5; mark 4 as key point.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1231 // Step 3: remove key point 3 (paths via 3 should disappear).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1233 // Step 4: remove edge 2->3 (breaks the original chain).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1235 // Step 5: add shortcut edge 2->5 (bypasses missing 3->4).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1237 // Step 6: add 5->6 and mark 5,6 as key points.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1239 // Step 7: add edge 6->2 (introduce a cycle).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1241 // Step 8: remove key point 2 (cycle still exists but via non-key).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1243 // Step 9: remove edge 6->2 and key point 5 (break cycle, shrink keys).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1245 // Step 10: re-add key point 2 and edge 2->3 (restore part of chain).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1247 // Step 11: re-add key point 3 and edge 3->4 (chain continues again).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1249 // Step 12: add new branch 3->7 and mark 7 as key point.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1251 // Step 13: add edge 7->5 (reconnect branch to existing node).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1253 // Step 14: add edge 5->8 and mark 8 as key point.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1255 // Step 15: remove edge 2->5 (drop the shortcut).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1257 // Step 16: remove key point 4 (paths via 4 should drop).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1259 // Step 17: add edge 8->2 (new cycle through 8).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1261 // Step 18: remove edge 7->5 (break branch reconnection).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1263 // Step 19: remove key point 7 and edge 8->2 (collapse new cycle).COMMENT
LOWcrates/adapters/src/integrated/delta_table/test.rs2790 // Step 1: two appends => two parquet files, one Delta version each.COMMENT
LOWcrates/adapters/src/integrated/delta_table/test.rs2795 // Step 2: OPTIMIZE coalesces the two files into one. Every action hasCOMMENT
LOWcrates/adapters/src/integrated/delta_table/test.rs2818 // Step 3: no-op UPDATE (`b = b`). delta-rs rewrites every matching fileCOMMENT
LOWcrates/adapters/src/integrated/delta_table/test.rs2841 // Step 4: real change. CDC tables encode an in-place row update as aCOMMENT
LOWcrates/adapters/src/static_compile/catalog.rs1129 // Step 1: insert a couple of values.COMMENT
LOWcrates/adapters/src/static_compile/catalog.rs1149 // Step 2: replace an entry.COMMENT
LOWcrates/adapters/src/static_compile/catalog.rs1166 // Step 3: delete an entry.COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py779 # Step 2: Create checkpoint and syncCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py783 # Step 3: Start standby pipelineCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1035 # Step 1: push a checkpoint to the source pipeline (becomes read_bucket).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1111 # Step 1: create the source pipeline (becomes read_bucket for standby).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1295 # Step 1: source pipeline creates a checkpoint (will become read_bucket).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1380 # Step 1: source pipeline creates a checkpoint (will become read_bucket).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1540 # Step 1: source pipeline creates a checkpoint (will become read_bucket).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py757 # Step 1: Start main pipelineCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py804 # Step 4: Add more data and make 3-10 checkpointsCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py826 # Step 5: Stop main and activate standbyCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py837 # Step 6: Validate standby has all expected recordsCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py942 # Step 1: push a checkpoint to the source pipeline's bucket (becomes read_bucket).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py967 # Step 2: start the main pipeline with an empty bucket and read_bucketCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1055 # Step 2: push a checkpoint to the main pipeline's own bucket.COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1075 # Step 3: restart with both bucket (has main data) and read_bucket (hasCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1131 # Step 2: start the main pipeline; it will push newer checkpoints toCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1144 # Step 3: start the standby pipeline with empty bucket, read_bucket=source.COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1166 # Step 4: main pipeline inserts data and pushes multiple checkpointsCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1184 # Step 5: activate standby — it should have tracked the latest bucketCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1315 # Step 2: main pipeline takes a LOCAL-ONLY checkpoint (never synced).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1341 # Step 3: restart with start_from=latest, empty bucket, read_bucket=source.COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1400 # Step 2: main pipeline takes a LOCAL-ONLY checkpoint (never synced).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1430 # Step 3: restart with the local UUID and read_bucket configured.COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1560 # Step 2: main pipeline creates and syncs its own checkpoint.COMMENT
31 more matches not shown…
Excessive Try-Catch Wrapping102 hits · 104 pts
SeverityFileLineSnippetContext
MEDIUMcrates/iceberg/src/test/create_test_table_s3.py79 print("Error: AWS_ACCESS_KEY_ID is not set")CODE
MEDIUMcrates/iceberg/src/test/create_test_table_s3.py83 print("Error: AWS_SECRET_ACCESS_KEY is not set")CODE
LOWcrates/iceberg/src/test/follow_table.py129 except Exception:CODE
LOWcrates/iceberg/src/test/follow_table.py133 except Exception:CODE
LOWpython/tests/utils.py423 except Exception:CODE
LOWpython/tests/utils.py427 except Exception:CODE
LOWpython/tests/stop_ci_run_pipelines.py79 except Exception as error:CODE
LOWpython/tests/kafka.py36 except Exception:CODE
LOWpython/tests/runtime_aggtest/aggtst_base.py303 except Exception as e:CODE
LOWpython/tests/runtime_aggtest/aggtst_base.py382 except Exception as e:CODE
LOWpython/tests/platform/test_pipeline_env.py20 except Exception as e:CODE
LOWpython/tests/platform/negative_test.py76 except Exception:CODE
LOWpython/tests/platform/negative_test.py116 except Exception:CODE
LOWpython/tests/platform/test_bootstrapping.py73 except Exception as e:STRING
LOWpython/tests/platform/test_bootstrapping.py641 except Exception as e:STRING
LOWpython/tests/platform/test_bootstrapping.py685 except Exception as e:STRING
LOWpython/tests/platform/test_bootstrapping.py730 except Exception as e:STRING
MEDIUMpython/tests/platform/test_checkpoint_sync.py297def checkpoint_sync_completed() -> bool:CODE
LOWpython/tests/platform/test_checkpoint_sync.py57 except Exception as e:CODE
LOWpython/tests/platform/test_checkpoint_sync.py995 except Exception:CODE
LOWpython/tests/platform/test_cluster_health.py29 except Exception:CODE
LOWpython/tests/platform/test_cluster_health.py76 except Exception:CODE
LOWpython/tests/platform/test_ingress_formats.py148 except Exception as e: # noqa: BLE001CODE
LOWpython/tests/platform/test_ingress_formats.py184 except Exception as e:CODE
LOWpython/tests/runtime/test_checkpoint_runtime_upgrade.py368 except Exception as e:CODE
LOWpython/tests/runtime/test_adhoc_queries.py210 except Exception:STRING
LOWpython/tests/workloads/test_jsonbench.py509 except Exception as e:CODE
LOWpython/tests/workloads/test_tpch.py1566 except Exception as e:CODE
LOWpython/tests/workloads/test_tpch.py1585 except Exception as e:CODE
LOWpython/tests/workloads/test_kafka_avro.py46 except Exception as e:CODE
LOWpython/tests/workloads/test_kafka_avro.py104 except Exception as e:CODE
LOWpython/tests/workloads/test_kafka_avro.py139 except Exception as e:CODE
LOWpython/feldera/testutils.py127 except Exception:CODE
LOWpython/feldera/testutils.py358 except Exception as error:CODE
LOWpython/feldera/testutils.py363 except Exception as error:CODE
LOWpython/feldera/testutils.py369 except Exception as error:CODE
LOWpython/feldera/testutils.py452 except Exception as e:CODE
LOWpython/feldera/testutils.py657 except Exception as e:CODE
LOWpython/feldera/testutils.py675 except Exception as e:CODE
LOWpython/feldera/testutils.py689 except Exception as e:CODE
LOWpython/feldera/testutils_oidc.py136 except Exception:CODE
LOWpython/feldera/testutils_oidc.py145 except Exception:CODE
LOWpython/feldera/testutils_oidc.py204 except Exception as e:CODE
LOWpython/feldera/testutils_oidc.py364 except Exception as e:CODE
LOWpython/feldera/rest/_httprequests.py111 except Exception as e:CODE
LOWpython/feldera/rest/errors.py73 except Exception:CODE
LOWpython/feldera/rest/feldera_client.py128 except Exception as e:CODE
LOW…thon/dbt-feldera/integration_tests/test_dbt_feldera.py212 except Exception as exc:CODE
LOW…thon/dbt-feldera/integration_tests/test_dbt_feldera.py224 except Exception as exc:CODE
LOW…thon/dbt-feldera/integration_tests/test_dbt_feldera.py231 except Exception as exc:CODE
LOW…thon/dbt-feldera/integration_tests/test_dbt_feldera.py296 except Exception as exc:CODE
LOW…thon/dbt-feldera/integration_tests/test_dbt_feldera.py449 except Exception as exc:CODE
LOWpython/dbt-feldera/integration_tests/conftest.py46 except Exception:CODE
LOWpython/dbt-feldera/integration_tests/conftest.py74 except Exception:CODE
LOWpython/dbt-feldera/integration_tests/conftest.py138 except Exception:CODE
LOWpython/dbt-feldera/integration_tests/docker_duckdb.py154 except Exception:CODE
LOWpython/dbt-feldera/integration_tests/docker_duckdb.py217 except Exception as exc:CODE
LOWpython/dbt-feldera/dbt/adapters/feldera/connections.py59 except Exception as exc:CODE
LOWpython/dbt-feldera/dbt/adapters/feldera/connections.py119 except Exception as exc:CODE
LOWpython/dbt-feldera/dbt/adapters/feldera/impl.py176 except Exception as exc:CODE
42 more matches not shown…
Verbosity Indicators61 hits · 90 pts
SeverityFileLineSnippetContext
LOWcrates/dbsp/src/operator/integral_weight_validator.rs104 // Step 0: insert key 42 with weight +1 → weight 1.COMMENT
LOWcrates/dbsp/src/operator/integral_weight_validator.rs105 // Step 1: delete key 42 with weight -2 → weight -1 (panic).COMMENT
LOWcrates/dbsp/src/operator/dynamic/input.rs1719 // Step 1:COMMENT
LOWcrates/dbsp/src/operator/dynamic/input.rs1745 // Step 2: repeat with one more additional key.COMMENT
LOWcrates/dbsp/src/operator/dynamic/group/row_number.rs485 // Step 1: Compute R0 and R1.COMMENT
LOWcrates/dbsp/src/operator/dynamic/group/row_number.rs507 // Step 2: Recompute all row numbers from the current position onward.COMMENT
LOWcrates/dbsp/src/operator/dynamic/group/rank.rs581 // Step 1: Compute R0 and R1.COMMENT
LOWcrates/dbsp/src/operator/dynamic/group/rank.rs591 // Step 2: Find the first value with rank R0 and step forward from it to computeCOMMENT
LOWcrates/dbsp/src/operator/dynamic/group/rank.rs625 // Step 3: Recompute all ranks from the current position onward.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1222 // Step 0: add edges 1->2, 2->3; mark 2 as key point.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1227 // Step 1: extend chain with 3->4; mark 3 as key point.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1229 // Step 2: extend chain with 4->5; mark 4 as key point.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1231 // Step 3: remove key point 3 (paths via 3 should disappear).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1233 // Step 4: remove edge 2->3 (breaks the original chain).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1235 // Step 5: add shortcut edge 2->5 (bypasses missing 3->4).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1237 // Step 6: add 5->6 and mark 5,6 as key points.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1239 // Step 7: add edge 6->2 (introduce a cycle).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1241 // Step 8: remove key point 2 (cycle still exists but via non-key).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1243 // Step 9: remove edge 6->2 and key point 5 (break cycle, shrink keys).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1245 // Step 10: re-add key point 2 and edge 2->3 (restore part of chain).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1247 // Step 11: re-add key point 3 and edge 3->4 (chain continues again).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1249 // Step 12: add new branch 3->7 and mark 7 as key point.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1251 // Step 13: add edge 7->5 (reconnect branch to existing node).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1253 // Step 14: add edge 5->8 and mark 8 as key point.COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1255 // Step 15: remove edge 2->5 (drop the shortcut).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1257 // Step 16: remove key point 4 (paths via 4 should drop).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1259 // Step 17: add edge 8->2 (new cycle through 8).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1261 // Step 18: remove edge 7->5 (break branch reconnection).COMMENT
LOWcrates/dbsp/src/operator/dynamic/multijoin/star_join.rs1263 // Step 19: remove key point 7 and edge 8->2 (collapse new cycle).COMMENT
LOWcrates/adapters/src/integrated/delta_table/test.rs2790 // Step 1: two appends => two parquet files, one Delta version each.COMMENT
LOWcrates/adapters/src/integrated/delta_table/test.rs2795 // Step 2: OPTIMIZE coalesces the two files into one. Every action hasCOMMENT
LOWcrates/adapters/src/integrated/delta_table/test.rs2818 // Step 3: no-op UPDATE (`b = b`). delta-rs rewrites every matching fileCOMMENT
LOWcrates/adapters/src/integrated/delta_table/test.rs2841 // Step 4: real change. CDC tables encode an in-place row update as aCOMMENT
LOWcrates/adapters/src/static_compile/catalog.rs1129 // Step 1: insert a couple of values.COMMENT
LOWcrates/adapters/src/static_compile/catalog.rs1149 // Step 2: replace an entry.COMMENT
LOWcrates/adapters/src/static_compile/catalog.rs1166 // Step 3: delete an entry.COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py779 # Step 2: Create checkpoint and syncCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py783 # Step 3: Start standby pipelineCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1035 # Step 1: push a checkpoint to the source pipeline (becomes read_bucket).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1111 # Step 1: create the source pipeline (becomes read_bucket for standby).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1295 # Step 1: source pipeline creates a checkpoint (will become read_bucket).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1380 # Step 1: source pipeline creates a checkpoint (will become read_bucket).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1540 # Step 1: source pipeline creates a checkpoint (will become read_bucket).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py757 # Step 1: Start main pipelineCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py804 # Step 4: Add more data and make 3-10 checkpointsCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py826 # Step 5: Stop main and activate standbyCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py837 # Step 6: Validate standby has all expected recordsCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py942 # Step 1: push a checkpoint to the source pipeline's bucket (becomes read_bucket).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py967 # Step 2: start the main pipeline with an empty bucket and read_bucketCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1055 # Step 2: push a checkpoint to the main pipeline's own bucket.COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1075 # Step 3: restart with both bucket (has main data) and read_bucket (hasCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1131 # Step 2: start the main pipeline; it will push newer checkpoints toCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1144 # Step 3: start the standby pipeline with empty bucket, read_bucket=source.COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1166 # Step 4: main pipeline inserts data and pushes multiple checkpointsCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1184 # Step 5: activate standby — it should have tracked the latest bucketCOMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1315 # Step 2: main pipeline takes a LOCAL-ONLY checkpoint (never synced).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1341 # Step 3: restart with start_from=latest, empty bucket, read_bucket=source.COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1400 # Step 2: main pipeline takes a LOCAL-ONLY checkpoint (never synced).COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1430 # Step 3: restart with the local UUID and read_bucket configured.COMMENT
LOWpython/tests/platform/test_checkpoint_sync.py1560 # Step 2: main pipeline creates and syncs its own checkpoint.COMMENT
1 more matches not shown…
Hallucination Indicators9 hits · 90 pts
SeverityFileLineSnippetContext
CRITICAL…sp/sqlCompiler/ir/type/primitive/DBSPTypeBaseType.java44 && org.dbsp.sqlCompiler.compiler.VariantMode.isEnabled())CODE
CRITICAL…sp/sqlCompiler/ir/type/primitive/DBSPTypeBaseType.java51 && org.dbsp.sqlCompiler.compiler.VariantMode.isEnabled())CODE
CRITICAL…g/dbsp/sqlCompiler/circuit/annotation/Annotations.java30 Annotation anno = org.dbsp.sqlCompiler.circuit.annotation.Annotation.fromJson(annotation);CODE
CRITICAL…mpiler/frontend/calciteCompiler/RenameIdentifiers.java199 return new org.dbsp.sqlCompiler.compiler.frontend.parser.SqlCreateTable(CODE
CRITICALcrates/dbsp/src/trace/ord/file/key_batch.rs438 time: self.batch.factories.factories1.key_factory.default_box(),CODE
CRITICALcrates/dbsp/src/trace/ord/vec/val_batch.rs678 let mut times = factories.layer_factories.child.child.keys.default_box();CODE
CRITICALcrates/dbsp/src/trace/ord/vec/val_batch.rs681 let mut diffs = factories.layer_factories.child.child.diffs.default_box();CODE
CRITICALcrates/adapters/src/controller.rs1360 .with_product(self.inner.status.pipeline_config.given_name.as_ref())CODE
CRITICALcrates/adapters/src/controller.rs8456 if self.status.pipeline_config.global.storage.is_none() {CODE
AI Slop Vocabulary15 hits · 43 pts
SeverityFileLineSnippetContext
MEDIUMopenapi.json5 "description": "\nWith Feldera, users create data pipelines out of SQL programs.\nA SQL program comprises tables andCODE
MEDIUM…Compiler/compiler/sql/tools/CompilerCircuitStream.java138 // not very robustCOMMENT
MEDIUM…piler/visitors/outer/intern/RewriteInternedFields.java401 // Essentially an identity functionCOMMENT
MEDIUM…piler/visitors/outer/intern/RewriteInternedFields.java414 // Essentially an identity functionCOMMENT
MEDIUMcrates/sqllib/src/float.rs470/// This is used to make tests involving FP values more robust; insteadCOMMENT
MEDIUMcrates/sqllib/src/float.rs494/// This is used to make tests involving FP values more robust; insteadCOMMENT
MEDIUMcrates/dbsp/src/circuit/circuit_builder.rs1450/// To leverage such optimizations, we adopt the best-effort approach: operatorsCOMMENT
MEDIUM…dbsp/src/operator/dynamic/aggregate/chain_aggregate.rs321 /// This design is robust against clock going back, clock input missing in some steps (e.g., in the middle of a tranCOMMENT
MEDIUMcrates/adapters/src/util.rs713 // making the test robust against timing and scheduling variations.COMMENT
MEDIUMcrates/adapters/src/server/stack_overflow_backtrace.rs75/// PRs to make this more robust are welcomeCOMMENT
MEDIUMcrates/adapters/src/integrated/delta_table/input.rs106/// so the check is robust to the deeply nested errors DataFusion typicallyCOMMENT
MEDIUMcrates/adapters/src/integrated/postgres/cdc_input.rs1642 // deterministic, just less robust to URI format variations.COMMENT
MEDIUMcrates/fxp/src/fixed.rs747 // Definitely does not fit.COMMENT
MEDIUMcrates/rest-api/openapi.json5 "description": "\nWith Feldera, users create data pipelines out of SQL programs.\nA SQL program comprises tables andCODE
MEDIUMpython/tests/utils.py388 # Bare (scheme-less) table path: the Rust FS harness reads tablesCOMMENT
Deep Nesting37 hits · 36 pts
SeverityFileLineSnippetContext
LOWbenchmark/feldera-sql/run.py27CODE
LOWbenchmark/feldera-sql/run.py82CODE
LOWbenchmark/feldera-sql/run.py232CODE
LOWpython/tests/runtime_aggtest/aggtst_base.py256CODE
LOWpython/tests/runtime_aggtest/atest_register_tests.py8CODE
LOW…n/tests/runtime_aggtest/orderby_tests/sqlite_runner.py127CODE
LOWpython/tests/platform/test_cluster_health.py55CODE
LOWpython/tests/platform/test_ingress_formats.py164CODE
LOWpython/tests/platform/test_orchestration.py216CODE
LOWpython/tests/platform/test_orchestration.py309CODE
LOWpython/tests/workloads/test_jsonbench.py186CODE
LOWpython/tests/workloads/test_tpch.py1467CODE
LOWpython/tests/workloads/test_tpch.py31CODE
LOWpython/tests/workloads/test_kafka_avro.py27CODE
LOWpython/tests/workloads/test_kafka_avro.py404CODE
LOWpython/feldera/_helpers.py65CODE
LOWpython/feldera/rest/_httprequests.py189CODE
LOWpython/feldera/rest/feldera_client.py184CODE
LOW…thon/dbt-feldera/integration_tests/test_dbt_feldera.py167CODE
LOWpython/dbt-feldera/dbt/adapters/feldera/impl.py608CODE
LOWpython/dbt-feldera/dbt/adapters/feldera/cursor.py97CODE
LOW…n/dbt-feldera/dbt/adapters/feldera/pipeline_manager.py266CODE
LOW…n/dbt-feldera/dbt/adapters/feldera/pipeline_manager.py407CODE
LOWpython/felderize/felderize/docs.py143CODE
LOWpython/felderize/felderize/docs.py186CODE
LOWpython/felderize/felderize/docs.py215CODE
LOWpython/felderize/felderize/docs.py323CODE
LOWscripts/scalebench.py113CODE
LOWscripts/scalebench.py344CODE
LOWscripts/scalebench.py356CODE
LOWscripts/scalebench.py396CODE
LOWscripts/scalebench.py624CODE
LOWscripts/dashboard.py589CODE
LOWscripts/dashboard.py1103CODE
LOWscripts/backup_pipelines.py262CODE
LOWscripts/dummy_oidc.py135CODE
LOWscripts/dummy_oidc.py638CODE
Fake / Example Data26 hits · 28 pts
SeverityFileLineSnippetContext
LOWpython/tests/platform_rbac/test_3_negative.py46 token = rogue_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_3_negative.py57 forged = rogue_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_3_negative.py59 genuine = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_3_negative.py70 "admin", email="admin@example.com", tenants=[TENANT], expires_in=-3600CODE
LOWpython/tests/platform_rbac/test_3_negative.py79 "admin", email="admin@example.com", tenants=[TENANT], audience="some-other-api"CODE
LOWpython/tests/platform_rbac/test_3_negative.py161 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_3_negative.py170 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_3_negative.py263 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_3_negative.py298 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_3_negative.py333 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_3_negative.py361 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_3_negative.py384 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_1_scenarios.py84 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_1_scenarios.py110 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_1_scenarios.py165 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_1_scenarios.py207 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_1_scenarios.py251 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_1_scenarios.py300 "admin", email="admin@example.com", tenants=[RENAMED_TENANT]CODE
LOWpython/tests/platform_rbac/test_1_scenarios.py395 "admin", email="admin@example.com", tenants=[TENANT, "beta"]CODE
LOWpython/tests/platform_rbac/test_1_scenarios.py414 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWpython/tests/platform_rbac/test_5_owner_revocation.py88 admin = primary_idp.token("admin", email="admin@example.com", tenants=[home])CODE
LOWpython/tests/platform_rbac/test_4_migration.py67 admin = primary_idp.token("admin", email="admin@example.com", tenants=[TENANT])CODE
LOWdocs.feldera.com/docs/sql/json.md553{"id": 123, "json": {"name": "John Doe", "scores": [8, 10]}}CODE
LOWscripts/rbac_demo.py86 "admin": mint(args.oidc, "admin", "admin@example.com", [tenant]),CODE
LOWscripts/dummy_oidc.py47KID = "dummy-key-1"CODE
LOWscripts/dummy_oidc.py79 "email": "admin@example.com",CODE
Modern Structural Boilerplate17 hits · 18 pts
SeverityFileLineSnippetContext
LOWpython/tests/__init__.py26__all__ = [CODE
LOWpython/tests/shared_test_pipeline.py14logger = logging.getLogger(__name__)CODE
LOWpython/tests/platform/helper.py42logger = logging.getLogger(__name__)CODE
LOWpython/tests/platform/helper.py299__all__ = [CODE
LOWpython/feldera/testutils.py26logger = logging.getLogger(__name__)CODE
LOWpython/feldera/pipeline.py49logger = logging.getLogger(__name__)CODE
LOWpython/feldera/rest/feldera_client.py25logger = logging.getLogger(__name__)CODE
LOW…thon/dbt-feldera/integration_tests/test_dbt_feldera.py33logger = logging.getLogger(__name__)CODE
LOWpython/dbt-feldera/integration_tests/conftest.py15logger = logging.getLogger(__name__)CODE
LOWpython/dbt-feldera/integration_tests/docker_duckdb.py17logger = logging.getLogger(__name__)CODE
LOWpython/dbt-feldera/integration_tests/docker_manager.py8logger = logging.getLogger(__name__)CODE
LOWpython/dbt-feldera/dbt/adapters/feldera/credentials.py7logger = logging.getLogger(__name__)CODE
LOWpython/dbt-feldera/dbt/adapters/feldera/connections.py19logger = logging.getLogger(__name__)CODE
LOWpython/dbt-feldera/dbt/adapters/feldera/impl.py17logger = logging.getLogger(__name__)CODE
LOWpython/dbt-feldera/dbt/adapters/feldera/cursor.py10logger = logging.getLogger(__name__)CODE
LOW…n/dbt-feldera/dbt/adapters/feldera/pipeline_manager.py15logger = logging.getLogger(__name__)CODE
LOWpython/felderize/felderize/__init__.py31__all__ = [CODE
Modern AI Meta-Vocabulary8 hits · 16 pts
SeverityFileLineSnippetContext
MEDIUMcrates/dbsp/src/circuit/circuit_builder.rs2764 /// checks, but there are currently no guardrails in the system againstCOMMENT
MEDIUMpython/feldera/pipeline.py237 https://docs.feldera.com/connectors/#input-connector-orchestrationSTRING
MEDIUMpython/feldera/pipeline.py256 https://docs.feldera.com/connectors/#input-connector-orchestrationSTRING
MEDIUMpython/feldera/rest/feldera_client.py1613 <https://docs.feldera.com/connectors/#input-connector-orchestration>STRING
MEDIUMpython/feldera/rest/feldera_client.py1638 <https://docs.feldera.com/connectors/#input-connector-orchestration>STRING
MEDIUMdocs.feldera.com/docs/connectors/orchestration.md1# Input connector orchestrationCOMMENT
MEDIUMdocs.feldera.com/docs/connectors/orchestration.md125## Automatic connector orchestrationCOMMENT
MEDIUM…ocs/use_cases/medallion_architecture/spark_notebook.py11# MAGIC no full re-scans, no orchestration.COMMENT
Magic Placeholder Names3 hits · 15 pts
SeverityFileLineSnippetContext
HIGHpython/tests/platform/TEST_AUTH.md36export FELDERA_API_KEY="your-api-key"CODE
HIGHpython/tests/platform/TEST_AUTH.md79 export FELDERA_API_KEY="your-api-key"CODE
HIGH…era.com/docs/use_cases/medallion_architecture/part2.md25export FELDERA_API_KEY=<your-api-key> # only if your instance requires authCODE
Slop Phrases7 hits · 14 pts
SeverityFileLineSnippetContext
LOW…lCompiler/compiler/frontend/CalciteToDBSPCompiler.java2242 // Don't forget to drop the added fieldCOMMENT
MEDIUMcrates/dbsp/src/operator/trace.rs148 /// * As discussed above, the retainment policy set using this methodCOMMENT
MEDIUMcrates/dbsp/src/operator/accumulate_trace.rs149 /// * As discussed above, the retainment policy set using this methodCOMMENT
LOWdeploy/docker-compose.yml7 # If you change the host side of the port mapping here, don't forget toCOMMENT
LOWdeploy/docker-compose.yml7 # If you change the host side of the port mapping here, don't forget toCOMMENT
LOWscripts/bump-versions.sh8# When pushing commits created by this script, don't forget to use the --follow-tags argument to `git push`COMMENT
LOWscripts/bump-versions.sh8# When pushing commits created by this script, don't forget to use the --follow-tags argument to `git push`COMMENT
Redundant / Tautological Comments8 hits · 13 pts
SeverityFileLineSnippetContext
LOWsql-to-dbsp-compiler/build.sh36 # Check if there is a valid checkout of CalciteCOMMENT
LOW…untime_aggtest/orderby_tests/automate_orderby_views.py38 # Assign names to views based on the table name and the value of the counterCOMMENT
LOWpython/tests/runtime/test_spreadsheet.py23 # Read the file ../crates/pipeline-manager/demos/sql/10-spreadsheet.sqlCOMMENT
LOWpython/tests/workloads/test_kafka_avro.py36 # Check if Schema Registry is availableCOMMENT
LOWpython/tests/workloads/test_kafka_avro.py39 # Check if Kafka broker is availableCOMMENT
LOWpython/feldera/testutils_oidc.py290 # Check if token is already cached and still validCOMMENT
LOW…ldera/dbt/include/feldera/macros/adapters/metadata.sql14 {# Check if a pipeline exists #}CODE
LOWpython/dbt-feldera/dbt/adapters/feldera/impl.py116 # Check if any values have decimal partsCOMMENT
TODO Padding8 hits · 12 pts
SeverityFileLineSnippetContext
LOWcrates/dbsp/src/dynamic/vec.rs391 // TODO: implement `swap` as a method of `LeanVec` to reduce code size.COMMENT
LOWcrates/dbsp/src/operator/dynamic/index.rs169 // TODO: implement consumersCOMMENT
LOWcrates/dbsp/src/operator/dynamic/distinct.rs1383 // TODO: implement microstep-compatible versions of integrate_nested, etc.COMMENT
LOWcrates/dbsp/src/operator/dynamic/upsert.rs241 // TODO: implement this check.COMMENT
LOWcrates/adapters/src/integrated/delta_table/test.rs1346/// TODO: implement verification using the delta table API rather thanCOMMENT
LOWcrates/adapters/src/format/json.rs71// TODO: implement support for parsing this format.COMMENT
LOW…line-manager/src/api/endpoints/pipeline_interaction.rs44// TODO: implement chunked and batch modes.COMMENT
LOWpython/feldera/rest/feldera_client.py1056 # TODO: implement this without using /stats when we have a better pipeline status reporting API.COMMENT
AI Response Leakage1 hit · 8 pts
SeverityFileLineSnippetContext
HIGH…compiler/frontend/calciteCompiler/ConvertletTable.java343 // windowed agg. I have added an optimizer ruleCOMMENT
Synthetic Comment Markers1 hit · 8 pts
SeverityFileLineSnippetContext
HIGHcrates/adapters/src/transport/kafka/ft/input.rs510 // Then replay as many steps as requested.COMMENT
AI Structural Patterns7 hits · 6 pts
SeverityFileLineSnippetContext
LOWpython/tests/platform/test_checkpoint_sync.py79CODE
LOWpython/tests/workloads/test_tpch.py31CODE
LOWpython/feldera/runtime_config.py70CODE
LOWpython/feldera/testutils.py417CODE
LOWpython/feldera/pipeline.py1767CODE
LOWpython/feldera/rest/config.py21CODE
LOWpython/felderize/felderize/skills.py141CODE
Self-Referential Comments2 hits · 5 pts
SeverityFileLineSnippetContext
MEDIUMcrates/iceberg/src/test/create_test_table_s3.py264 # Create the DataFrameCOMMENT
MEDIUM…n/tests/runtime_aggtest/orderby_tests/sqlite_runner.py29sqlite_db_path = ":memory:" # Create an in-memory databaseCODE
Example Usage Blocks3 hits · 4 pts
SeverityFileLineSnippetContext
LOW…dbt-feldera/integration_tests/scripts/run-dbt-local.sh6# Usage:COMMENT
LOW…nsole/src/lib/compositions/useReactiveWaiter.svelte.ts263// Example usage:COMMENT
LOWscripts/inotify.sh4# Usage:COMMENT