Home / influxdata / influxdb
Repository Analysis

influxdata/influxdb

Scalable datastore for metrics, events, and real-time analytics

4.9 Likely human-written View on GitHub
4.9
Adjusted Score
4.9
Raw Score
100%
Time Factor
2026-05-30
Last Push
31,517
Stars
Rust
Language
340,136
Lines of Code
946
Files
1128
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 0HIGH 33MEDIUM 140LOW 955

Pattern Findings

1128 matches across 14 categories. Click a row to expand file-level details.

Over-Commented Block791 hits · 774 pts
SeverityFileLineSnippet
LOWCargo.toml101 ".git*",
LOWdeny.toml1# Configuration documentation:
LOWdeny.toml21 # (requires CA compromise). Stuck on 0.102.x via wasmtime's rustls 0.22.x
LOWrustfmt.toml1edition = "2024"
LOWinstall_influxdb.sh1#!/bin/sh -e
LOWinstall_influxdb.sh21# - Extracts to user home directory (~/.influxdb)
LOWinstall_influxdb.sh41# ├── influxdb3 (Main binary)
LOWinstall_influxdb.sh61# - Detects existing docker-compose.yml at ~/.influxdb/docker/
LOWinstall_influxdb.sh81# Cluster ID: (Enterprise only) Cluster identifier
LOWinstall_influxdb.sh101# Error Exits (exit 1):
LOWinstall_influxdb.sh121# - Opens Explorer UI in default browser upon successful startup
LOWinfluxdb3_client/src/lib.rs161 /// let token = "secret-token-string";
LOWinfluxdb3_client/src/lib.rs181 /// client
LOWinfluxdb3_client/src/lib.rs201 body: NoBody,
LOWinfluxdb3_client/src/lib.rs241 /// ```no_run
LOWinfluxdb3_client/src/lib.rs281 /// .ttl(120)
LOWinfluxdb3_client/src/lib.rs321
LOWinfluxdb3_client/src/lib.rs1141
LOWinfluxdb3_client/src/lib.rs1181
LOWinfluxdb3_client/src/lib.rs1221 .get_or_insert_with(Default::default)
LOWinfluxdb3_sys_events/src/lib.rs21 /// in the buffer.
LOWinfluxdb3_write/src/table_index_cache.rs221 // during LRU eviction).
LOWinfluxdb3_write/src/table_index_cache.rs241/// of the system (eg retention period handling, hard delete handling, anything else that nees to
LOWinfluxdb3_write/src/table_index_cache.rs301 /// snapshots are converted.
LOWinfluxdb3_write/src/table_index_cache.rs321 ///
LOWinfluxdb3_write/src/table_index_cache.rs1121 /// This method performs a comprehensive synchronization between the object store and the local
LOWinfluxdb3_write/src/table_index_cache.rs1141 /// - Creates a new index by loading and merging all snapshots
LOWinfluxdb3_write/src/table_index_cache.rs1221 debug!("updated table index for {:?}", table_id);
LOWinfluxdb3_write/src/persister.rs101
LOWinfluxdb3_write/src/lib.rs161
LOWinfluxdb3_write/src/lib.rs181 /// The min time from all parquet files in the snapshot.
LOWinfluxdb3_write/src/lib.rs461///
LOWinfluxdb3_write/src/table_index_cache/tests.rs1641
LOW…3_write/src/table_index/test_table_index_operations.rs601
LOWinfluxdb3_write/src/write_buffer/queryable_buffer.rs381
LOWinfluxdb3_write/src/write_buffer/queryable_buffer.rs401 // 3 (force_snapshot) // triggered by mem check interval 10s
LOWinfluxdb3_write/src/write_buffer/validator.rs101 // Check if the database is soft-deleted and reject writes if so.
LOWinfluxdb3_write/src/write_buffer/tests.rs1901 debug!(?total_buffer_size_bytes_after, "total buffer size");
LOWinfluxdb3_write/src/write_buffer/tests.rs1921 // }
LOWinfluxdb3_clap_blocks/src/object_store.rs401 /// `--object-store` to a cloud object storage to have any effect.
LOWinfluxdb3_clap_blocks/src/object_store.rs421
LOWinfluxdb3_clap_blocks/src/object_store.rs481 /// value.
LOWinfluxdb3_clap_blocks/src/object_store.rs541 long = gen_name!($prefix, "aws-skip-signature"),
LOWinfluxdb3_clap_blocks/src/object_store.rs581 pub google_service_account: Option<String>,
LOWinfluxdb3_clap_blocks/src/object_store.rs601 ///
LOWinfluxdb3_clap_blocks/src/object_store.rs701 ///
LOWinfluxdb3_clap_blocks/src/memory_size.rs1//! Helper types to express memory size.
LOWinfluxdb3_clap_blocks/src/datafusion.rs1use std::collections::HashMap;
LOWinfluxdb3_clap_blocks/src/datafusion.rs21 /// (out-of-memory) if the fan-out is too large.
LOWinfluxdb3_clap_blocks/src/datafusion.rs61}
LOWinfluxdb3_catalog/src/lib.rs1//! # InfluxDB 3 Catalog
LOWinfluxdb3_catalog/src/lib.rs21//! Snapshots contain the complete catalog state at a specific sequence number, used for faster startup.
LOWinfluxdb3_catalog/src/lib.rs41//!
LOWinfluxdb3_catalog/src/lib.rs61//! // In log/versions/v4.rs
LOWinfluxdb3_catalog/src/lib.rs81//! ```ignore
LOWinfluxdb3_catalog/src/lib.rs101//!
LOWinfluxdb3_catalog/src/lib.rs121//! #### 3. Update Deserialization
LOWinfluxdb3_catalog/src/lib.rs141//!
LOWinfluxdb3_catalog/src/lib.rs161//! ### Important Considerations
LOWinfluxdb3_catalog/src/catalog.rs81 Mutex::const_new(CatalogSequenceNumber::new(0));
731 more matches not shown…
Decorative Section Separators125 hits · 502 pts
SeverityFileLineSnippet
MEDIUMinstall_influxdb.sh875# ==============================================================================
MEDIUMinstall_influxdb.sh877# ==============================================================================
MEDIUMinstall_influxdb.sh136# ==============================================================================
MEDIUMinstall_influxdb.sh138# ==============================================================================
MEDIUMinstall_influxdb.sh177# ==============================================================================
MEDIUMinstall_influxdb.sh179# ==============================================================================
MEDIUMinstall_influxdb.sh205# ==============================================================================
MEDIUMinstall_influxdb.sh207# ==============================================================================
MEDIUMinstall_influxdb.sh248# ==============================================================================
MEDIUMinstall_influxdb.sh250# ==============================================================================
MEDIUMinstall_influxdb.sh313# ==============================================================================
MEDIUMinstall_influxdb.sh315# ==============================================================================
MEDIUMinstall_influxdb.sh683# ==============================================================================
MEDIUMinstall_influxdb.sh685# ==============================================================================
MEDIUMinstall_influxdb.sh1179# ==============================================================================
MEDIUMinstall_influxdb.sh1181# ==============================================================================
MEDIUMcore/predicate/src/rpc_predicate/field_rewrite.rs121 // ┌─────────┐
MEDIUMcore/predicate/src/rpc_predicate/field_rewrite.rs127 // └─────────┘
MEDIUMcore/predicate/src/rpc_predicate/field_rewrite.rs161 // ┌─────────┐ ┌─────────┐
MEDIUMcore/predicate/src/rpc_predicate/field_rewrite.rs165 // └─────────┘ └─────────┘
MEDIUMcore/predicate/src/rpc_predicate/field_rewrite.rs177 // ┌─────────┐
MEDIUMcore/predicate/src/rpc_predicate/field_rewrite.rs181 // └─────────┘
MEDIUMcore/predicate/src/rpc_predicate/field_rewrite.rs195 // ┌──────┐
MEDIUMcore/predicate/src/rpc_predicate/field_rewrite.rs197 // │ ---- ├─────────┐
MEDIUMcore/predicate/src/rpc_predicate/field_rewrite.rs198 // │ "f1" │ true ◀─┼─────f1 matches
MEDIUMcore/predicate/src/rpc_predicate/field_rewrite.rs201 // └──────┴─────────┘
MEDIUMcore/iox_query/src/memory_pool.rs100/// ┌─────────────┐┌────────────────────────────────────┐
MEDIUMcore/iox_query/src/memory_pool.rs106/// └──────▲──────┘└──────────────▲─────────────────────┘
MEDIUMcore/iox_query/src/memory_pool.rs110/// Query A ───────────────────┘
MEDIUMcore/iox_query/src/provider/adapter.rs80/// ┌────────────────┐ ┌───────────────────────────────┐
MEDIUMcore/iox_query/src/provider/adapter.rs81/// │ ┌─────┐┌─────┐ │ │ ┌─────┐┌──────┐┌─────┐┌─────┐ │
MEDIUMcore/iox_query/src/provider/adapter.rs84/// ┌──────────────┐ │ │ 1 ││ 10 │ │ ┌──────────────┐ │ │ 1 ││ NULL ││ 10 ││ foo │ │
MEDIUMcore/iox_query/src/provider/adapter.rs87/// └──────────────┘ │ │ 4 ││ 40 │ │ └──────────────┘ │ │ 4 ││ NULL ││ 40 ││ foo │ │
MEDIUMcore/iox_query/src/provider/adapter.rs88/// │ └─────┘└─────┘ │ │ └─────┘└──────┘└─────┘└─────┘ │
MEDIUMcore/iox_query/src/provider/adapter.rs91/// └────────────────┘ └───────────────────────────────┘
MEDIUMcore/iox_query/src/provider/reorder_partitions.rs20/// ┌─────────────────────────┐
MEDIUMcore/iox_query/src/provider/reorder_partitions.rs24/// └─────────────────────────┘ │ ┌───────────────────┐ ┌───────────────────┐ ┌───────────────┐
MEDIUMcore/iox_query/src/provider/reorder_partitions.rs29/// ┌─────────────────────────┐ │ └───────────────────┘ └───────────────────┘ └───────┴───────┘
MEDIUMcore/iox_query/src/provider/reorder_partitions.rs33/// └─────────────────────────┘
MEDIUMcore/iox_query/src/provider/progressive_eval.rs40/// ┌─────────────────────────┐
MEDIUMcore/iox_query/src/provider/progressive_eval.rs44/// └─────────────────────────┘ │ ┌───────────────────┐ ┌───────────────────────────────┐
MEDIUMcore/iox_query/src/provider/progressive_eval.rs48/// ┌─────────────────────────┐ │ └───────────────────┘ └─┬─────┴───────────────────────┘
MEDIUMcore/iox_query/src/provider/progressive_eval.rs52/// └─────────────────────────┘
MEDIUMcore/iox_query/src/exec/split.rs16//! └────────────┬──────────┘
MEDIUMcore/iox_query/src/exec/split.rs25//! ┌────────────────────────┐
MEDIUMcore/iox_query/src/exec/split.rs28//! └────────────────────────┘
MEDIUMcore/iox_query/src/exec/split.rs33//! ┌────────────────────────┐ (Filter, Dedup, etc)
MEDIUMcore/iox_query/src/exec/split.rs38//! └────────────────────────┘ │
MEDIUMcore/iox_query/src/exec/split.rs39//! ▲ ┌────────────────────────┐
MEDIUMcore/iox_query/src/exec/split.rs41//! ┌────────────────────────┐ │ │
MEDIUMcore/iox_query/src/exec/split.rs42//! │ TableScan │ └────────────────────────┘
MEDIUMcore/iox_query/src/exec/split.rs44//! └────────────────────────┘
MEDIUMcore/iox_query/src/exec/gapfill/algo.rs47/// ╓────╥───┬───┬─────────────╥───┬───┬─────────────╖
MEDIUMcore/iox_query/src/exec/gapfill/algo.rs49/// ╟────╫───┼───┼─────────────╫───┼───┼─────────────╢
MEDIUMcore/iox_query/src/exec/gapfill/algo.rs51/// │ ╟────╫───┼───┼─────────────╫───┼───┼─────────────╢
MEDIUMcore/iox_query/src/exec/gapfill/algo.rs53/// │ ╟────╫───┼───┼─────────────╫───┼───┼─────────────╢
MEDIUMcore/iox_query/src/exec/gapfill/algo.rs57/// │ ╟────╫───┼───┼─────────────╫───┼───┼─────────────╢
MEDIUMcore/iox_query/src/exec/gapfill/algo.rs59/// │ ╟────╫───┼───┼─────────────╫───┼───┼─────────────╢
MEDIUMcore/iox_query/src/exec/gapfill/algo.rs61/// ╟────╫───┼───┼─────────────╫───┼───┼─────────────╢
MEDIUMcore/iox_query/src/exec/gapfill/algo.rs63/// ╟────╫───┼───┼─────────────╫───┼───┼─────────────╢
65 more matches not shown…
Synthetic Comment Markers30 hits · 182 pts
SeverityFileLineSnippet
HIGHcore/trace_exporters/src/thrift/jaeger.rs385 ref_type: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs386 trace_id_low: f_2.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs387 trace_id_high: f_3.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs388 span_id: f_4.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs545 trace_id_low: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs546 trace_id_high: f_2.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs547 span_id: f_3.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs548 parent_span_id: f_4.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs549 operation_name: f_5.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs551 flags: f_7.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs552 start_time: f_8.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs553 duration: f_9.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs760 full_queue_dropped_spans: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs761 too_large_dropped_spans: f_2.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs762 failed_to_emit_spans: f_3.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs184 key: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs185 v_type: f_2.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs300 timestamp: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs301 fields: f_2.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs678 service_name: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs849 process: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs850 spans: f_2.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs928 ok: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/jaeger.rs1130 batches: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/agent.rs239 spans: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/agent.rs291 batch: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/zipkincore.rs763 ok: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/trace_exporters/src/thrift/zipkincore.rs997 spans: f_1.expect("auto-generated code should have checked for presence of required fields"),
HIGHcore/tracker/src/task.rs825 // std::thread::sleep is guaranteed to take at least as long as requested
HIGHcore/influxdb2_client/tests/common/server_fixture.rs15// variable is set, or via `docker` otherwise), set up the server as requested and
Hyper-Verbose Identifiers69 hits · 50 pts
SeverityFileLineSnippet
LOW.circleci/packages/test_influxdb3-launcher.py387 def test_single_required_key_present(self):
LOW.circleci/packages/test_influxdb3-launcher.py393 def test_single_required_key_missing(self):
LOW.circleci/packages/test_influxdb3-launcher.py400 def test_comma_separated_all_present(self):
LOW.circleci/packages/test_influxdb3-launcher.py408 def test_comma_separated_some_missing(self):
LOW.circleci/packages/test_influxdb3-launcher.py417 def test_multiple_groups_one_satisfied(self):
LOW.circleci/packages/test_influxdb3-launcher.py465 def test_non_scalar_value_raises(self):
LOW.circleci/packages/test_influxdb3-launcher.py472 def test_boolean_scalar_allowed(self):
LOW.circleci/packages/test_influxdb3-launcher.py480 def test_enterprise_to_core_downgrade_fails(self):
LOW.circleci/packages/test_influxdb3-launcher.py568 def test_write_pidfile_creates_directory(self):
LOW.circleci/packages/test_influxdb3-launcher.py577 def test_write_pidfile_permissions(self):
LOW.circleci/packages/test_influxdb3-launcher.py585 def test_write_pidfile_explicit_pid(self):
LOW.circleci/packages/test_influxdb3-launcher.py1543 def test_read_stamp_nonexistent(self):
LOW.circleci/packages/test_influxdb3-launcher.py1549 def test_write_and_read_stamp(self):
LOW.circleci/packages/test_influxdb3-launcher.py1556 def test_write_stamp_enterprise(self):
LOW.circleci/packages/test_influxdb3-launcher.py1563 def test_write_stamp_overwrites(self):
LOW.circleci/packages/test_influxdb3-launcher.py1571 def test_check_flavor_migration_fresh_install_core(self):
LOW.circleci/packages/test_influxdb3-launcher.py1578 def test_check_flavor_migration_fresh_install_enterprise(self):
LOW.circleci/packages/test_influxdb3-launcher.py1585 def test_check_flavor_migration_same_flavor_core(self):
LOW.circleci/packages/test_influxdb3-launcher.py1689 def test_platform_id_double_quotes(self):
LOW.circleci/packages/test_influxdb3-launcher.py1697 def test_platform_id_single_quotes(self):
LOW.circleci/packages/test_influxdb3-launcher.py1705 def test_platform_id_no_quotes(self):
LOW.circleci/packages/test_influxdb3-launcher.py1817 def test_returns_empty_on_fedora(self):
LOW.circleci/packages/test_influxdb3-launcher.py1826 def test_returns_empty_when_no_os_release(self):
LOW.circleci/packages/test_influxdb3-launcher.py1834 def test_returns_empty_when_cert_bundle_missing(self):
LOW.circleci/packages/test_influxdb3-launcher.py1844 def test_returns_empty_when_ssl_cert_file_already_set(self):
LOW.circleci/packages/test_influxdb3-launcher.py129 def test_symlink_to_executable(self):
LOW.circleci/packages/test_influxdb3-launcher.py138 def test_windows_branch_skips_exec_bit(self):
LOW.circleci/packages/test_influxdb3-launcher.py254 def test_special_characters_in_value(self):
LOW.circleci/packages/test_influxdb3-launcher.py295 def test_mismatched_quotes_toml(self):
LOW.circleci/packages/test_influxdb3-launcher.py302 def test_core_flavor_mappings(self):
LOW.circleci/packages/test_influxdb3-launcher.py319 def test_enterprise_flavor_mappings(self):
LOW.circleci/packages/test_influxdb3-launcher.py338 def test_default_key_transformation(self):
LOW.circleci/packages/test_influxdb3-launcher.py430 def test_multiple_groups_none_satisfied(self):
LOW.circleci/packages/test_influxdb3-launcher.py444 def test_empty_value_treated_as_missing(self):
LOW.circleci/packages/test_influxdb3-launcher.py453 def test_toml_nested_value_skipped(self):
LOW.circleci/packages/test_influxdb3-launcher.py517 def test_enterprise_with_license_file(self):
LOW.circleci/packages/test_influxdb3-launcher.py531 def test_enterprise_with_license_email_and_type(self):
LOW.circleci/packages/test_influxdb3-launcher.py606 def test_platform_supports_fork_constant(self):
LOW.circleci/packages/test_influxdb3-launcher.py616 def test_daemonize_forks_and_writes_pidfile(self):
LOW.circleci/packages/test_influxdb3-launcher.py670 def test_daemonize_creates_new_session(self):
LOW.circleci/packages/test_influxdb3-launcher.py716 def test_daemonize_redirects_to_log_file(self):
LOW.circleci/packages/test_influxdb3-launcher.py760 def test_daemonize_log_file_open_failure(self):
LOW.circleci/packages/test_influxdb3-launcher.py796 def test_daemonize_mocked_double_fork(self):
LOW.circleci/packages/test_influxdb3-launcher.py861 def test_daemonize_unsupported_platform(self):
LOW.circleci/packages/test_influxdb3-launcher.py894 def test_run_environment_precedence(self):
LOW.circleci/packages/test_influxdb3-launcher.py951 def test_run_argument_passing(self):
LOW.circleci/packages/test_influxdb3-launcher.py979 def test_run_restores_sighup_before_exec(self):
LOW.circleci/packages/test_influxdb3-launcher.py1004 def test_run_keeps_sighup_default(self):
LOW.circleci/packages/test_influxdb3-launcher.py1060 def test_missing_required_flavor(self):
LOW.circleci/packages/test_influxdb3-launcher.py1090 def test_missing_required_exec(self):
LOW.circleci/packages/test_influxdb3-launcher.py1109 def test_missing_required_stamp_dir(self):
LOW.circleci/packages/test_influxdb3-launcher.py1180 def test_separator_splits_arguments(self):
LOW.circleci/packages/test_influxdb3-launcher.py1219 def test_no_separator_empty_exec_args(self):
LOW.circleci/packages/test_influxdb3-launcher.py1254 def test_successful_execution_with_pidfile(self):
LOW.circleci/packages/test_influxdb3-launcher.py1297 def test_core_missing_object_store(self):
LOW.circleci/packages/test_influxdb3-launcher.py1329 def test_enterprise_missing_license(self):
LOW.circleci/packages/test_influxdb3-launcher.py1361 def test_enterprise_only_email_fails(self):
LOW.circleci/packages/test_influxdb3-launcher.py1395 def test_log_file_without_daemonize_warns(self):
LOW.circleci/packages/test_influxdb3-launcher.py1441 def test_daemonize_with_pidfile(self):
LOW.circleci/packages/test_influxdb3-launcher.py1492 def test_daemonize_unsupported_platform_via_main(self):
9 more matches not shown…
Verbosity Indicators27 hits · 46 pts
SeverityFileLineSnippet
LOWinfluxdb3_write/src/table_index_cache/tests.rs2434 // Step 1: Create async channel
LOWinfluxdb3_write/src/table_index_cache/tests.rs2437 // Step 2: Collect all parquet file paths from cached indices
LOWinfluxdb3_write/src/table_index_cache/tests.rs2452 // Step 3: Verify each file exists
LOWcore/influxdb_iox_client/src/client/flightsql.rs122 /// Step 1: send a [`CommandStatementQuery`] message to the
LOWcore/influxdb_iox_client/src/client/flightsql.rs126 /// Step 2: Fetch the results described in the [`FlightInfo`]
LOWcore/influxdb_iox_client/src/client/flightsql.rs466 /// Step 1: Sends a [`ActionCreatePreparedStatementRequest`] message to
LOWcore/influxdb_iox_client/src/client/flightsql.rs471 /// Step 2: Add parameters to the prepared statement using `DoPut(` [`CommandStatementQuery`] )
LOWcore/influxdb_iox_client/src/client/flightsql.rs568 /// Step 1: send a [`CommandStatementQuery`] message to the
LOWcore/influxdb_iox_client/src/client/flightsql.rs572 /// Step 2: Fetch the results described in the [`FlightInfo`]
LOW…c/physical_optimizer/sort/order_union_sorted_inputs.rs152 // Step 1: Remove any RoundRobin repartition nodes that may interfere with optimization
LOW…c/physical_optimizer/sort/order_union_sorted_inputs.rs157 // Step 2: Split and regroup partitioned file scans. Also re-orders the scan partitions.
LOW…c/physical_optimizer/sort/order_union_sorted_inputs.rs163 // Step 3: compensate for previous redistribution (for parallelized sorting) passes.
LOW…c/physical_optimizer/sort/order_union_sorted_inputs.rs166 // Step 4: try to extract the lexical ranges for the input partitions
LOW…c/physical_optimizer/sort/order_union_sorted_inputs.rs171 // Step 5: if needed, re-order the partitions
LOW…c/physical_optimizer/sort/order_union_sorted_inputs.rs182 // Step 6: Replace SortPreservingMergeExec with ProgressiveEvalExec
LOWcore/iox_query_influxql/src/plan/planner.rs2569 // For non-existent columns, we need to check if the user specified a gap-filling value.
LOWcore/influxdb_influxql_parser/src/timestamp.rs96 // Step 1: Date-time format
LOWcore/influxdb_influxql_parser/src/timestamp.rs116 // Step 2: RFC3339Nano format
LOWcore/influxdb_influxql_parser/src/timestamp.rs132 // Step 3: Date format
LOWcore/influxdb_influxql_parser/src/timestamp.rs148 // Step 1: Date-time format
LOWcore/influxdb_influxql_parser/src/timestamp.rs171 // Step 2: RFC3339Nano format
LOWcore/influxdb_influxql_parser/src/timestamp.rs187 // Step 3: Date format
LOWinfluxdb3/tests/cli/offline_tokens.rs15 // Step 1: Create offline admin token using CLI
LOWinfluxdb3/tests/cli/offline_tokens.rs38 // Step 2: Start server with token files
LOWinfluxdb3/tests/cli/offline_tokens.rs49 // Step 4: Verify tokens exist
LOWinfluxdb3/tests/cli/offline_tokens.rs58 // Step 4: Verify database creation
LOWinfluxdb3/tests/cli/offline_tokens.rs67 // Step 5: Test admin token privileges
Excessive Try-Catch Wrapping54 hits · 36 pts
SeverityFileLineSnippet
MEDIUM.circleci/packages/test_influxdb3-launcher.py2090 print(f"Error: {LAUNCHER_PATH} is not a file", file=sys.stderr)
LOW.circleci/packages/test_influxdb3-launcher.py632 except Exception:
LOW.circleci/packages/test_influxdb3-launcher.py684 except Exception:
LOW.circleci/packages/test_influxdb3-launcher.py732 except Exception:
LOW.circleci/packages/test_influxdb3-launcher.py778 except Exception:
LOW.circleci/packages/sandbox_verify.py821 except Exception:
LOW.circleci/packages/sandbox_verify.py965 except Exception:
LOW.circleci/packages/sandbox_verify.py975 except Exception:
LOW.circleci/packages/sandbox_verify.py982 except Exception:
LOW.circleci/packages/sandbox_verify.py989 except Exception:
LOW.circleci/packages/sandbox_verify.py136 except Exception:
LOW.circleci/packages/sandbox_verify.py152 except Exception:
LOW.circleci/packages/sandbox_verify.py170 except Exception:
LOW.circleci/packages/sandbox_verify.py190 except Exception:
LOW.circleci/packages/sandbox_verify.py210 except Exception:
LOW.circleci/packages/sandbox_verify.py226 except Exception:
LOW.circleci/packages/sandbox_verify.py245 except Exception:
LOW.circleci/packages/sandbox_verify.py294 except Exception:
LOW.circleci/packages/sandbox_verify.py318 except Exception:
LOW.circleci/packages/sandbox_verify.py340 except Exception:
LOW.circleci/packages/sandbox_verify.py360 except Exception:
LOW.circleci/packages/sandbox_verify.py380 except Exception:
LOW.circleci/packages/sandbox_verify.py403 except Exception:
LOW.circleci/packages/sandbox_verify.py442 except Exception:
LOW.circleci/packages/sandbox_verify.py479 except Exception:
LOW.circleci/packages/sandbox_verify.py524 except Exception:
LOW.circleci/packages/sandbox_verify.py556 except Exception:
LOW.circleci/packages/sandbox_verify.py585 except Exception:
LOW.circleci/packages/sandbox_verify.py602 except Exception:
LOW.circleci/packages/sandbox_verify.py627 except Exception:
LOW.circleci/packages/sandbox_verify.py648 except Exception:
LOW.circleci/packages/sandbox_verify.py669 except Exception:
LOW.circleci/packages/sandbox_verify.py698 except Exception:
LOW.circleci/packages/sandbox_verify.py716 except Exception:
LOW.circleci/packages/sandbox_verify.py730 except Exception:
LOW.circleci/packages/sandbox_verify.py754 except Exception:
LOW.circleci/packages/sandbox_verify.py778 except Exception:
LOW.circleci/packages/sandbox_verify.py800 except Exception:
LOW.circleci/packages/sandbox_verify.py838 except Exception:
LOW.circleci/packages/sandbox_verify.py848 except Exception:
LOW.circleci/packages/sandbox_verify.py860 except Exception:
LOW.circleci/packages/sandbox_verify.py878 except Exception:
LOW.circleci/packages/sandbox_verify.py896 except Exception:
LOW.circleci/packages/sandbox_verify.py910 except Exception:
LOW.circleci/packages/sandbox_verify.py929 except Exception:
LOW.circleci/packages/sandbox_verify.py947 except Exception:
LOW.circleci/packages/sandbox_verify.py1001 except Exception:
LOW.circleci/packages/sandbox_verify.py1014 except Exception:
LOW.circleci/packages/sandbox_verify.py1024 except Exception:
LOW.circleci/packages/sandbox_verify.py1042 except Exception:
LOW.circleci/packages/sandbox_verify.py1054 except Exception:
LOW.circleci/packages/sandbox_verify.py1066 except Exception:
LOW.circleci/packages/sandbox_verify.py1088 except Exception:
LOW.circleci/packages/sandbox_verify.py1105 except Exception:
Self-Referential Comments9 hits · 27 pts
SeverityFileLineSnippet
MEDIUMinstall_influxdb.sh653 # Create the config.json file
MEDIUMinfluxdb3/tests/cli/mod.rs3175 # Creating a mock Flask Response object
MEDIUMinfluxdb3/tests/cli/mod.rs3782 # Create a complex object (nested dictionaries and lists)
MEDIUM.circleci/packages/test_influxdb3-launcher.py77 # Create the Python script
MEDIUM.circleci/packages/test_influxdb3-launcher.py1894 # Create the Python script
MEDIUM.circleci/packages/test_influxdb3-launcher.py1920 # Create a mock executable that prints an env var
MEDIUM.circleci/packages/test_influxdb3-launcher.py1953 # Create a simple mock executable
MEDIUM.circleci/packages/test_influxdb3-launcher.py1982 # Create a simple mock executable
MEDIUM.circleci/packages/test_influxdb3-launcher.py2015 # Create a mock executable that writes to log and marker file
AI Slop Vocabulary6 hits · 16 pts
SeverityFileLineSnippet
LOWCargo.toml314# crates.io release and our fork), just add it to this list here.
MEDIUMinfluxdb3_write/src/write_buffer/table_buffer.rs79 /// that are in the buffer index, this will also leverage those to prune rows in the resulting
MEDIUMinfluxdb3_clap_blocks/src/object_store.rs915 // can leverage PUT IF NOT EXISTS semantics when writing new catalog files
MEDIUMcore/mutable_batch/src/writer.rs1179 // A test to make sure some optimized versions of writing values to a `Writer` (which utilize
MEDIUMcore/partition/src/template/strftime.rs100/// To leverage this reuse of timestamps, this type retains a cache of the 5
MEDIUM.circleci/packages/config.yaml120 # usr/lib/influxdb3-{core,enterprise} to facilitate upgrades from core
Magic Placeholder Names2 hits · 12 pts
SeverityFileLineSnippet
HIGHinstall_influxdb.sh865 printf "1. Replace ${DIM}\"YOUR_TOKEN_HERE\"${NC} with your admin token in the Explorer config file:\n"
HIGHinstall_influxdb.sh832 configure_explorer_via_file "YOUR_TOKEN_HERE" "http://${CONTAINER_NAME}:8181" "$SERVER_NAME" "$DOCKER_DIR"
Redundant / Tautological Comments5 hits · 8 pts
SeverityFileLineSnippet
LOWinstall_influxdb.sh989 # Check if license file exists
LOWinfluxdb3_py_api/src/system_py.rs564 # Check if value has no decimal component
LOWinfluxdb3/tests/cli/mod.rs2840 # Check if authorization header is present (case-insensitive)
LOWinfluxdb3/tests/cli/mod.rs3710 # Check if we've run before by looking for a cache value
LOW…i/packages/influxdb3/fs/usr/lib/influxdb3/sysv-init.sh75 # Check if service is enabled
Deep Nesting6 hits · 4 pts
SeverityFileLineSnippet
LOWinfluxdb3_load_generator/analysis/app.py23
LOW.circleci/packages/sandbox_verify.py269
LOW.circleci/packages/sandbox_verify.py483
LOW.circleci/packages/sandbox_verify.py589
LOW.circleci/packages/sandbox_verify.py804
LOW.circleci/packages/sandbox_verify.py900
Cross-Language Confusion1 hit · 2 pts
SeverityFileLineSnippet
HIGH.circleci/packages/sandbox_verify.py37 "trigger_arguments": null,
Unused Imports2 hits · 2 pts
SeverityFileLineSnippet
LOWinfluxdb3_load_generator/analysis/app.py4
LOW.circleci/packages/sandbox_verify.py48
Fake / Example Data1 hit · 0 pts
SeverityFileLineSnippet
LOW.circleci/packages/test_influxdb3-launcher.py1365 'object-store = "file"\nlicense-email = "user@example.com"\n'