Incremental engine for long horizon agents 🌟 Star if you like it!
This report presents the forensic synthetic code analysis of cocoindex-io/cocoindex, a Rust project with 10,748 GitHub stars. SynthScan v2.0 examined 223,717 lines of code across 857 source files, recording 2968 pattern matches distributed across 19 syntactic categories. The overall adjusted score of 23.7 places this repository in the Moderate AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 2968 distinct pattern matches across 19 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | python/cocoindex/cli.py | 36 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/cli.py | 38 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/cli.py | 55 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/cli.py | 57 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/cli.py | 96 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/cli.py | 98 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/cli.py | 498 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM | python/cocoindex/cli.py | 500 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM | python/cocoindex/cli.py | 543 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM | python/cocoindex/cli.py | 545 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 75 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 77 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 83 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 85 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1197 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1199 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1206 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1208 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1561 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1563 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 168 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 170 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 197 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 199 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 225 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 227 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 246 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 248 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 334 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 336 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 353 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 355 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 460 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 462 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 595 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 597 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 740 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 742 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 863 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 865 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 969 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 971 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 1291 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 1293 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 1390 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 1392 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1053 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1055 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1062 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1064 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1407 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1409 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 67 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 69 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 100 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 102 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 145 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 147 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 166 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 168 | # --------------------------------------------------------------------------- | COMMENT |
| 880 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/user_app_loader.py | 36 | def _import_as_package_module( | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 120 | def build_relationship_upsert( | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 148 | def build_relationship_delete(rel_type: str, pk_fields: Sequence[str]) -> str: | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 190 | def build_relationship_index_create( | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 205 | def build_relationship_index_drop(name: str) -> str: | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 241 | def build_vector_index_create( | CODE |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 414 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 931 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/surrealdb/_target.py | 387 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/surrealdb/_target.py | 795 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/falkordb/_cypher.py | 98 | def build_relationship_upsert( | CODE |
| LOW | python/cocoindex/connectors/falkordb/_cypher.py | 126 | def build_relationship_delete(rel_type: str, pk_fields: Sequence[str]) -> str: | CODE |
| LOW⚡ | python/cocoindex/connectors/falkordb/_cypher.py | 158 | def build_relationship_index_create(rel_type: str, fields: Sequence[str]) -> str: | CODE |
| LOW⚡ | python/cocoindex/connectors/falkordb/_cypher.py | 166 | def build_relationship_index_drop(rel_type: str, fields: Sequence[str]) -> str: | CODE |
| LOW⚡ | python/cocoindex/connectors/falkordb/_cypher.py | 174 | def build_vector_index_create( | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 375 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 881 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/localfs/_target.py | 90 | def _apply_actions_with_child( | CODE |
| LOW⚡ | python/cocoindex/connectors/doris/_target.py | 493 | def _convert_to_key_column_type(doris_type: str) -> str: | CODE |
| LOW⚡ | python/cocoindex/connectors/doris/_target.py | 561 | def _generate_stream_load_label() -> str: | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 377 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 738 | def _generate_create_table_ddl( | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 991 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 1331 | def build_vector_search_query( | CODE |
| LOW⚡ | python/cocoindex/connectors/zvec/_target.py | 90 | def _validate_collection_name(name: str) -> None: | CODE |
| LOW | python/cocoindex/connectors/zvec/_target.py | 764 | def _apply_collection_actions( | CODE |
| LOW | python/cocoindex/connectors/zvec/_target.py | 975 | def declare_collection_target( | CODE |
| LOW | python/cocoindex/connectors/bigquery/_target.py | 156 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/bigquery/_target.py | 610 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 149 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 510 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 366 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 640 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 393 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 932 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 1048 | async def _ensure_pgvector_extension( | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 1355 | def declare_sql_command_attachment( | CODE |
| LOW | python/cocoindex/connectors/kafka/_target.py | 277 | def declare_kafka_topic_target( | CODE |
| LOW | python/cocoindex/connectors/iggy/_source.py | 289 | async def _resolve_initial_high_watermark(self) -> int: | CODE |
| LOW | python/cocoindex/connectors/iggy/_target.py | 297 | def declare_iggy_topic_target( | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 130 | def _resolve_sparse_vector_def( | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 597 | def declare_collection_target( | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 678 | def _sparse_modifier_from_spec( | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 713 | def _sparse_vector_params_from_def( | CODE |
| LOW | python/cocoindex/connectors/azure_blob/_source.py | 107 | def _metadata_from_properties(props: _BlobProperties) -> file.FileMetadata: | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 284 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 378 | def _count_prunable_old_versions(versions: Sequence[dict[str, Any]]) -> int: | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 460 | def _legacy_fingerprint_for_null_backfill( | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 940 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/_internal/runner.py | 490 | def _warn_subprocess_multi_gpu() -> None: | CODE |
| LOW | python/cocoindex/_internal/memo_fingerprint.py | 55 | def _make_state_deserialize_fn( | CODE |
| LOW | python/cocoindex/_internal/memo_fingerprint.py | 196 | def register_memo_key_function( | CODE |
| LOW | python/cocoindex/_internal/memo_fingerprint.py | 210 | def register_not_memo_keyable(typ: type) -> None: | CODE |
| LOW | python/cocoindex/_internal/memo_fingerprint.py | 232 | def unregister_memo_key_function(typ: type) -> None: | CODE |
| LOW | python/cocoindex/_internal/inspect_api.py | 30 | async def iter_stable_paths_by_name( | CODE |
| LOW | python/cocoindex/_internal/inspect_api.py | 48 | async def _iter_stable_paths_collected( | CODE |
| LOW | python/cocoindex/_internal/inspect_api.py | 54 | def list_stable_paths_info_sync( | CODE |
| LOW | python/cocoindex/_internal/inspect_api.py | 69 | async def get_stable_path_detail_by_name( | CODE |
| LOW | python/cocoindex/_internal/inspect_api.py | 78 | async def query_stable_path_details( | CODE |
| LOW | python/cocoindex/_internal/inspect_api.py | 92 | async def query_stable_path_details_by_name( | CODE |
| 1063 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/cocoindex/connectors/surrealdb/_target.py | 0 | declare a snowflake table target and return a pending tabletarget. | STRING |
| HIGH | python/cocoindex/connectors/bigquery/_target.py | 0 | declare a snowflake table target and return a pending tabletarget. | STRING |
| HIGH | python/cocoindex/connectors/snowflake/_target.py | 0 | declare a snowflake table target and return a pending tabletarget. | STRING |
| HIGH | python/cocoindex/connectors/surrealdb/_target.py | 0 | mount a snowflake table target and return a ready-to-use tabletarget. | STRING |
| HIGH | python/cocoindex/connectors/bigquery/_target.py | 0 | mount a snowflake table target and return a ready-to-use tabletarget. | STRING |
| HIGH | python/cocoindex/connectors/snowflake/_target.py | 0 | mount a snowflake table target and return a ready-to-use tabletarget. | STRING |
| HIGH | python/cocoindex/connectors/doris/_target.py | 0 | handler for row-level target states within a table. | STRING |
| HIGH | python/cocoindex/connectors/bigquery/_target.py | 0 | handler for row-level target states within a table. | STRING |
| HIGH | python/cocoindex/connectors/snowflake/_target.py | 0 | handler for row-level target states within a table. | STRING |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 0 | handler for row-level target states within a table. | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | handler for row-level target states within a table. | STRING |
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 0 | handler for row-level target states within a table. | STRING |
| HIGH | python/cocoindex/connectors/bigquery/_target.py | 0 | convert a record type to a dict of column name -> columndef. | STRING |
| HIGH | python/cocoindex/connectors/snowflake/_target.py | 0 | convert a record type to a dict of column name -> columndef. | STRING |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 0 | convert a record type to a dict of column name -> columndef. | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | convert a record type to a dict of column name -> columndef. | STRING |
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 0 | convert a record type to a dict of column name -> columndef. | STRING |
| HIGH | python/cocoindex/connectors/bigquery/_target.py | 0 | primary-key column signature used for table-level main tracking record. | STRING |
| HIGH | python/cocoindex/connectors/snowflake/_target.py | 0 | primary-key column signature used for table-level main tracking record. | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | primary-key column signature used for table-level main tracking record. | STRING |
| HIGH | python/cocoindex/connectors/bigquery/_target.py | 0 | per-non-pk column tracking record used for incremental alter table operations. | STRING |
| HIGH | python/cocoindex/connectors/snowflake/_target.py | 0 | per-non-pk column tracking record used for incremental alter table operations. | STRING |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 0 | per-non-pk column tracking record used for incremental alter table operations. | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | per-non-pk column tracking record used for incremental alter table operations. | STRING |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 0 | create a tableschema from pre-resolved column definitions. for constructing from a record type, use the async classmetho | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | create a tableschema from pre-resolved column definitions. for constructing from a record type, use the async classmetho | STRING |
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 0 | create a tableschema from pre-resolved column definitions. for constructing from a record type, use the async classmetho | STRING |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 0 | apply row actions (upserts and deletes) to the database. | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | apply row actions (upserts and deletes) to the database. | STRING |
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 0 | apply row actions (upserts and deletes) to the database. | STRING |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 0 | key identifying a table: (database_key, pg_schema_name, table_name). | STRING |
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 0 | key identifying a table: (database_key, pg_schema_name, table_name). | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | key identifying a table: (database_key, pg_schema_name, table_name). | STRING |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 0 | apply table actions (ddl) and return child row handlers. | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | apply table actions (ddl) and return child row handlers. | STRING |
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 0 | apply table actions (ddl) and return child row handlers. | STRING |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 0 | a target for writing rows to a lancedb table. the table is managed as a target state, with the scope used to scope the t | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | a target for writing rows to a lancedb table. the table is managed as a target state, with the scope used to scope the t | STRING |
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 0 | a target for writing rows to a lancedb table. the table is managed as a target state, with the scope used to scope the t | STRING |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 0 | convert a row (dict or object) into dict[str, any] using the schema columns, and apply column encoders for both dict and | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | convert a row (dict or object) into dict[str, any] using the schema columns, and apply column encoders for both dict and | STRING |
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 0 | convert a row (dict or object) into dict[str, any] using the schema columns, and apply column encoders for both dict and | STRING |
| HIGH | docs/src/content/example-posts/text-embedding.md | 0 | select filename, text, embedding <=> $1 as distance from "{pg_schema_name}"."{table_name}" order by distance asc limit $ | STRING |
| HIGH | docs/src/content/example-posts/pdf-embedding.md | 0 | select filename, text, embedding <=> $1 as distance from "{pg_schema_name}"."{table_name}" order by distance asc limit $ | STRING |
| HIGH | examples/text_embedding/main.py | 0 | select filename, text, embedding <=> $1 as distance from "{pg_schema_name}"."{table_name}" order by distance asc limit $ | STRING |
| HIGH | examples/amazon_s3_embedding/main.py | 0 | select filename, text, embedding <=> $1 as distance from "{pg_schema_name}"."{table_name}" order by distance asc limit $ | STRING |
| HIGH | examples/gdrive_text_embedding/main.py | 0 | select filename, text, embedding <=> $1 as distance from "{pg_schema_name}"."{table_name}" order by distance asc limit $ | STRING |
| HIGH | examples/azure_blob_embedding/main.py | 0 | select filename, text, embedding <=> $1 as distance from "{pg_schema_name}"."{table_name}" order by distance asc limit $ | STRING |
| HIGH | examples/pdf_embedding/main.py | 0 | select filename, text, embedding <=> $1 as distance from "{pg_schema_name}"."{table_name}" order by distance asc limit $ | STRING |
| HIGH | examples/oci_object_storage_embedding/main.py | 0 | select filename, text, embedding <=> $1 as distance from "{pg_schema_name}"."{table_name}" order by distance asc limit $ | STRING |
| HIGH | docs/src/content/example-posts/patient-intake-dspy.md | 0 | extract structured patient information from a medical intake form image. | STRING |
| HIGH | examples/patient_intake_extraction_dspy/README.md | 0 | extract structured patient information from a medical intake form image. | STRING |
| HIGH | examples/patient_intake_extraction_dspy/main.py | 0 | extract structured patient information from a medical intake form image. | STRING |
| HIGH | docs/src/content/example-posts/patient-intake-dspy.md | 0 | process a patient intake form pdf and extract structured information. | STRING |
| HIGH | docs/src/content/example-posts/patient-intake-baml.md | 0 | process a patient intake form pdf and extract structured information. | STRING |
| HIGH | examples/patient_intake_extraction_baml/main.py | 0 | process a patient intake form pdf and extract structured information. | STRING |
| HIGH | examples/patient_intake_extraction_dspy/main.py | 0 | process a patient intake form pdf and extract structured information. | STRING |
| HIGH | docs/src/content/example-posts/patient-intake-dspy.md | 0 | main application function that processes patient intake forms. | STRING |
| HIGH | docs/src/content/example-posts/patient-intake-baml.md | 0 | main application function that processes patient intake forms. | STRING |
| HIGH | examples/patient_intake_extraction_baml/main.py | 0 | main application function that processes patient intake forms. | STRING |
| 7 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/cli.py | 401 | """ | COMMENT |
| LOW | python/cocoindex/_internal/live_component.py | 41 | _M_contra = TypeVar("_M_contra", contravariant=True) | COMMENT |
| LOW | python/cocoindex/_internal/live_component.py | 61 | # Task running `process()` would inherit its parent Task's `Context` | COMMENT |
| LOW | python/cocoindex/_internal/live_component.py | 341 | # the nested-mount path — we install a fresh inner controller at the | COMMENT |
| LOW | python/cocoindex/_internal/function.py | 921 | memo_args, memo_kwargs = _apply_memo_key( | COMMENT |
| LOW | python/cocoindex/_internal/function.py | 1641 | # | COMMENT |
| LOW | python/tests/core/test_logic_change_detection.py | 401 | } | COMMENT |
| LOW | …on/tests/core/test_context_tracked_state_validation.py | 421 | env.context_provider.provide(COMP_KEY, StatefulEmbedder("ec", 10)) | COMMENT |
| LOW | rust/py/src/code.rs | 21 | #[pyo3(get)] | COMMENT |
| LOW | rust/py/src/runtime.rs | 161 | }; | COMMENT |
| LOW | rust/py/src/fingerprint.rs | 1 | use crate::prelude::*; | COMMENT |
| LOW | rust/py/src/batching.rs | 1 | //! Python bindings for batching infrastructure. | COMMENT |
| LOW | rust/py/src/batching.rs | 61 | }) | COMMENT |
| LOW | rust/py/src/batching.rs | 101 | /// | COMMENT |
| LOW | rust/py/src/function.rs | 61 | let fp_obj = Py::new(py, PyFingerprint(*fp))?; | COMMENT |
| LOW | rust/py/src/ops.rs | 81 | COMMENT | |
| LOW | rust/py/src/ops.rs | 261 | /// | COMMENT |
| LOW | rust/py/src/ops.rs | 301 | #[pyo3(get)] | COMMENT |
| LOW | rust/py/src/context.rs | 61 | /// resolves asynchronously once the members finish. | COMMENT |
| LOW | rust/py/src/context.rs | 101 | .next_id(key.as_ref().map(|k| &k.0), deadline) | COMMENT |
| LOW | rust/py/src/context.rs | 121 | /// Either way the `StoredValue` cell is returned directly, so the Python | COMMENT |
| LOW | rust/code_ast/src/lib.rs | 1 | //! Shared tree-sitter foundation for CocoIndex code/text operations. | COMMENT |
| LOW | rust/code_ast/src/hazards.rs | 1 | //! Tree-trust hazards: a pre-pass over a parsed AST detecting trees whose top | COMMENT |
| LOW | rust/code_ast/src/source.rs | 21 | /// The parser returned no tree. Rare (cancellation/timeout-class failures); | COMMENT |
| LOW | rust/code_ast/src/source.rs | 41 | /// grammar. A consumer that resolves languages through its own table (e.g. a | COMMENT |
| LOW | rust/code_ast/src/elements/types.rs | 1 | //! Public output types for code-element extraction. | COMMENT |
| LOW | rust/code_ast/src/elements/config.rs | 21 | /// Default normalized [`DeclarationKind`] for this node type, before language refinement | COMMENT |
| LOW | rust/code_ast/src/elements/config.rs | 41 | #[derive(Debug, Clone, Serialize, Deserialize)] | COMMENT |
| LOW | rust/code_ast/src/elements/hooks.rs | 61 | /// Refine the normalized [`DeclarationKind`] for grammars where one AST node type covers | COMMENT |
| LOW | rust/code_ast/src/view/render.rs | 41 | /// A zero-length Frame segment at `pos` whose `summary` renders `text`. | COMMENT |
| LOW | rust/code_ast/src/view/mod.rs | 41 | pub kind: SegmentKind, | COMMENT |
| LOW | rust/code_ast/src/view/frames.rs | 1 | //! Context frames: one-line headers identifying the structures enclosing a span. | COMMENT |
| LOW | rust/core/src/state/db_schema.rs | 21 | /// `UserState*` keyspace but are isolated by a discriminant byte so they | COMMENT |
| LOW | rust/core/src/state/db_schema.rs | 241 | pub processor_fp: Fingerprint, | COMMENT |
| LOW | rust/core/src/state/db_schema.rs | 261 | #[serde(rename = "L", default, skip_serializing_if = "Vec::is_empty")] | COMMENT |
| LOW | rust/core/src/state/db_schema.rs | 321 | #[serde_as] | COMMENT |
| LOW | rust/core/src/state/db_schema.rs | 361 | /// in-flight lifecycle (paired with `pending_process_token == self`). | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 1 | //! Per-component submit lifecycle on the state-store side: the engine | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 21 | //! `clear_stage_marker` are inherent methods on `AppStore` (the per-app | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 41 | //! AppStore::precommit(component_path, | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 81 | use crate::state::target_state_path::TargetStatePath; | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 101 | /// blob's `pending_process_token` field. | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 121 | } | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 141 | /// - `Some(self_path)` — `__target` already held self (crash-recovery | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 161 | /// The owner's `pending_process_token` from its tracking-info blob. | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 181 | pub preempted_owner_updates: BTreeMap<StablePath, Vec<u8>>, | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 341 | /// If true, also prefix-delete all `Live`-kind user-state rows for self. | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 361 | /// | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 381 | /// returned [`PrecommitWritePlan`] and commits — or contributes no | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 541 | self.clear_staged_tracking(component_path, process_token) | COMMENT |
| LOW | rust/core/src/state_store/app_store.rs | 1 | //! Per-app handle within a [`Storage`](super::Storage). | COMMENT |
| LOW | rust/core/src/state_store/app_store.rs | 921 | Ok(()) | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 81 | COMMENT | |
| LOW | rust/core/src/state_store/storage.rs | 121 | COMMENT | |
| LOW | rust/core/src/state_store/storage.rs | 161 | /// from the final commit), the write txn and its coordinator read guard are | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 341 | /// coalesced into a single underlying write txn for throughput. FIFO: | COMMENT |
| LOW | rust/core/src/state_store/txn.rs | 1 | //! LMDB transaction wrappers and the shared transaction/resize coordinator. | COMMENT |
| LOW | rust/core/src/engine/execution.rs | 541 | // | COMMENT |
| LOW | rust/core/src/engine/execution.rs | 621 | struct PreCommitOutput<Prof: EngineProfile> { | COMMENT |
| LOW | rust/core/src/engine/execution.rs | 661 | processor_name: Option<Arc<str>>, | COMMENT |
| 176 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/engine_object.py | 5 | CODE | |
| LOW | python/cocoindex/engine_object.py | 8 | CODE | |
| LOW | python/cocoindex/__init__.py | 6 | CODE | |
| LOW | python/cocoindex/__init__.py | 7 | CODE | |
| LOW | python/cocoindex/__init__.py | 13 | CODE | |
| LOW | python/cocoindex/_version_check.py | 1 | CODE | |
| LOW | python/cocoindex/inspect.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 15 | CODE | |
| LOW | python/cocoindex/connectors/neo4j/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/surrealdb/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/falkordb/_cypher.py | 12 | CODE | |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 20 | CODE | |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 37 | CODE | |
| LOW | python/cocoindex/connectors/falkordb/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/localfs/_source.py | 3 | CODE | |
| LOW | python/cocoindex/connectors/localfs/_target.py | 3 | CODE | |
| LOW | python/cocoindex/connectors/localfs/_common.py | 3 | CODE | |
| LOW | python/cocoindex/connectors/localfs/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/localfs/__init__.py | 5 | CODE | |
| LOW | python/cocoindex/connectors/localfs/__init__.py | 8 | CODE | |
| LOW | python/cocoindex/connectors/amazon_s3/_source.py | 10 | CODE | |
| LOW | python/cocoindex/connectors/amazon_s3/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/doris/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/valkey/_target.py | 3 | CODE | |
| LOW | python/cocoindex/connectors/valkey/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/zvec/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/bigquery/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/snowflake/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/sqlite/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/postgres/_source.py | 7 | CODE | |
| LOW | python/cocoindex/connectors/postgres/__init__.py | 3 | CODE | |
| LOW | python/cocoindex/connectors/postgres/__init__.py | 4 | CODE | |
| LOW | python/cocoindex/connectors/kafka/_source.py | 13 | CODE | |
| LOW | python/cocoindex/connectors/kafka/_target.py | 9 | CODE | |
| LOW | python/cocoindex/connectors/kafka/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/kafka/__init__.py | 3 | CODE | |
| LOW | python/cocoindex/connectors/iggy/_source.py | 9 | CODE | |
| LOW | python/cocoindex/connectors/iggy/_target.py | 9 | CODE | |
| LOW | python/cocoindex/connectors/iggy/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/iggy/__init__.py | 3 | CODE | |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 9 | CODE | |
| LOW | python/cocoindex/connectors/qdrant/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/turbopuffer/_target.py | 13 | CODE | |
| LOW | python/cocoindex/connectors/turbopuffer/__init__.py | 2 | CODE | |
| LOW | …hon/cocoindex/connectors/oci_object_storage/_source.py | 15 | CODE | |
| LOW | …on/cocoindex/connectors/oci_object_storage/__init__.py | 1 | CODE | |
| LOW | …on/cocoindex/connectors/oci_object_storage/__init__.py | 1 | CODE | |
| LOW | …on/cocoindex/connectors/oci_object_storage/__init__.py | 1 | CODE | |
| LOW | …on/cocoindex/connectors/oci_object_storage/__init__.py | 1 | CODE | |
| LOW | …on/cocoindex/connectors/oci_object_storage/__init__.py | 1 | CODE | |
| LOW | …on/cocoindex/connectors/oci_object_storage/__init__.py | 1 | CODE | |
| LOW | python/cocoindex/connectors/azure_blob/_source.py | 3 | CODE | |
| LOW | python/cocoindex/connectors/azure_blob/__init__.py | 1 | CODE | |
| LOW | python/cocoindex/connectors/azure_blob/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/azure_blob/__init__.py | 3 | CODE | |
| LOW | python/cocoindex/connectors/azure_blob/__init__.py | 4 | CODE | |
| LOW | python/cocoindex/connectors/azure_blob/__init__.py | 5 | CODE | |
| LOW | python/cocoindex/connectors/azure_blob/__init__.py | 6 | CODE | |
| LOW | python/cocoindex/connectors/lancedb/__init__.py | 2 | CODE | |
| LOW | python/cocoindex/connectors/google_drive/_source.py | 7 | CODE | |
| 213 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | python/cocoindex/cli.py | 41 | def _setup_logging() -> None: | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 20 | __all__ = [ | CODE |
| LOW⚡ | python/cocoindex/connectors/neo4j/_target.py | 1565 | __all__ = [ | CODE |
| LOW⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1411 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/falkordb/_cypher.py | 17 | __all__ = [ | CODE |
| LOW⚡ | python/cocoindex/connectors/falkordb/_target.py | 1588 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/localfs/_source.py | 393 | __all__ = ["walk_dir", "File", "DirWalker"] | CODE |
| LOW | python/cocoindex/connectors/localfs/_target.py | 500 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/localfs/_common.py | 78 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/amazon_s3/_source.py | 12 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 1387 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/valkey/_target.py | 22 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/cocoindex/connectors/valkey/_target.py | 768 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/zvec/_target.py | 1003 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/bigquery/_target.py | 988 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 893 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 1375 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/postgres/_source.py | 255 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 61 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 1507 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/kafka/_source.py | 512 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/kafka/_target.py | 327 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/iggy/_source.py | 583 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/iggy/_target.py | 367 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 768 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/turbopuffer/_target.py | 582 | __all__ = [ | CODE |
| LOW | …hon/cocoindex/connectors/oci_object_storage/_source.py | 17 | __all__ = [ | CODE |
| LOW | …on/cocoindex/connectors/oci_object_storage/__init__.py | 10 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/azure_blob/_source.py | 5 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/azure_blob/__init__.py | 8 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 1507 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/google_drive/_source.py | 264 | __all__ = [ | CODE |
| LOW | python/cocoindex/_internal/rwlock.py | 9 | __all__ = ["RWLock", "RWLockReadGuard", "RWLockWriteGuard"] | CODE |
| LOW | python/cocoindex/_internal/batching.py | 28 | __all__ = ["RetryWithSmallerBatch"] | CODE |
| LOW | python/cocoindex/_internal/memo_fingerprint.py | 450 | __all__ = [ | CODE |
| LOW | python/cocoindex/_internal/inspect_api.py | 111 | __all__ = [ | CODE |
| LOW⚡ | python/cocoindex/_internal/api.py | 892 | __all__ = [ | CODE |
| LOW | python/cocoindex/_internal/context_keys.py | 160 | def set_core_env(self, core_env: core.Environment) -> None: | CODE |
| LOW | python/cocoindex/_internal/live_component.py | 296 | async def update_full(self) -> None: | CODE |
| LOW | python/cocoindex/_internal/live_component.py | 524 | async def update_all(self) -> None: | CODE |
| LOW | python/cocoindex/_internal/environment.py | 113 | def set_exception_handler(self, handler: ExceptionHandler) -> None: | CODE |
| LOW | python/cocoindex/connectorkits/fingerprint.py | 41 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectorkits/statediff.py | 22 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectorkits/__init__.py | 7 | __all__ = ["SingleWatcherGuard", "default_subpath_name"] | CODE |
| LOW | python/cocoindex/connectorkits/async_adapters.py | 5 | __all__ = ["async_to_sync_iter", "sync_to_async_iter"] | CODE |
| LOW | python/cocoindex/connectorkits/target.py | 5 | __all__ = ["ManagedBy"] | CODE |
| LOW | python/cocoindex/resources/id.py | 20 | __all__ = ["IdGenerator", "UuidGenerator", "generate_id", "generate_uuid"] | CODE |
| LOW | python/cocoindex/resources/chunk.py | 5 | __all__ = ["Chunk", "TextPosition"] | CODE |
| LOW | python/cocoindex/resources/file.py | 5 | __all__ = [ | CODE |
| LOW | python/cocoindex/resources/view.py | 11 | __all__ = ["SourceView", "ViewSegment"] | CODE |
| LOW | python/cocoindex/resources/live_map.py | 37 | __all__ = ["LiveMap"] | CODE |
| LOW | python/cocoindex/resources/rate_limit.py | 13 | __all__ = ["RateLimiter"] | CODE |
| LOW | python/cocoindex/resources/embedder.py | 11 | __all__ = ["Embedder"] | CODE |
| LOW | python/cocoindex/resources/schema.py | 67 | __all__ = [ | CODE |
| LOW | python/cocoindex/ops/code.py | 11 | __all__ = [ | STRING |
| LOW | python/cocoindex/ops/__init__.py | 7 | __all__ = ["code", "litellm", "sentence_transformers", "text"] | CODE |
| LOW | python/cocoindex/ops/litellm.py | 10 | __all__ = [ | CODE |
| LOW | python/cocoindex/ops/text.py | 6 | __all__ = [ | CODE |
| LOW | python/cocoindex/ops/sentence_transformers.py | 9 | __all__ = ["SentenceTransformerEmbedder"] | CODE |
| LOW | python/cocoindex/ops/entity_resolution/llm_resolver.py | 22 | __all__ = ["LlmPairResolver"] | CODE |
| 35 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/user_app_loader.py | 107 | except Exception as e: | CODE |
| LOW | python/cocoindex/cli.py | 82 | except Exception: | CODE |
| LOW | python/cocoindex/cli.py | 163 | except Exception: | CODE |
| LOW | python/cocoindex/cli.py | 178 | except Exception: | CODE |
| LOW | python/cocoindex/cli.py | 288 | except Exception as e: | CODE |
| LOW | python/cocoindex/cli.py | 1112 | except Exception as e: | STRING |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 658 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 671 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 605 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 621 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1099 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1113 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1125 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1139 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1171 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1187 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 227 | except Exception as e: | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 1060 | except Exception as e: | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 1105 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 1115 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 429 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 703 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 102 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/kafka/_source.py | 138 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/kafka/_source.py | 289 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/iggy/_source.py | 136 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 391 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 654 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 512 | except Exception: # pylint: disable=broad-exception-caught | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 531 | except Exception: # pylint: disable=broad-exception-caught | CODE |
| LOW | python/cocoindex/_internal/runner.py | 142 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/runner.py | 253 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/batching.py | 53 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/batching.py | 139 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/batching.py | 174 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/memo_fingerprint.py | 74 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/memo_fingerprint.py | 365 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/target_state.py | 68 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/serde.py | 365 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/serde.py | 399 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/serde.py | 417 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/serde.py | 426 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/setting.py | 48 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/api.py | 588 | except Exception as exc: | CODE |
| LOW | python/cocoindex/_internal/api.py | 612 | except Exception as exc: | CODE |
| LOW | python/cocoindex/_internal/environment.py | 532 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/environment.py | 551 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/deadline.py | 206 | except Exception as error: | CODE |
| LOW | python/cocoindex/_internal/function.py | 735 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/function.py | 1270 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/function.py | 2259 | except Exception: | CODE |
| LOW | python/cocoindex/connectorkits/async_adapters.py | 68 | except Exception as e: # pylint: disable=broad-except | CODE |
| LOW | python/cocoindex/connectorkits/async_adapters.py | 151 | except Exception as e: # pylint: disable=broad-except | CODE |
| MEDIUM | python/cocoindex/connectorkits/async_adapters.py | 62 | def producer() -> None: | CODE |
| MEDIUM | python/cocoindex/connectorkits/async_adapters.py | 145 | def run_async() -> None: | CODE |
| LOW | python/cocoindex/ops/litellm.py | 271 | except Exception as e: | CODE |
| LOW | python/cocoindex/ops/sentence_transformers.py | 49 | except Exception: # pragma: no cover - defensive | CODE |
| LOW | python/cocoindex/ops/sentence_transformers.py | 153 | except Exception as e: | CODE |
| LOW | python/tests/conftest.py | 28 | except Exception: | CODE |
| LOW | python/tests/conftest.py | 75 | except Exception as e: | CODE |
| 20 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/engine_object.py | 17 | CODE | |
| LOW | python/cocoindex/cli.py | 714 | CODE | |
| LOW | python/cocoindex/cli.py | 914 | CODE | |
| LOW | python/cocoindex/cli.py | 1003 | CODE | |
| LOW | python/cocoindex/cli.py | 935 | CODE | |
| LOW | python/cocoindex/cli.py | 1017 | CODE | |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 1068 | CODE | |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 1324 | CODE | |
| LOW | python/cocoindex/connectors/surrealdb/_target.py | 915 | CODE | |
| LOW | python/cocoindex/connectors/surrealdb/_target.py | 1184 | CODE | |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1019 | CODE | |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1351 | CODE | |
| LOW | python/cocoindex/connectors/localfs/_source.py | 105 | CODE | |
| LOW | python/cocoindex/connectors/localfs/_source.py | 218 | CODE | |
| LOW | python/cocoindex/connectors/doris/_target.py | 677 | CODE | |
| LOW | python/cocoindex/connectors/doris/_target.py | 1034 | CODE | |
| LOW | python/cocoindex/connectors/valkey/_target.py | 388 | CODE | |
| LOW | python/cocoindex/connectors/valkey/_target.py | 441 | CODE | |
| LOW | python/cocoindex/connectors/valkey/_target.py | 482 | CODE | |
| LOW | python/cocoindex/connectors/zvec/_target.py | 538 | CODE | |
| LOW | python/cocoindex/connectors/zvec/_target.py | 894 | CODE | |
| LOW | python/cocoindex/connectors/bigquery/_target.py | 754 | CODE | |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 393 | CODE | |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 649 | CODE | |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 862 | CODE | |
| LOW | python/cocoindex/connectors/postgres/_target.py | 518 | CODE | |
| LOW | python/cocoindex/connectors/kafka/_source.py | 276 | CODE | |
| LOW | python/cocoindex/connectors/iggy/_source.py | 329 | CODE | |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 179 | CODE | |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 368 | CODE | |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 748 | CODE | |
| LOW | python/cocoindex/_internal/runner.py | 216 | CODE | |
| LOW | python/cocoindex/_internal/serde.py | 339 | CODE | |
| LOW | python/cocoindex/_internal/serde.py | 386 | CODE | |
| LOW | python/cocoindex/_internal/environment.py | 342 | CODE | |
| LOW | python/cocoindex/_internal/datatype.py | 205 | CODE | |
| LOW | python/cocoindex/_internal/datatype.py | 284 | CODE | |
| LOW | python/cocoindex/_internal/datatype.py | 129 | CODE | |
| LOW | python/cocoindex/_internal/deadline.py | 134 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 524 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 624 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 729 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 764 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 1262 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 1329 | CODE | |
| LOW | python/cocoindex/connectorkits/async_adapters.py | 23 | CODE | |
| LOW | python/cocoindex/connectorkits/async_adapters.py | 99 | CODE | |
| LOW | python/tests/conftest.py | 51 | CODE | |
| LOW | python/tests/conftest.py | 70 | CODE | |
| LOW | python/tests/connectors/test_valkey_target.py | 78 | CODE | |
| LOW | python/tests/core/test_logic_change_detection.py | 45 | CODE | |
| LOW | python/tests/cli/test_cli.py | 71 | CODE | |
| LOW | python/tests/cli/test_cli.py | 330 | CODE | |
| LOW | python/tests/common/target_states.py | 209 | CODE | |
| LOW | python/tests/common/target_states.py | 396 | CODE | |
| LOW | examples/sec_edgar_analytics/main.py | 105 | CODE | |
| LOW | examples/entire_session_search/main.py | 117 | CODE | |
| LOW | examples/entire_session_search/main.py | 180 | CODE | |
| LOW | examples/meeting_notes_graph_falkordb/main.py | 301 | CODE | |
| LOW | …amples/conversation_to_knowledge/conv_knowledge/app.py | 178 | CODE | |
| 4 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 1184 | Create a TableTarget for writing rows to a SQLite table (regular or virtual). Declares the table target state | STRING |
| HIGH | python/cocoindex/_internal/api.py | 797 | Declare a persistent state for the current component. On the first run, the returned handle's `.value` is `ini | STRING |
| HIGH | python/cocoindex/_internal/component_ctx.py | 298 | Create a component subpath for use with mount()/use_mount() or as a context manager. Args: *key_parts: | STRING |
| HIGH | python/cocoindex/_internal/component_ctx.py | 373 | Retrieve a value from the context. This replaces the old `scope.use(key)` API. Args: key: The Con | STRING |
| HIGH | python/cocoindex/_internal/component_ctx.py | 485 | Get the next unique ID for the given key. This is an internal function that generates unique IDs within the cu | STRING |
| HIGH | python/cocoindex/connectorkits/statediff.py | 199 | Compute a diff for a composite state and group sub-state transitions. Args: t: A `StateTransition` whose de | STRING |
| HIGH | python/cocoindex/connectorkits/async_adapters.py | 28 | Adapt a synchronous iterator function to an asynchronous iterator. This function takes a callable that returns | STRING |
| HIGH | python/cocoindex/connectorkits/async_adapters.py | 104 | Adapt an asynchronous iterator function to a synchronous iterator. This function takes a callable that returns | STRING |
| HIGH | python/cocoindex/ops/code.py | 31 | Source text plus a lazily-parsed, shared AST. The universal input for APIs that may need a parse: pass one handle t | STRING |
| HIGH | python/cocoindex/ops/text.py | 21 | Detect programming language from a filename. Args: filename: The filename to detect language from (e.g., "m | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/tests/core/test_component_memo.py | 359 | # Step 1: Load with memo=True and run. | COMMENT |
| LOW | python/tests/core/test_component_memo.py | 370 | # Step 2: Load without memo=True and run. | COMMENT |
| LOW | python/tests/core/test_component_memo.py | 381 | # Step 3: Load with memo=True again and run. | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 690 | // Step 1: hold a guarded read transaction open. | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 700 | // Step 2: concurrent write that will trigger MapFull + resize. | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 723 | // Step 3: wait until the resize path holds (or waits for) the coordinator | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 742 | // Step 4: release the read transaction (txn drops before its guard). | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 745 | // Step 5: write completes, map grows, data is readable. | COMMENT |
| LOW | examples/rust/conversation_to_knowledge/src/pipeline.rs | 29 | /// Step 1: identify speakers + session metadata. | COMMENT |
| LOW | examples/rust/conversation_to_knowledge/src/pipeline.rs | 59 | /// Step 2: extract thematic statements + the entities they involve. | COMMENT |
| LOW⚡ | examples/rust/conversation_to_knowledge/src/pipeline.rs | 116 | // Step 1: format with no known names, extract metadata + speaker map. | COMMENT |
| LOW⚡ | examples/rust/conversation_to_knowledge/src/pipeline.rs | 120 | // Step 2: format with real names, extract statements. | COMMENT |
| LOW | examples/conversation_to_knowledge/spec.md | 58 | #### Step 1: Extract metadata and identify speakers | COMMENT |
| LOW | examples/conversation_to_knowledge/spec.md | 69 | #### Step 2: Extract statements and involved entities | COMMENT |
| LOW | examples/conversation_to_knowledge/design.md | 289 | # Step 1: reformat with empty map (no names known yet), then extract metadata | COMMENT |
| LOW | examples/conversation_to_knowledge/design.md | 293 | # Step 2: reformat with real names, then extract statements | COMMENT |
| LOW⚡ | …amples/conversation_to_knowledge/conv_knowledge/app.py | 129 | # Step 1: format with empty map (no names known yet), then extract metadata | COMMENT |
| LOW⚡ | …amples/conversation_to_knowledge/conv_knowledge/app.py | 133 | # Step 2: format with real names, then extract statements | COMMENT |
| LOW⚡ | …es/conversation_to_knowledge/conv_knowledge/extract.py | 50 | # Step 1: Extract metadata + identify speakers | COMMENT |
| LOW⚡ | …es/conversation_to_knowledge/conv_knowledge/extract.py | 111 | # Step 2: Extract statements + involved entities | COMMENT |
| LOW | dev/agent-skills/target-connector/attachments.md | 41 | ### Step 1: Define Attachment Types | COMMENT |
| LOW | dev/agent-skills/target-connector/attachments.md | 55 | ### Step 2: Implement Attachment Handler | COMMENT |
| LOW | dev/agent-skills/target-connector/attachments.md | 79 | ### Step 3: Add `attachment()` to Parent Handler | COMMENT |
| LOW | dev/agent-skills/target-connector/attachments.md | 93 | ### Step 4: Expose User-Facing API | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/tests/core/test_component_memo.py | 359 | # Step 1: Load with memo=True and run. | COMMENT |
| LOW | python/tests/core/test_component_memo.py | 370 | # Step 2: Load without memo=True and run. | COMMENT |
| LOW | python/tests/core/test_component_memo.py | 381 | # Step 3: Load with memo=True again and run. | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 690 | // Step 1: hold a guarded read transaction open. | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 700 | // Step 2: concurrent write that will trigger MapFull + resize. | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 723 | // Step 3: wait until the resize path holds (or waits for) the coordinator | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 742 | // Step 4: release the read transaction (txn drops before its guard). | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 745 | // Step 5: write completes, map grows, data is readable. | COMMENT |
| LOW | examples/rust/conversation_to_knowledge/src/pipeline.rs | 29 | /// Step 1: identify speakers + session metadata. | COMMENT |
| LOW | examples/rust/conversation_to_knowledge/src/pipeline.rs | 59 | /// Step 2: extract thematic statements + the entities they involve. | COMMENT |
| LOW⚡ | examples/rust/conversation_to_knowledge/src/pipeline.rs | 116 | // Step 1: format with no known names, extract metadata + speaker map. | COMMENT |
| LOW⚡ | examples/rust/conversation_to_knowledge/src/pipeline.rs | 120 | // Step 2: format with real names, extract statements. | COMMENT |
| LOW⚡ | …amples/conversation_to_knowledge/conv_knowledge/app.py | 129 | # Step 1: format with empty map (no names known yet), then extract metadata | COMMENT |
| LOW⚡ | …amples/conversation_to_knowledge/conv_knowledge/app.py | 133 | # Step 2: format with real names, then extract statements | COMMENT |
| LOW⚡ | …es/conversation_to_knowledge/conv_knowledge/extract.py | 50 | # Step 1: Extract metadata + identify speakers | COMMENT |
| LOW⚡ | …es/conversation_to_knowledge/conv_knowledge/extract.py | 111 | # Step 2: Extract statements + involved entities | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …/content/example-posts/multi-codebase-summarization.md | 55 | export GEMINI_API_KEY="your-api-key" | CODE |
| HIGH | …rc/content/example-posts/hackernews-trending-topics.md | 342 | export GEMINI_API_KEY="your-api-key" | CODE |
| HIGH | examples/rust/multi_codebase_summarization/src/main.rs | 23 | //! export LLM_API_KEY="your-api-key" | COMMENT |
| HIGH | skills/cocoindex/references/setup_database.md | 142 | api_key="your-api-key", | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/cli.py | 1094 | # Check if directory exists and has files | STRING |
| LOW | python/cocoindex/connectors/localfs/_target.py | 76 | # Write file | COMMENT |
| LOW | python/cocoindex/connectors/localfs/_target.py | 156 | # Check if update needed | COMMENT |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 763 | # Check if vector columns are used but sqlite-vec is not loaded | COMMENT |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 884 | # Check if this is a virtual table (for special handling) | COMMENT |
| LOW | python/cocoindex/connectors/kafka/_source.py | 302 | # Check if already caught up (e.g. empty topic, or fully consumed) | COMMENT |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 1062 | # Check if table exists | COMMENT |
| LOW | python/cocoindex/_internal/function.py | 810 | # Check if cached result is still valid | COMMENT |
| LOW | python/cocoindex/_internal/function.py | 1364 | # Check if cached result is still valid | COMMENT |
| LOW | dev/run_maturin_develop.sh | 18 | # Check if running with free-threaded Python (Python 3.13+ has _is_gil_enabled) | COMMENT |
| LOW | dev/generate_cli_docs.py | 90 | # Check if this is a new option line (starts with exactly 2 spaces then -) | COMMENT |
| LOW | dev/generate_cli_docs.py | 154 | # Check if this is a command line (starts with 2 spaces + command name) | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | python/cocoindex/connectors/doris/_target.py | 577 | # Create a session bound to the current event loop. _apply_actions may run | COMMENT |
| MEDIUM | python/cocoindex/connectors/lancedb/_target.py | 1078 | # Create an empty batch with the schema | COMMENT |
| MEDIUM | python/cocoindex/_internal/component_ctx.py | 273 | # Create a new ComponentContext with extended path | COMMENT |
| MEDIUM | python/tests/connectors/test_postgres_target.py | 818 | # Create a view that depends on column "extra" so DROP COLUMN fails. | COMMENT |
| MEDIUM | python/tests/connectors/test_sqlite_target.py | 1182 | # Create a new connection without loading vec extension | COMMENT |
| MEDIUM | python/tests/cli/app_not_bound.py | 36 | # Create the app but DON'T bind it to a simple module-level name. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 1138 | # Existing rows are backfilled with null, so additive schema | COMMENT |
| HIGH | python/tests/ops/test_text.py | 495 | " this.users.push(user);\n" | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/connectors/iggy/_source.py | 498 | CODE | |
| LOW | python/cocoindex/connectors/iggy/_source.py | 538 | CODE | |
| LOW | python/cocoindex/connectors/iggy/_source.py | 255 | CODE | |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 1284 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 1814 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 1971 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 1990 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 2102 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 2127 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/_internal/memo_fingerprint.py | 264 | # For others, don't try to sort and just return a placeholder. | COMMENT |
| MEDIUM | docs/package-lock.json | 6659 | "resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.3.tgz", | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | rust/sdk/cocoindex/tests/ops_api.rs | 269 | r#"{"matched": "Acme Corp", "canonical": "matched"}"# | CODE |
| LOW | rust/sdk/cocoindex/tests/ops_api.rs | 292 | .resolve_pair("ACME", &["Acme Corp".to_string()]) | CODE |
| LOW | rust/sdk/cocoindex/tests/ops_api.rs | 295 | assert_eq!(decision.matched.as_deref(), Some("Acme Corp")); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | examples/sec_edgar_analytics/docker-compose.yml | 4 | # Usage: | COMMENT |
| LOW | dev/agent-skills/cocoindex-diagrams/scripts/preview.sh | 6 | # Usage: | COMMENT |