Incremental engine for long horizon agents 🌟 Star if you like it!
This report summarizes scanner evidence for cocoindex-io/cocoindex, a Rust project with 11,667 GitHub stars. SynthScan examined 248,517 lines of code across 906 source files, recording 3391 pattern matches distributed across 20 syntactic categories. The legacy adjusted pattern signal is 24.5 (Elevated pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 1756 finding(s).
Are imports declared and package/API names verified? 311 finding(s).
Are wrappers, guards, and repeated structures necessary? 2670 finding(s).
Which changes need focused human review? 3391 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 3391 distinct pattern matches across 20 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. 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 configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | python/cocoindex/cli.py | 38 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/cli.py | 40 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/cli.py | 57 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/cli.py | 59 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/cli.py | 98 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/cli.py | 100 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/cli.py | 512 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM | python/cocoindex/cli.py | 514 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM | python/cocoindex/cli.py | 557 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM | python/cocoindex/cli.py | 559 | # --------------------------------------------------------------------------- | STRING |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 78 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 80 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 86 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 88 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1208 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1210 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1217 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1219 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1572 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/neo4j/_target.py | 1574 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 171 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 173 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 200 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 202 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 228 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 230 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 249 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 251 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 337 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 339 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 356 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 358 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 463 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 465 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 598 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 600 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 743 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 745 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 868 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 870 | # --------------------------------------------------------------------------- | 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 | 1302 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 1304 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 1401 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/neo4j/_target.py | 1403 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1221 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1223 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1230 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1232 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1595 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1597 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 73 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 75 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 99 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 101 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 163 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 165 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 198 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/cocoindex/connectors/surrealdb/_target.py | 200 | # --------------------------------------------------------------------------- | COMMENT |
| 957 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/cli.py | 857 | async def _show_target_states_from_app( | STRING |
| LOW | python/cocoindex/cli.py | 868 | async def _show_target_states_from_database( | STRING |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 135 | def build_relationship_upsert( | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 163 | def build_relationship_delete(rel_type: str, pk_fields: Sequence[str]) -> str: | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 178 | def build_relationship_delete_all(rel_type: str) -> str: | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 214 | def build_relationship_index_create( | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 229 | def build_relationship_index_drop(name: str) -> str: | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 265 | def build_vector_index_create( | CODE |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 417 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 942 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/surrealdb/_target.py | 462 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/surrealdb/_target.py | 959 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/falkordb/_cypher.py | 109 | def build_relationship_upsert( | CODE |
| LOW | python/cocoindex/connectors/falkordb/_cypher.py | 137 | def build_relationship_delete(rel_type: str, pk_fields: Sequence[str]) -> str: | CODE |
| LOW | python/cocoindex/connectors/falkordb/_cypher.py | 153 | def build_relationship_delete_all(rel_type: str) -> str: | CODE |
| LOW⚡ | python/cocoindex/connectors/falkordb/_cypher.py | 178 | def build_relationship_index_create(rel_type: str, fields: Sequence[str]) -> str: | CODE |
| LOW⚡ | python/cocoindex/connectors/falkordb/_cypher.py | 186 | def build_relationship_index_drop(rel_type: str, fields: Sequence[str]) -> str: | CODE |
| LOW⚡ | python/cocoindex/connectors/falkordb/_cypher.py | 194 | def build_vector_index_create( | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 377 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 891 | 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 | 1034 | def _is_benign_column_ddl_error(e: Exception, *, expect_exists: bool) -> bool: | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 1382 | def build_vector_search_query( | CODE |
| LOW⚡ | python/cocoindex/connectors/zvec/_target.py | 91 | def _validate_collection_name(name: str) -> None: | CODE |
| LOW | python/cocoindex/connectors/zvec/_target.py | 763 | def _apply_collection_actions( | CODE |
| LOW | python/cocoindex/connectors/zvec/_target.py | 969 | def declare_collection_target( | CODE |
| LOW | python/cocoindex/connectors/bigquery/_target.py | 157 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/bigquery/_target.py | 611 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 150 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 511 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 367 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 643 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 395 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 936 | async def _execute_values_upsert_chunk(self, chunk: list[_RowValue]) -> None: | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 952 | async def _execute_unnest_upsert_chunk( | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 1117 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 1236 | async def _ensure_pgvector_extension( | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 1545 | def declare_sql_command_attachment( | CODE |
| LOW | python/cocoindex/connectors/kafka/_target.py | 274 | 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 | 294 | def declare_iggy_topic_target( | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 131 | def _resolve_sparse_vector_def( | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 596 | def declare_collection_target( | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 677 | def _sparse_modifier_from_spec( | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 712 | 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 | 286 | async def _columns_from_record_type( | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 380 | def _count_prunable_old_versions(versions: Sequence[dict[str, Any]]) -> int: | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 464 | def _legacy_fingerprint_for_null_backfill( | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 951 | def _table_composite_tracking_record_from_spec( | CODE |
| LOW | python/cocoindex/_internal/runner.py | 401 | 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 | 211 | def register_not_memo_keyable(typ: type) -> None: | CODE |
| 1278 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/doris/_target.py | 0 | apply table actions (ddl) and fulfill the child row handlers. | STRING |
| HIGH | python/cocoindex/connectors/bigquery/_target.py | 0 | apply table actions (ddl) and fulfill the child row handlers. | STRING |
| HIGH | python/cocoindex/connectors/snowflake/_target.py | 0 | apply table actions (ddl) and fulfill the child row handlers. | STRING |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 0 | apply table actions (ddl) and fulfill the child row handlers. | STRING |
| HIGH | python/cocoindex/connectors/postgres/_target.py | 0 | apply table actions (ddl) and fulfill the child row handlers. | STRING |
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 0 | apply table actions (ddl) and fulfill the child row handlers. | 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 | 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 |
| 19 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/cli.py | 421 | # localfs.declare_dir_target, | 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/ops/litellm.py | 381 | # out a 30s backoff would otherwise hold a slot it isn't using. | COMMENT |
| LOW | python/cocoindex/ops/litellm.py | 441 | except Exception as e: | 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/target_state.rs | 41 | /// sinks constructed from the same callback share one batching identity (the | COMMENT |
| LOW | rust/py/src/memo_fingerprint.rs | 281 | Ok(false) | 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/inspect/db_inspect.rs | 101 | /// `StableKey`s via the inverted owner index + the owner's tracking info, | 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 | 161 | StablePath(StablePath, StablePathEntryKey), | COMMENT |
| LOW | rust/core/src/state/db_schema.rs | 281 | /// isn't part of the memo key. See `TargetProviderDeps`. | COMMENT |
| LOW | rust/core/src/state/db_schema.rs | 301 | COMMENT | |
| LOW | rust/core/src/state/db_schema.rs | 361 | } | COMMENT |
| LOW | rust/core/src/state/db_schema.rs | 401 | /// | 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 | 321 | // --------------------------------------------------------------------------- | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 341 | /// target `StateKind::Regular` — they carry the per-build `coco.use_state` | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 361 | /// deltas + tombstones — see [`reconcile_child_existence`]. | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 381 | /// Phase 2 driver. Opens a batched precommit WTxn, runs `callback` | COMMENT |
| LOW | rust/core/src/state_store/submit_session.rs | 581 | /// * declared-not-present → write `__cex` row, recurse into Directory. | 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/storage.rs | 81 | DEFAULT_MAP_SIZE | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 121 | env: Arc<EnvSlot>, | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 161 | } | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 181 | /// thread from start to finish — see [`Runner::run`]. | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 441 | /// `Box::pin(async move { … })`). Multiple concurrent callers' bodies are | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 461 | /// return value (or a shared slot each run overwrites), never by | COMMENT |
| 204 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 | 39 | 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 | |
| LOW | python/cocoindex/connectors/google_drive/__init__.py | 2 | CODE | |
| 242 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/cocoindex/connectors/localfs/_source.py | 200 | except TypeError: | CODE |
| HIGH | python/cocoindex/connectors/localfs/_source.py | 204 | except TypeError: | CODE |
| HIGH | python/cocoindex/connectors/doris/_target.py | 203 | except ImportError: | CODE |
| HIGH | python/cocoindex/connectors/doris/_target.py | 213 | except ImportError: | CODE |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 825 | except sqlite3.OperationalError: | CODE |
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 859 | except sqlite3.OperationalError: | CODE |
| HIGH | python/cocoindex/connectors/qdrant/_target.py | 393 | except Exception: | CODE |
| HIGH | python/cocoindex/connectors/turbopuffer/_target.py | 403 | except NotFoundError: | CODE |
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 1066 | except (OSError, ValueError): | CODE |
| HIGH | python/cocoindex/_internal/runner.py | 141 | except Exception: | CODE |
| HIGH | python/cocoindex/_internal/serde.py | 98 | except ImportError: | CODE |
| HIGH | python/cocoindex/_internal/serde.py | 127 | except ImportError: | CODE |
| HIGH | python/cocoindex/_internal/api.py | 711 | except RuntimeError: | CODE |
| HIGH | python/cocoindex/_internal/context_keys.py | 57 | except RuntimeError: | CODE |
| HIGH | python/cocoindex/_internal/environment.py | 580 | except Exception: | CODE |
| HIGH | python/cocoindex/_internal/environment.py | 599 | except Exception: | CODE |
| HIGH | python/cocoindex/_internal/environment.py | 408 | except StopAsyncIteration: | CODE |
| HIGH | python/cocoindex/_internal/environment.py | 422 | except StopIteration: | CODE |
| HIGH | python/cocoindex/connectorkits/async_adapters.py | 136 | except RuntimeError: | CODE |
| HIGH | python/cocoindex/connectorkits/async_adapters.py | 95 | except _queue.Empty: | CODE |
| HIGH | python/cocoindex/connectorkits/async_adapters.py | 179 | except _queue.Empty: | CODE |
| HIGH | python/cocoindex/ops/sentence_transformers.py | 49 | except Exception: # pragma: no cover - defensive | CODE |
| HIGH | python/tests/connectors/test_qdrant_target.py | 480 | except Exception: | CODE |
| HIGH | python/tests/connectors/test_turbopuffer_target.py | 272 | except Exception: | CODE |
| HIGH | python/tests/connectors/test_kafka_source.py | 218 | except asyncio.CancelledError: | CODE |
| HIGH | python/tests/connectors/test_kafka_source.py | 514 | except asyncio.CancelledError: | CODE |
| HIGH | python/tests/connectors/test_localfs_live.py | 128 | except asyncio.CancelledError: | CODE |
| HIGH | python/tests/connectors/test_localfs_live.py | 174 | except asyncio.CancelledError: | CODE |
| HIGH | python/tests/connectors/test_localfs_live.py | 211 | except asyncio.CancelledError: | CODE |
| HIGH | python/tests/connectors/test_localfs_live.py | 238 | except asyncio.CancelledError: | CODE |
| HIGH | python/tests/connectors/test_valkey_target.py | 121 | except Exception: | CODE |
| HIGH | python/tests/connectors/test_surrealdb_target.py | 182 | except Exception: | CODE |
| HIGH | python/tests/connectors/test_surrealdb_target.py | 186 | except Exception: | CODE |
| HIGH | python/tests/connectors/test_surrealdb_target.py | 190 | except Exception: | CODE |
| HIGH | python/tests/connectors/test_falkordb_target.py | 577 | except Exception: # noqa: BLE001 | CODE |
| HIGH | python/tests/core/test_auto_refresh.py | 114 | except Exception: | CODE |
| HIGH | python/tests/core/test_auto_refresh.py | 175 | except Exception: | CODE |
| HIGH | python/tests/core/test_concurrency_control.py | 679 | except Exception: | CODE |
| HIGH | python/tests/core/test_live_component.py | 1450 | except Exception: | CODE |
| HIGH | python/tests/core/test_cancellation.py | 70 | except Exception: | CODE |
| HIGH | python/tests/core/test_cancellation.py | 115 | except Exception: | CODE |
| HIGH | python/tests/core/test_app_drop.py | 280 | except Exception: | CODE |
| HIGH | python/tests/resources/test_live_map.py | 490 | except asyncio.CancelledError: | CODE |
| HIGH | python/tests/resources/test_live_map.py | 353 | except asyncio.CancelledError: | CODE |
| HIGH | python/tests/resources/test_live_map.py | 310 | except asyncio.CancelledError: | CODE |
| HIGH | python/tests/internal/test_memo_fingerprint.py | 188 | except TypeError: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | python/cocoindex/cli.py | 43 | def _setup_logging() -> None: | CODE |
| LOW | python/cocoindex/connectors/neo4j/_cypher.py | 20 | __all__ = [ | CODE |
| LOW⚡ | python/cocoindex/connectors/neo4j/_target.py | 1576 | __all__ = [ | CODE |
| LOW⚡ | python/cocoindex/connectors/surrealdb/_target.py | 1599 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/falkordb/_cypher.py | 17 | __all__ = [ | CODE |
| LOW⚡ | python/cocoindex/connectors/falkordb/_target.py | 1600 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/localfs/_source.py | 403 | __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 | 1438 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/valkey/_target.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/cocoindex/connectors/valkey/_target.py | 770 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/zvec/_target.py | 997 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/bigquery/_target.py | 993 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 898 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 1397 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/postgres/_source.py | 255 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 63 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/cocoindex/connectors/postgres/_target.py | 1697 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/kafka/_source.py | 512 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/kafka/_target.py | 324 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/iggy/_source.py | 583 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/iggy/_target.py | 364 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 767 | __all__ = [ | CODE |
| LOW | python/cocoindex/connectors/turbopuffer/_target.py | 581 | __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 | 1528 | __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 | 470 | __all__ = [ | CODE |
| LOW | python/cocoindex/_internal/inspect_api.py | 158 | __all__ = [ | CODE |
| LOW⚡ | python/cocoindex/_internal/api.py | 897 | __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 | 292 | async def update_full(self) -> None: | CODE |
| LOW | python/cocoindex/_internal/live_component.py | 519 | async def update_all(self) -> None: | CODE |
| LOW | python/cocoindex/_internal/environment.py | 140 | 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 | 38 | __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 |
| 39 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 | 84 | except Exception: | CODE |
| LOW | python/cocoindex/cli.py | 177 | except Exception: | CODE |
| LOW | python/cocoindex/cli.py | 192 | except Exception: | CODE |
| LOW | python/cocoindex/cli.py | 302 | except Exception as e: | CODE |
| LOW | python/cocoindex/cli.py | 1247 | except Exception as e: | STRING |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 661 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 674 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 607 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 623 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1098 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1112 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1124 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1138 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1183 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1199 | 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 | 1073 | except Exception as e: | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 1090 | except Exception as e: | CODE |
| LOW | python/cocoindex/connectors/doris/_target.py | 1127 | except Exception as e: | CODE |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 430 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 708 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 103 | 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 | 393 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 653 | except Exception: | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 516 | except Exception: # pylint: disable=broad-exception-caught | CODE |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 535 | except Exception: # pylint: disable=broad-exception-caught | CODE |
| LOW | python/cocoindex/_internal/runner.py | 141 | 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 | 380 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/target_state.py | 82 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/serde.py | 367 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/serde.py | 401 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/serde.py | 419 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/serde.py | 428 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/target_state_codec.py | 239 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/target_state_codec.py | 285 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/setting.py | 52 | except Exception as e: | CODE |
| LOW | python/cocoindex/_internal/api.py | 593 | except Exception as exc: | CODE |
| LOW | python/cocoindex/_internal/api.py | 617 | except Exception as exc: | CODE |
| LOW | python/cocoindex/_internal/environment.py | 580 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/environment.py | 599 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/deadline.py | 207 | except Exception as error: | CODE |
| LOW | python/cocoindex/_internal/function.py | 745 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/function.py | 1324 | except Exception: | CODE |
| LOW | python/cocoindex/_internal/function.py | 2289 | except Exception: | CODE |
| LOW | python/cocoindex/connectorkits/async_adapters.py | 69 | except Exception as e: # pylint: disable=broad-except | CODE |
| LOW | python/cocoindex/connectorkits/async_adapters.py | 153 | except Exception as e: # pylint: disable=broad-except | CODE |
| MEDIUM | python/cocoindex/connectorkits/async_adapters.py | 63 | def producer() -> None: | CODE |
| MEDIUM | python/cocoindex/connectorkits/async_adapters.py | 147 | def run_async() -> None: | CODE |
| LOW | python/cocoindex/ops/litellm.py | 441 | 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 |
| 23 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/engine_object.py | 17 | CODE | |
| LOW | python/cocoindex/cli.py | 764 | CODE | |
| LOW | python/cocoindex/cli.py | 1049 | CODE | |
| LOW | python/cocoindex/cli.py | 1138 | CODE | |
| LOW | python/cocoindex/cli.py | 1070 | CODE | |
| LOW | python/cocoindex/cli.py | 1152 | CODE | |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 1073 | CODE | |
| LOW | python/cocoindex/connectors/neo4j/_target.py | 1335 | CODE | |
| LOW | python/cocoindex/connectors/surrealdb/_target.py | 610 | CODE | |
| LOW | python/cocoindex/connectors/surrealdb/_target.py | 1083 | CODE | |
| LOW | python/cocoindex/connectors/surrealdb/_target.py | 1372 | CODE | |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1022 | CODE | |
| LOW | python/cocoindex/connectors/falkordb/_target.py | 1363 | CODE | |
| LOW | python/cocoindex/connectors/localfs/_source.py | 105 | CODE | |
| LOW | python/cocoindex/connectors/localfs/_source.py | 228 | CODE | |
| LOW | python/cocoindex/connectors/doris/_target.py | 677 | CODE | |
| LOW | python/cocoindex/connectors/doris/_target.py | 1047 | CODE | |
| LOW | python/cocoindex/connectors/doris/_target.py | 1101 | CODE | |
| LOW | python/cocoindex/connectors/valkey/_target.py | 391 | CODE | |
| LOW | python/cocoindex/connectors/valkey/_target.py | 440 | CODE | |
| LOW | python/cocoindex/connectors/valkey/_target.py | 481 | CODE | |
| LOW | python/cocoindex/connectors/zvec/_target.py | 539 | CODE | |
| LOW | python/cocoindex/connectors/zvec/_target.py | 888 | CODE | |
| LOW | python/cocoindex/connectors/bigquery/_target.py | 755 | CODE | |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 394 | CODE | |
| LOW | python/cocoindex/connectors/snowflake/_target.py | 650 | CODE | |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 794 | CODE | |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 877 | CODE | |
| LOW | python/cocoindex/connectors/postgres/_target.py | 753 | CODE | |
| LOW | python/cocoindex/connectors/postgres/_target.py | 520 | CODE | |
| LOW | python/cocoindex/connectors/postgres/_target.py | 1166 | 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 | 180 | CODE | |
| LOW | python/cocoindex/connectors/qdrant/_target.py | 371 | CODE | |
| LOW | python/cocoindex/connectors/lancedb/_target.py | 758 | CODE | |
| LOW | python/cocoindex/_internal/serde.py | 341 | CODE | |
| LOW | python/cocoindex/_internal/serde.py | 388 | CODE | |
| LOW | python/cocoindex/_internal/target_state_codec.py | 198 | CODE | |
| LOW | python/cocoindex/_internal/environment.py | 380 | 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 | 534 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 634 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 739 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 794 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 950 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 1316 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 1393 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 1760 | CODE | |
| LOW | python/cocoindex/connectorkits/async_adapters.py | 24 | CODE | |
| LOW | python/cocoindex/connectorkits/async_adapters.py | 101 | CODE | |
| LOW | python/tests/conftest.py | 51 | CODE | |
| LOW | python/tests/conftest.py | 70 | CODE | |
| LOW | python/tests/connectors/test_valkey_target.py | 91 | CODE | |
| LOW | python/tests/core/test_target_state_values.py | 106 | CODE | |
| LOW | python/tests/core/test_target_state_codec.py | 50 | CODE | |
| LOW | python/tests/cli/test_cli.py | 71 | CODE | |
| 13 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/cocoindex/connectors/sqlite/_target.py | 1206 | 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 | 802 | 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 | 321 | 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 | 396 | 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 | 508 | 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 | 29 | Adapt a synchronous iterator function to an asynchronous iterator. This function takes a callable that returns | STRING |
| HIGH | python/cocoindex/connectorkits/async_adapters.py | 106 | 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 | 909 | // Step 1: hold a guarded read transaction open. | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 919 | // Step 2: concurrent write that will trigger MapFull + resize. | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 942 | // Step 3: wait until the resize path holds (or waits for) the coordinator | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 961 | // Step 4: release the read transaction (txn drops before its guard). | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 964 | // 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 | 51 | # Step 1: Extract metadata + identify speakers | COMMENT |
| LOW⚡ | …es/conversation_to_knowledge/conv_knowledge/extract.py | 115 | # 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 | 909 | // Step 1: hold a guarded read transaction open. | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 919 | // Step 2: concurrent write that will trigger MapFull + resize. | COMMENT |
| LOW | rust/core/src/state_store/storage.rs | 942 | // Step 3: wait until the resize path holds (or waits for) the coordinator | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 961 | // Step 4: release the read transaction (txn drops before its guard). | COMMENT |
| LOW⚡ | rust/core/src/state_store/storage.rs | 964 | // 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 | 51 | # Step 1: Extract metadata + identify speakers | COMMENT |
| LOW⚡ | …es/conversation_to_knowledge/conv_knowledge/extract.py | 115 | # 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 |
|---|---|---|---|---|
| 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 | 1095 | # Create an empty batch with the schema | COMMENT |
| MEDIUM | python/cocoindex/_internal/component_ctx.py | 296 | # Create a new ComponentContext with extended path | COMMENT |
| MEDIUM | python/cocoindex/_internal/function.py | 821 | # Create the fn call context (and record this function's own logic fp) | COMMENT |
| MEDIUM | python/tests/connectors/test_postgres_target.py | 822 | # 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 |
|---|---|---|---|---|
| LOW | python/cocoindex/cli.py | 1229 | # 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 | 766 | # Check if vector columns are used but sqlite-vec is not loaded | COMMENT |
| LOW | python/cocoindex/connectors/sqlite/_target.py | 898 | # 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 | 1079 | # Check if table exists | COMMENT |
| LOW | python/cocoindex/_internal/function.py | 848 | # Check if cached result is still valid | COMMENT |
| LOW | python/cocoindex/_internal/function.py | 1429 | # 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 |
|---|---|---|---|---|
| HIGH | python/cocoindex/connectors/lancedb/_target.py | 1155 | # Existing rows are backfilled with null, so additive schema | COMMENT |
| HIGH | python/tests/ops/test_text.py | 585 | " 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 | 1305 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 1896 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 2030 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 2132 | CODE | |
| LOW | python/cocoindex/_internal/function.py | 2157 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/cocoindex/_internal/memo_fingerprint.py | 279 | # For others, don't try to sort and just return a placeholder. | COMMENT |
| MEDIUM | docs/package-lock.json | 7292 | "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 |