Qdrant - High-performance, massive-scale Vector Database and Vector Search Engine for the next generation of AI. Also available in the cloud https://cloud.qdrant.io/
1839 matches across 16 categories. Click a row to expand file-level details.
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | tests/openapi/test_match_except_empty.py | 98 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 100 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 126 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 128 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 156 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 160 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 168 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 170 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 208 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 210 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 238 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 243 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 275 | # --------------------------------------------------------------------------- |
| MEDIUM | tests/openapi/test_match_except_empty.py | 278 | # --------------------------------------------------------------------------- |
| MEDIUM | lib/collection/src/wal_delta.rs | 1011 | // ┌───┬───────►┌───┐ |
| MEDIUM | lib/collection/src/wal_delta.rs | 1013 | // └─▲─┴───────►└─▲─┘ |
| MEDIUM | lib/collection/src/wal_delta.rs | 1035 | // │ B ├───────►│ E │ |
| MEDIUM | lib/collection/src/wal_delta.rs | 1041 | // │ E ├───────►│ A │ |
| MEDIUM | lib/collection/src/shards/shard_holder/resharding.rs | 508 | // ┌────────────┐ ┌──────────┐ |
| MEDIUM | lib/collection/src/shards/shard_holder/resharding.rs | 514 | // └────────────┘ └──────────┘ |
| MEDIUM | lib/collection/src/shards/shard_holder/resharding.rs | 517 | // ┌────────────┐ ┌──────────┐ |
| MEDIUM | lib/collection/src/shards/shard_holder/resharding.rs | 523 | // └────────────┘ └──────────┘ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 58 | // ┌──────────────┐ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 62 | // └──────┬───────┘ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 63 | // │ Report created ┌───────────┐ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 64 | // └────────────────────► │ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 66 | // ┌─────────────────────┤ │ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 67 | // │ └───────────┘ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 68 | // ┌─────▼───────┐ User Promote ┌──────────┐ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 69 | // │ ◄──────────────────────────► │ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 71 | // │ ◄───────────┐ │ │ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 72 | // └──┬──────────┘ │Transfer └──┬───────┘ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 74 | // │ ┌──────┴────────┐ │Update |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 78 | // │ └───────▲───────┘ │ │ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 80 | // ┌──▼──────────┐ Transfer │ │ │ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 82 | // │ Dead ├────────────┘ │ │ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 84 | // └─▲───────▲───┘ Transfer │ │ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 86 | // │ └────────────────────────────┘ │ |
| MEDIUM | lib/collection/src/shards/replica_set/mod.rs | 88 | // └─────────────────────────────────────────┘ |
| MEDIUM | …ection/src/shards/replica_set/partial_snapshot_meta.rs | 11 | /// ┌─────────────────┐ |
| MEDIUM | …ection/src/shards/replica_set/partial_snapshot_meta.rs | 13 | /// └───────┬─────────┘ |
| MEDIUM | …ection/src/shards/replica_set/partial_snapshot_meta.rs | 14 | /// │◄────────────── |
| MEDIUM | …ection/src/shards/replica_set/partial_snapshot_meta.rs | 16 | /// ┌───────▼─────────┐ (accept reads, |
| MEDIUM | …ection/src/shards/replica_set/partial_snapshot_meta.rs | 18 | /// └───────┬─────────┘ |
| MEDIUM | …ection/src/shards/replica_set/partial_snapshot_meta.rs | 19 | /// │◄─────────────── |
| MEDIUM | …ection/src/shards/replica_set/partial_snapshot_meta.rs | 21 | /// ┌───────▼─────────┐ (reject reads, |
| MEDIUM | …ection/src/shards/replica_set/partial_snapshot_meta.rs | 23 | /// └───────┬─────────┘ |
| MEDIUM | …ection/src/shards/replica_set/partial_snapshot_meta.rs | 26 | /// ┌───────▼─────────┐ |
| MEDIUM | …ection/src/shards/replica_set/partial_snapshot_meta.rs | 28 | /// └─────────────────┘ |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 80 | /// ┌───────────┐ ┌───────────┐ ┌───────────┐ |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 82 | /// └───────────┘ └───────────┘ └───────────┘ |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 85 | /// ────►┌─┬──────────────────────|────────────────────────►|──┐ |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 88 | /// └─┴────────────────────►┬─┬──────────────────────►┌─┐◄┘ |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 92 | /// | │X├───────────────────────┴─┘◄┘ |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 99 | /// | │X├───────────────────────┬─┐ |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 102 | /// | ┌─┐◄─·│X│·──────────────────────┤ │ |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 104 | /// | └─┴──·│X│·─────────────────────►│ ├─┐ |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 107 | /// | │X│◄──────────────────────┴─┘◄┘ |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 109 | /// ┌─┐◄────────────────────┤ │ | |
| MEDIUM | lib/collection/src/shards/transfer/snapshot.rs | 116 | /// │ ├──────────────────·│ │X│·─────────────────────►┌─┬─┐ |
| 129 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tools/smaps-view.py | 21 | |
| LOW | tools/smaps-view.py | 41 | # ShmemPmdMapped: 0 kB |
| LOW | config/config.yaml | 1 | log_level: INFO |
| LOW | config/config.yaml | 21 | # Where to store snapshots |
| LOW | config/config.yaml | 41 | # |
| LOW | config/config.yaml | 81 | # CPU budget, how many CPUs (threads) to allocate for an optimization job. |
| LOW | config/config.yaml | 101 | # Default is to allow 1 transfer. |
| LOW | config/config.yaml | 121 | # The minimal number of vectors in a segment, required to perform segment optimization |
| LOW | config/config.yaml | 141 | # If not set, will be automatically selected considering the number of available CPUs. |
| LOW | config/config.yaml | 161 | # optimizers configs regardless of the config above and the options specified at collection creation. |
| LOW | config/config.yaml | 181 | # When the maximum estimated amount of points that a condition satisfies is smaller than |
| LOW | config/config.yaml | 221 | # More info: https://qdrant.tech/documentation/guides/quantization |
| LOW | config/config.yaml | 241 | # Max HNSW value allowed in search parameters. |
| LOW | config/config.yaml | 281 | |
| LOW | config/config.yaml | 301 | # (Either above or via an external service like nginx.) |
| LOW | config/config.yaml | 321 | # Hardware reporting adds information to the API responses with a |
| LOW | config/config.yaml | 361 | # Compact consensus operations once we have this amount of applied |
| LOW | config/config.yaml | 381 | # This certificate will be used to validate the certificates |
| LOW | config/config.yaml | 401 | # dir: ./storage/audit |
| LOW | tests/openapi_consistency_check.sh | 1 | #!/usr/bin/env bash |
| LOW | tests/grpc_consistency_check.sh | 1 | #!/usr/bin/env bash |
| LOW | tests/basic_grpc_test.sh | 341 | # use the reflection service to get the shape of a specific message |
| LOW | tests/basic_grpc_test.sh | 361 | #curl -L -X POST "http://$QDRANT_HOST/collections/test_collection/points/search" \ |
| LOW | tests/consensus_tests/test_shard_wal_delta_transfer.py | 661 | # transfer could break the subsequent WAL delta transfer. Specifically, any new |
| LOW | tests/consensus_tests/test_resharding.py | 321 | # Inject a delay on EVERY peer. The staging delay is broadcast to all |
| LOW | …ensus_tests/test_resharding_set_replica_dead_replay.py | 101 | ) |
| LOW | …us_tests/test_shard_snapshot_transfer_missing_point.py | 21 | MISSING_ID_START = 10_000_000 |
| LOW | …us_tests/test_shard_snapshot_transfer_missing_point.py | 101 | return shard['state'] |
| LOW | tests/consensus_tests/test_shard_stream_transfer.py | 281 | |
| LOW | tests/consensus_tests/test_shard_stream_transfer.py | 481 | |
| LOW | …sts/consensus_tests/test_collection_recovery_limits.py | 161 | peer_url = start_peer(killed_peer_dir, "peer_0_restarted.log", bootstrap_url, port=restart_port) |
| LOW | tests/consensus_tests/test_failed_snapshot_recovery.py | 41 | r = requests.put(f"{peer_api_uri}/collections/{COLLECTION_NAME}/snapshots/recover", |
| LOW | tests/consensus_tests/test_partial_snapshot.py | 21 | # |
| LOW | tests/consensus_tests/test_partial_snapshot.py | 41 | # - collection is *exactly* the same on both peers: same points and segment IDs |
| LOW | lib/trififo/benches/cache_comparison.rs | 1 | //! Cache comparison benchmarks for trififo. |
| LOW | lib/trififo/benches/cache_comparison.rs | 261 | } |
| LOW | lib/trififo/benches/cache_comparison.rs | 281 | // } |
| LOW | lib/trififo/src/seqlock.rs | 1 | use std::cell::UnsafeCell; |
| LOW | lib/trififo/src/seqlock.rs | 21 | /// shared resource even as it is being modified. |
| LOW | lib/trififo/src/seqlock.rs | 41 | /// println!("Value: {}", value); |
| LOW | lib/trififo/src/seqlock.rs | 61 | /// The way a seqlock can prevent lock contention, is by allowing reader to access |
| LOW | lib/collection/benches/prof.rs | 21 | /// fn fibonacci_profiled(criterion: &mut Criterion) { |
| LOW | lib/collection/src/optimizers_builder.rs | 41 | pub vacuum_min_vector_number: usize, |
| LOW | lib/collection/src/optimizers_builder.rs | 61 | #[validate(range(min = 1))] |
| LOW | lib/collection/src/optimizers_builder.rs | 81 | /// Note: 1kB = 1 vector of size 256. |
| LOW | lib/collection/src/recommendations.rs | 221 | request, |
| LOW | lib/collection/src/config.rs | 81 | pub enum ShardingMethod { |
| LOW | lib/collection/src/config.rs | 101 | #[serde(default)] |
| LOW | lib/collection/src/config.rs | 121 | pub read_fan_out_factor: Option<u32>, |
| LOW | lib/collection/src/update_handler.rs | 41 | /// Operation. If None, then the operation data is read from WAL |
| LOW | lib/collection/src/update_handler.rs | 81 | pub optimizers: Arc<Vec<Arc<Optimizer>>>, |
| LOW | lib/collection/src/wal_delta.rs | 81 | /// |
| LOW | lib/collection/src/wal_delta.rs | 181 | |
| LOW | lib/collection/src/wal_delta.rs | 1001 | // 2.1. Operation 30 is written to A, but not B (Second channel) |
| LOW | lib/collection/src/wal_delta.rs | 1021 | // |
| LOW | lib/collection/src/wal_delta.rs | 1361 | /// - What node is used as entry point |
| LOW | lib/collection/src/wal_delta.rs | 1801 | .expect("WAL ordering property violated"); |
| LOW | …rc/collection_manager/probabilistic_search_sampling.rs | 1 | /// Precomputed sampling table for the probabilistic segment search algorithm. |
| LOW | …collection/src/collection_manager/segments_searcher.rs | 601 | /// Process sequentially contiguous batches |
| LOW | …rc/collection_manager/optimizers/indexing_optimizer.rs | 581 | /// |
| 824 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tools/smaps-view.py | 137 | def calculate_cache_percentage(pid: int, pattern: str, verbose: bool = False) -> Dict[str, float]: |
| LOW | tests/openapi/test_query_indexes.py | 119 | def test_filtered_query_results_same_for_different_indexes(query, collection_name): |
| LOW | tests/openapi/test_query_indexes.py | 154 | def test_filtered_query_groups_results_same_for_different_indexes(collection_name): |
| LOW | tests/openapi/test_query_indexes.py | 195 | def test_filtered_query_batches_results_same_for_different_indexes(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 52 | def test_patch_collection_full(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 84 | def test_patch_collection_partially(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 106 | def test_strict_mode_query_limit_validation(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 137 | def test_strict_mode_timeout_validation(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 138 | def search_request_with_timeout(timeout): |
| LOW | tests/openapi/test_strictmode.py | 165 | def test_strict_mode_unindexed_filter_keyword_read_validation(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 166 | def search_request_with_filter(): |
| LOW | tests/openapi/test_strictmode.py | 220 | def test_strict_mode_unindexed_filter_integer_read_validation(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 221 | def search_request_with_filter(): |
| LOW | tests/openapi/test_strictmode.py | 305 | def test_strict_mode_unindexed_filter_phrase_read_validation(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 326 | def search_request_with_filter(kind: str): |
| LOW | tests/openapi/test_strictmode.py | 371 | def test_strict_mode_unindexed_filter_write_validation(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 372 | def update_request_with_filter(): |
| LOW | tests/openapi/test_strictmode.py | 427 | def test_strict_mode_max_ef_hnsw_validation(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 461 | def test_strict_mode_allow_exact_validation(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 495 | def test_strict_mode_search_max_oversampling_validation(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 532 | def test_strict_mode_upsert_max_batch_size(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 574 | def test_strict_mode_update_many_upsert_max_batch_size(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 622 | def test_strict_mode_update_vectors_max_batch_size(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 670 | def test_strict_mode_search_max_batch_size(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 706 | def test_strict_mode_max_collection_size_upsert(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 751 | def test_strict_mode_max_sparse_length_upsert(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 824 | def test_strict_mode_max_collection_size_upsert_batch(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 873 | def test_strict_mode_max_multivector_size_upsert(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1020 | def test_strict_mode_read_rate_limiting(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1077 | def test_strict_mode_max_collection_payload_size_upsert(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1122 | def test_strict_mode_max_collection_payload_size_upsert_batch(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1171 | def test_strict_mode_max_collection_point_count_upsert_batch(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1221 | def test_strict_mode_write_rate_limiting(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1291 | def test_strict_mode_write_rate_limiting_filtered_update_op(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1331 | def test_strict_mode_write_rate_limiting_batch_update_op(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1373 | def test_filter_many_conditions(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1412 | def test_filter_large_condition(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1450 | def test_filter_nested_condition(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1523 | def test_strict_mode_formula_expression(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1583 | def test_strict_mode_read_rate_limiting_small_replenish(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1626 | def test_strict_mode_unset_rate_limiting_config(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1682 | def test_strict_mode_recommendation_best_score_read_rate_limiting(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1743 | def test_strict_mode_retrieve_read_rate_limiting(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1807 | def test_scroll_filter_many_conditions(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1852 | def test_strict_mode_group_limits(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1919 | def test_strict_mode_distance_matrix_limits(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1950 | def test_read_rate_limiter_many_vectors(full_collection_name): |
| LOW | tests/openapi/test_strictmode.py | 1960 | def check_multivector_query_raw(should_succeed: bool): |
| LOW | tests/openapi/test_strictmode.py | 1975 | def check_multivector_query_id(should_succeed: bool): |
| LOW | tests/openapi/test_strictmode.py | 2024 | def test_strict_mode_group_by_unindexed(collection_name): |
| LOW | tests/openapi/test_strictmode.py | 2176 | def test_strict_mode_full_scan(full_collection_name): |
| LOW | tests/openapi/test_strictmode.py | 2284 | def test_strict_mode_full_scan_simple(full_collection_name): |
| LOW | tests/openapi/test_strictmode.py | 2342 | def test_strict_mode_multitenant_full_scan(full_collection_name): |
| LOW | tests/openapi/test_strictmode.py | 2457 | def test_strict_mode_payload_index_count(collection_name): |
| LOW | tests/openapi/test_multi_vector.py | 14 | def multivector_collection_setup( |
| LOW | tests/openapi/test_multi_vector.py | 46 | def test_multi_vector_float_persisted(collection_name): |
| LOW | tests/openapi/test_multi_vector.py | 138 | def test_multi_vector_validation(collection_name): |
| LOW | tests/openapi/test_multi_vector.py | 380 | def test_multi_with_euclidean(collection_name): |
| LOW | tests/openapi/test_multi_vector_unnamed.py | 15 | def multivector_collection_setup( |
| LOW | tests/openapi/test_multi_vector_unnamed.py | 45 | def test_multi_vector_float_persisted(collection_name): |
| 434 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tools/smaps-view.py | 18 | |
| LOW | tests/openapi/test_multi_vector_unnamed.py | 2 | |
| LOW | tests/openapi/test_multi_vector_uint8.py | 2 | |
| LOW | tests/openapi/test_conditional_update.py | 1 | |
| LOW | tests/openapi/test_snapshot.py | 1 | |
| LOW | tests/openapi/test_snapshot.py | 4 | |
| LOW | tests/openapi/test_filtered_delete.py | 6 | |
| LOW | tests/consensus_tests/test_shard_snapshot_deadlock.py | 8 | |
| LOW | tests/consensus_tests/test_shard_consistency.py | 6 | |
| LOW | tests/consensus_tests/test_hw_measurement.py | 6 | |
| LOW | tests/consensus_tests/test_collection_created_after.py | 3 | |
| LOW | …s/consensus_tests/test_shard_transfer_rate_limiting.py | 4 | |
| LOW | tests/consensus_tests/test_snapshot_recovery.py | 4 | |
| LOW | tests/consensus_tests/test_custom_sharding.py | 6 | |
| LOW | tests/consensus_tests/test_custom_sharding.py | 7 | |
| LOW | tests/consensus_tests/test_read_consistency.py | 7 | |
| LOW | tests/consensus_tests/test_many_collections.py | 3 | |
| LOW | tests/consensus_tests/test_strict_mode.py | 5 | |
| LOW | tests/consensus_tests/test_recover_dead_node.py | 3 | |
| LOW | tests/consensus_tests/test_update_concurrency.py | 5 | |
| LOW | tests/consensus_tests/test_shard_wal_delta_transfer.py | 8 | |
| LOW | tests/consensus_tests/test_sparse_points_search.py | 3 | |
| LOW | …sensus_tests/test_shard_snapshot_clocks_consistency.py | 7 | |
| LOW | …sensus_tests/test_shard_snapshot_clocks_consistency.py | 8 | |
| LOW | …sensus_tests/test_shard_snapshot_clocks_consistency.py | 9 | |
| LOW | tests/consensus_tests/test_recovery_mode.py | 2 | |
| LOW | …ests/test_shard_snapshot_transfer_clear_and_restart.py | 5 | |
| LOW | tests/consensus_tests/test_replicate_points.py | 6 | |
| LOW | tests/consensus_tests/test_collection_sharding.py | 3 | |
| LOW | tests/consensus_tests/test_points_query.py | 3 | |
| LOW | tests/consensus_tests/test_resharding.py | 7 | |
| LOW | …/consensus_tests/test_disable_url_snapshot_recovery.py | 6 | |
| LOW | …ensus_tests/test_resharding_set_replica_dead_replay.py | 25 | |
| LOW | tests/consensus_tests/test_collection_created_before.py | 3 | |
| LOW | tests/consensus_tests/test_points_recommendation.py | 3 | |
| LOW | …s/consensus_tests/test_cluster_operation_coalescing.py | 5 | |
| LOW | tests/consensus_tests/test_resharding_replay.py | 11 | |
| LOW | tests/consensus_tests/test_collection_recovery.py | 5 | |
| LOW | …consensus_tests/test_shard_snapshot_transfer_cancel.py | 6 | |
| LOW | tests/consensus_tests/test_triple_replication.py | 5 | |
| LOW | tests/consensus_tests/test_cluster_rejoin.py | 10 | |
| LOW | tests/consensus_tests/test_named_vector_crud.py | 5 | |
| LOW | tests/consensus_tests/test_named_vector_crud.py | 5 | |
| LOW | tests/consensus_tests/test_named_vector_crud.py | 7 | |
| LOW | tests/consensus_tests/test_tenant_promotion.py | 5 | |
| LOW | tests/consensus_tests/test_tenant_promotion.py | 6 | |
| LOW | tests/consensus_tests/test_force_delete_peer.py | 2 | |
| LOW | tests/consensus_tests/test_force_delete_peer.py | 4 | |
| LOW | …us_tests/test_shard_snapshot_transfer_missing_point.py | 6 | |
| LOW | tests/consensus_tests/test_cluster_metadata.py | 4 | |
| LOW | tests/consensus_tests/custom_sharding.py | 1 | |
| LOW | tests/consensus_tests/custom_sharding.py | 2 | |
| LOW | tests/consensus_tests/test_shard_stream_transfer.py | 7 | |
| LOW | tests/consensus_tests/test_segment_max_size.py | 1 | |
| LOW | tests/consensus_tests/test_segment_max_size.py | 3 | |
| LOW | tests/consensus_tests/test_segment_max_size.py | 4 | |
| LOW | tests/consensus_tests/test_segment_max_size.py | 7 | |
| LOW | tests/consensus_tests/test_dummy_shard.py | 5 | |
| LOW | tests/consensus_tests/test_two_follower_nodes_down.py | 5 | |
| LOW | …ts/consensus_tests/test_learners_promoted_to_voters.py | 2 | |
| 46 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | tools/smaps-view.py | 177 | print(f"Error: Could not find /proc/{pid}/smaps", file=sys.stderr) |
| LOW | tools/smaps-view.py | 179 | except Exception as e: |
| MEDIUM | tools/smaps-view.py | 180 | print(f"Error processing smaps: {e}", file=sys.stderr) |
| LOW | tests/consensus_tests/test_custom_sharding.py | 331 | except Exception as e: |
| LOW | …nsus_tests/test_streaming_snapshot_consensus_freeze.py | 87 | except Exception as e: |
| LOW | …nsus_tests/test_streaming_snapshot_consensus_freeze.py | 100 | except Exception as e: |
| LOW | …nsus_tests/test_streaming_snapshot_consensus_freeze.py | 114 | except Exception as e: |
| LOW | tests/consensus_tests/test_cluster_rejoin.py | 556 | except Exception: |
| MEDIUM | tests/consensus_tests/test_cluster_rejoin.py | 552 | def old_peer_consensus_stopped(): |
| LOW | tests/consensus_tests/utils.py | 712 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 720 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 728 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 736 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 743 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 750 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 758 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 766 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 775 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 784 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 795 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 806 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 814 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 822 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 830 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 837 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 863 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 881 | except Exception as e: |
| LOW | tests/consensus_tests/utils.py | 67 | except Exception as e: |
| LOW | tests/consensus_tests/test_failed_snapshot_recovery.py | 194 | except Exception as e: |
| LOW | tests/consensus_tests/test_failed_snapshot_recovery.py | 214 | except Exception as e: |
| LOW | tests/consensus_tests/test_failed_snapshot_recovery.py | 328 | except Exception as e: |
| LOW | tests/consensus_tests/test_failed_snapshot_recovery.py | 372 | except Exception as e: |
| LOW | tests/consensus_tests/test_io_uring_eintr.py | 60 | except Exception as e: |
| LOW | tests/consensus_tests/test_consensus_compaction.py | 197 | except Exception: |
| LOW | tests/consensus_tests/test_consensus_compaction.py | 224 | except Exception as e: |
| LOW | tests/consensus_tests/test_listener_node.py | 40 | except Exception as e: |
| LOW | tests/consensus_tests/test_listener_node.py | 47 | except Exception as e: |
| LOW | tests/consensus_tests/test_snapshot_recovery_kill.py | 27 | except Exception: |
| LOW | tests/consensus_tests/test_resharding_extras.py | 232 | except Exception as e: |
| LOW | tests/e2e_tests/conftest.py | 37 | except Exception as e: |
| LOW | tests/e2e_tests/conftest.py | 258 | except Exception as docker_error: |
| LOW | tests/e2e_tests/client_utils.py | 34 | except Exception: |
| LOW | tests/e2e_tests/client_utils.py | 53 | except Exception: |
| LOW | tests/e2e_tests/client_utils.py | 69 | except Exception: |
| LOW | tests/e2e_tests/client_utils.py | 81 | except Exception as e: |
| LOW | tests/e2e_tests/client_utils.py | 98 | except Exception as e: |
| LOW | tests/e2e_tests/client_utils.py | 240 | except Exception as e: |
| LOW | tests/e2e_tests/client_utils.py | 251 | except Exception as e: |
| LOW | tests/e2e_tests/client_utils.py | 268 | except Exception as e: |
| LOW | tests/e2e_tests/client_utils.py | 295 | except Exception as e: |
| LOW | tests/e2e_tests/client_utils.py | 334 | except Exception as e: |
| LOW | tests/e2e_tests/client_utils.py | 469 | except Exception as e: |
| LOW | tests/e2e_tests/test_data_compatibility.py | 115 | except Exception as e: |
| LOW | tests/e2e_tests/test_data_compatibility.py | 129 | except Exception as error: |
| LOW | tests/e2e_tests/test_data_compatibility.py | 270 | except Exception as e: |
| LOW | tests/e2e_tests/test_low_ram.py | 71 | except Exception as e: |
| LOW | tests/e2e_tests/test_strict_mode_memory.py | 112 | except Exception as exc: # qdrant-client may wrap differently depending on version |
| LOW | tests/e2e_tests/utils.py | 196 | except Exception as e: |
| MEDIUM | tests/e2e_tests/utils.py | 197 | print(f"Error stopping container {container.name if hasattr(container, 'name') else 'unknown'}: {e}") |
| LOW | tests/e2e_tests/utils.py | 247 | except Exception: |
| 4 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | lib/collection/src/collection/mod.rs | 524 | // If not initialized yet, we need to check if it was initialized by this call |
| LOW | lib/collection/src/tests/deferred_points_dedup.rs | 232 | // Step 1: Insert initial batch of points (wait=true to ensure they are persisted) |
| LOW | lib/collection/src/tests/deferred_points_dedup.rs | 246 | // Step 2: Overwrite all point values with new random vectors — this triggers CoW. |
| LOW | lib/collection/src/tests/deferred_points_dedup.rs | 277 | // Step 3: Overwrite again — this creates another round of CoW on top of the |
| LOW | lib/collection/src/tests/deferred_points_dedup.rs | 306 | // Step 4: Assert no duplicate non-deferred point IDs across segments |
| LOW | lib/gpu/src/pipeline.rs | 99 | // Before we start, we need to check if the device supports dynamic subgroup size. |
| LOW | …rc/segment/tests/test_immutable_payload_index_files.rs | 86 | // Step 1: appendable source segment with payload + field indices. |
| LOW | …rc/segment/tests/test_immutable_payload_index_files.rs | 134 | // Step 2: build a non-appendable target via SegmentBuilder. Mmap vector |
| LOW | …ndex/field_index/geo_index/mmap_geo_index/lifecycle.rs | 433 | // Step 1: binary search to find the index of the `start` entry. |
| LOW | …ndex/field_index/geo_index/mmap_geo_index/lifecycle.rs | 441 | // Step 2: read entries in chunks starting from `start`. Chunks may |
| LOW | …ndex/field_index/geo_index/mmap_geo_index/lifecycle.rs | 491 | // Step 3: read the collected ranges and accumulate unique, |
| LOW | lib/gridstore/src/gridstore/tests.rs | 1073 | // Step 1: Write initial data and flush |
| LOW | lib/gridstore/src/gridstore/tests.rs | 1082 | // Step 2: Open a reader |
| LOW | lib/gridstore/src/gridstore/tests.rs | 1086 | // Step 3: Verify reader sees initial data |
| LOW | lib/gridstore/src/gridstore/tests.rs | 1092 | // Step 4: live_reload when nothing changed should be a no-op |
| LOW | lib/gridstore/src/gridstore/tests.rs | 1098 | // Step 5: Write more data via writable storage and flush |
| LOW | lib/gridstore/src/gridstore/tests.rs | 1108 | // Step 6: live_reload should update max_point_offset and make new data accessible |
| LOW | src/snapshots.rs | 55 | // if it does, we need to check if we want to overwrite it |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tests/openapi/test_wait_timeout.py | 103 | "text": "Lorem ipsum, dolor sit amet.", |
| LOW | tests/openapi/test_wait_timeout.py | 103 | "text": "Lorem ipsum, dolor sit amet.", |
| LOW | tests/openapi/test_wait_timeout.py | 137 | "text": "Lorem ipsum, dolor sit amet.", |
| LOW | tests/openapi/test_wait_timeout.py | 137 | "text": "Lorem ipsum, dolor sit amet.", |
| LOW | tests/openapi/test_wait_timeout.py | 171 | "text": "Lorem ipsum, dolor sit amet.", |
| LOW | tests/openapi/test_wait_timeout.py | 171 | "text": "Lorem ipsum, dolor sit amet.", |
| LOW | tests/e2e_tests/client_utils.py | 124 | "Lorem ipsum dolor sit amet consectetur adipiscing elit", |
| LOW | tests/e2e_tests/client_utils.py | 124 | "Lorem ipsum dolor sit amet consectetur adipiscing elit", |
| LOW | lib/collection/tests/integration/multi_vec_test.rs | 108 | payload: Some(serde_json::from_str(r#"{"number": "John Doe"}"#).unwrap()), |
| LOW | lib/collection/tests/integration/pagination_test.rs | 34 | payload: Some(serde_json::from_str(r#"{"number": "John Doe"}"#).unwrap()), |
| LOW | …llection/tests/integration/continuous_snapshot_test.rs | 134 | payload: Some(serde_json::from_str(r#"{"number": "John Doe"}"#).unwrap()), |
| LOW | …collection/tests/integration/snapshot_recovery_test.rs | 107 | payload: Some(serde_json::from_str(r#"{"number": "John Doe"}"#).unwrap()), |
| LOW | lib/collection/tests/integration/grouping_test.rs | 496 | const BODY_TEXT: &str = "lorem ipsum dolor sit amet"; |
| LOW | lib/collection/tests/integration/grouping_test.rs | 496 | const BODY_TEXT: &str = "lorem ipsum dolor sit amet"; |
| LOW | …/segment/tests/integration/segment_on_disk_snapshot.rs | 37 | "names": ["John Doe", "Bill Murray"], |
| LOW | lib/segment/src/segment/tests/mod.rs | 115 | "name": "John Doe", |
| LOW | lib/segment/src/segment/tests/mod.rs | 202 | "name": "John Doe", |
| LOW | …/src/payload_storage/in_memory_payload_storage_impl.rs | 177 | "name": "John Doe", |
| LOW | …/src/payload_storage/in_memory_payload_storage_impl.rs | 197 | "John Doe".to_string().into(), |
| LOW | …/src/payload_storage/in_memory_payload_storage_impl.rs | 228 | let payload: Payload = serde_json::from_str(r#"{"name": "John Doe"}"#).unwrap(); |
| LOW | …/src/payload_storage/in_memory_payload_storage_impl.rs | 245 | "name": "John Doe", |
| LOW | lib/segment/src/payload_storage/payload_storage_enum.rs | 252 | let payload: Payload = serde_json::from_str(r#"{"name": "John Doe"}"#).unwrap(); |
| LOW | lib/segment/src/index/struct_payload_index/tests.rs | 22 | "name": "John Doe" |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | tests/consensus_tests/test_resharding.py | 196 | # Create a list to collect replica URIs selected during test |
| MEDIUM | tests/consensus_tests/test_resharding.py | 231 | # Create a list to collect replica URIs selected during test |
| MEDIUM | tests/consensus_tests/test_resharding.py | 419 | # Create a list to collect replica URIs selected during test |
| MEDIUM | tests/consensus_tests/test_named_vector_crud.py | 119 | # Create a new dense named vector |
| MEDIUM | tests/consensus_tests/test_named_vector_crud.py | 140 | # Create a new sparse named vector |
| MEDIUM | …sts/consensus_tests/test_collection_recovery_limits.py | 141 | # Create an extra peer to allow moving some replicas |
| MEDIUM | tests/consensus_tests/test_resharding_extras.py | 197 | # Create a shard key |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | tests/e2e_tests/utils.py | 120 | Extract HTTP and gRPC ports from container. For host network mode, returns standard Qdrant ports (6333, 6334). F |
| HIGH | tests/e2e_tests/utils.py | 201 | Core function to create a Qdrant container with given configuration. Args: docker_client: Docker client ins |
| HIGH | tests/e2e_tests/utils.py | 253 | General utility function to extract various archive formats. Args: archive_file: Path to the archive file t |
| HIGH | tests/e2e_tests/utils.py | 328 | Extract container info from a docker-compose container. Args: container: Docker container object from docke |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tools/smaps-view.py | 116 | # Don't forget to add the last entry if it matches |
| LOW | config/development.yaml | 5 | # Also don't forget to copy temporary configurations into config/config.yaml if they need |
| LOW | config/development.yaml | 5 | # Also don't forget to copy temporary configurations into config/config.yaml if they need |
| LOW | lib/gpu/src/instance.rs | 184 | // Don't forget to destroy the instance if we failed to find any physical devices. |
| LOW | lib/gpu/src/instance.rs | 217 | // Don't forget to destroy the instance if we failed to find any physical devices. |
| LOW | lib/gpu/src/instance.rs | 240 | // Don't forget to destroy the instance if we failed to create a debug messenger. |
| MEDIUM | lib/segment/src/segment/entry.rs | 38 | /// This is a basic implementation of the trait, meaning that it implements the _actual_ operations with data and not |
| LOW | lib/storage/src/content_manager/consensus/persistent.rs | 75 | // IF YOU ADD NEW DATA INTO `PERSISTENT` STATE, DON'T FORGET TO ALSO ADD IT INTO RAFT SNAPSHOT! |
| LOW | lib/common/common/src/progress_tracker.rs | 205 | /// Before entering hot loops, don't forget to call `Arc::deref` on it. |
| LOW | lib/common/common/src/universal_io/traits/file_ops.rs | 20 | // When adding provided methods, don't forget to update impls in crate::universal_io::wrappers::*. |
| LOW | lib/common/common/src/universal_io/traits/write.rs | 35 | // When adding provided methods, don't forget to update impls in crate::universal_io::wrappers::*. |
| LOW | lib/common/common/src/universal_io/traits/read.rs | 141 | // When adding provided methods, don't forget to update impls in crate::universal_io::wrappers::*. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tools/smaps-view.py | 60 | |
| LOW | tests/openapi/test_service.py | 116 | |
| LOW | tests/consensus_tests/test_shard_wal_delta_transfer.py | 51 | |
| LOW | tests/consensus_tests/test_two_follower_nodes_down.py | 28 | |
| LOW | tests/consensus_tests/utils.py | 474 | |
| LOW | tests/consensus_tests/test_write_ordering.py | 13 | |
| LOW | tests/consensus_tests/test_resharding_deferred.py | 183 | |
| LOW | tests/manual/test_memory_reporting.py | 24 | |
| LOW | tests/e2e_tests/conftest.py | 218 | |
| LOW | tests/e2e_tests/client_utils.py | 60 | |
| LOW | tests/e2e_tests/client_utils.py | 102 | |
| LOW | tests/e2e_tests/test_data_compatibility.py | 49 | |
| LOW | tests/e2e_tests/utils.py | 252 | |
| LOW | tests/e2e_tests/utils.py | 326 | |
| LOW | tests/e2e_tests/utils.py | 375 | |
| LOW | tests/e2e_tests/test_continuous_snapshots.py | 39 | |
| LOW | lib/edge/publish/amalgamate.py | 308 |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | tests/openapi/test_match_except_empty.py | 0 | except: [] without index should return all points that have the field. |
| HIGH | tests/openapi/test_match_except_empty.py | 0 | except: [] without index should return all points that have the field. |
| HIGH | tests/openapi/test_match_except_empty.py | 0 | except: [] without index should return all points that have the field. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tools/integration-test-coverage.sh | 8 | # Check if target/llvm-cov-target/debug/qdrant exists, if not build it: |
| LOW | tools/smaps-view.py | 83 | # Check if line starts with an address range (new memory map entry) |
| LOW | tests/basic_grpc_inference_test.sh | 12 | # Check if local grpcurl exists and is executable |
| LOW | tests/openapi/test_strictmode.py | 1794 | # Check if tokens are gone |
| LOW | tests/consensus_tests/test_io_uring_eintr.py | 178 | # Check if the process is still alive |
| LOW | tests/e2e_tests/conftest.py | 97 | # Check if image already exists |
| LOW | tests/e2e_tests/conftest.py | 198 | # Check if this is being used with indirect parametrization |
| LOW | tests/e2e_tests/test_continuous_snapshots.py | 19 | # Check if we should stop |
| LOW | lib/edge/tools/prepare_facet_snapshot.sh | 33 | # Check if Qdrant is already running |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | lib/collection/src/collection/distance_matrix.rs | 213 | // use the same filter for all requests to leverage batch search |
| MEDIUM | lib/segment/src/json_path/mod.rs | 239 | // nuanced cases include wildcard indexes, e.g., `a[0].b` and `a[].b` intersect. |
| MEDIUM | lib/quantization/src/turboquant/simd/query1bit/mod.rs | 466 | // — tightens to `<=` here to be robust against tiny-dim rng noise). |
| MEDIUM | lib/sparse/src/index/search_context.rs | 100 | // sort ids to fully leverage posting list iterator traversal |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | tests/openapi/test_filter_is_empty.py | 149 | # Point 1 has an explicit null, point 2 has no payload, point 3 has a value. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | tools/missed_cherry_picks.sh | 5 | # Example usage: |
| LOW | tools/generate_docker_compose_cluster.sh | 9 | # Example usage: |
| LOW | lib/segment/src/common/anonymize.rs | 12 | /// # Usage example |
| LOW | lib/edge/python/codegen/src/lib.rs | 7 | /// # Usage example |