Home / scylladb / scylladb
Repository Analysis

scylladb/scylladb

NoSQL data store using the Seastar framework, compatible with Apache Cassandra and Amazon DynamoDB

29.6 Moderate AI signal View on GitHub
29.6
Adjusted Score
29.6
Raw Score
100%
Time Factor
2026-05-30
Last Push
15,567
Stars
C++
Language
263,738
Lines of Code
1147
Files
5752
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 11HIGH 478MEDIUM 195LOW 5068

Pattern Findings

5752 matches across 18 categories. Click a row to expand file-level details.

Hyper-Verbose Identifiers3348 hits · 3088 pts
SeverityFileLineSnippet
LOWconfigure.py295def check_for_minimal_compiler_version(cxx):
LOWconfigure.py396def resolve_compilers_for_compiler_cache(args, compiler_cache):
LOWconfigure.py1867def get_clang_inline_threshold():
LOWconfigure.py1997def prepare_advanced_optimizations(*, modes, build_modes, args):
LOWconfigure.py3128def generate_compdb_for_cmake_build(source_dir, build_dir):
LOWgen_segmented_compress_params.py64def best_nominal_data_size_for_bucket_size(chunk_size, bucket_size, n_values):
LOWscylla-gdb.py42def get_template_arg_with_prefix(gdb_type, prefix):
LOWscylla-gdb.py529 def external_memory_footprint(self):
LOWscylla-gdb.py537def deref_libcpp_hashtable_nodes_data_member(ptr):
LOWscylla-gdb.py2009def find_single_sstable_readers():
LOWscylla-gdb.py2140def has_enable_lw_shared_from_this(type):
LOWscylla-gdb.py2341 def summarize_inheriting_execution_stage(ies):
LOWscylla-gdb.py2360 def summarize_table_phased_barrier_users(db, barrier_name):
LOWscylla-gdb.py2371 def summarize_storage_proxy_coordinator_stats(sp):
LOWscylla-gdb.py2805def get_seastar_memory_start_and_size():
LOWscylla-gdb.py2914 def is_seastar_allocator_used():
LOWscylla-gdb.py3490def seastar_threads_on_current_shard():
LOWscylla-gdb.py3662 def external_memory_footprint(self):
LOWscylla-gdb.py3680 def external_memory_footprint(self):
LOWscylla-gdb.py3719 def external_memory_footprint(self):
LOWscylla-gdb.py4538def get_gms_generation_or_version(i):
LOWscylla-gdb.py4608def find_sstables_attached_to_tables():
LOWscylla-gdb.py4757 def dump_compaction_group_memtables(compaction_group):
LOWscylla-gdb.py4842 def _traverse_object_graph_breadth_first(address, max_depth, max_vertices, timeout_seconds, value_range_override):
LOWscylla-gdb.py4895 def _do_generate_object_graph(address, output_file, max_depth, max_vertices, timeout_seconds, value_range_override):
LOWscylla-gdb.py5525 def get_cql_type_deserializer(self, type_name):
LOWscylla-gdb.py5555 def parse_clustering_key_bytes(self, b):
LOWscylla-gdb.py5559 def parse_partition_key_bytes(self, b):
LOWscylla-gdb.py5999 def dump_reads_from_semaphore(semaphore):
LOWscylla-gdb.py6447 def _last_token_of_compaction_group(self, most_significant_bits, group):
LOWidl-compiler.py440 def to_string_send_fn_signature(self):
LOWidl-compiler.py449 def to_string_handle_ret_value(self):
LOWidl-compiler.py531 def handler_function_return_values(self):
LOWidl-compiler.py545 def send_function_return_type(self):
LOWidl-compiler.py560 def handler_function_parameters_str(self):
LOWidl-compiler.py570 def send_function_signature_params_list(self, include_placeholder_names, dst_type):
LOWidl-compiler.py583 def send_message_argument_list(self):
LOWidl-compiler.py629def template_type_parse_action(tokens):
LOWidl-compiler.py663def class_member_parse_action(tokens):
LOWidl-compiler.py686def rpc_verb_param_parse_action(tokens):
LOWidl-compiler.py692def rpc_verb_return_val_parse_action(tokens):
LOWidl-compiler.py1044def add_param_writer_basic_type(name, base_state, typ, var_type="", var_index=None, root_node=False):
LOWidl-compiler.py891def list_local_writable_types(t):
LOWidl-compiler.py1355def register_writable_local_type(cls):
LOWidl-compiler.py1621def generate_rpc_verbs_declarations(hout, module_name):
LOWidl-compiler.py1637def generate_rpc_verbs_definitions(cout, module_name):
LOWidl-compiler.py1693def setup_additional_metadata(tree, ns_context = [], parent_template_params=[]):
LOWtest/scylla_gdb/test_sstable_commands.py39def test_sstable_summary_output(gdb_cmd):
LOWtest/scylla_gdb/test_basic_commands.py74def test_nonexistent_scylla_command(gdb_cmd):
LOWtest/scylla_gdb/test_schema_commands.py40def test_generate_object_graph(gdb_cmd, request):
LOWtest/cluster/test_table_desc_read_barrier.py19async def test_table_desc_read_barrier(manager: ManagerClient) -> None:
LOW…cluster/test_write_query_during_cql_server_shutdown.py22async def test_write_query_during_cql_server_shutdown(request: pytest.FixtureRequest, manager: ManagerClient) -> None:
LOWtest/cluster/test_replica_exceptions.py85async def test_replica_do_apply_rate_limit_no_cpp_exceptions(manager: ManagerClient):
LOWtest/cluster/test_replica_exceptions.py107async def test_replica_query_rate_limit_no_cpp_exceptions(manager: ManagerClient):
LOWtest/cluster/test_replica_exceptions.py129async def test_replica_writes_apply_counter_update_timeout(manager: ManagerClient):
LOWtest/cluster/test_replica_exceptions.py152async def test_replica_writes_do_apply_counter_update_timeout(manager: ManagerClient):
LOWtest/cluster/test_replica_exceptions.py177async def test_replica_database_apply_timeout(manager: ManagerClient):
LOWtest/cluster/test_deprecating_cluster_features.py20async def test_feature_deprecation_works(manager: ManagerClient) -> None:
LOWtest/cluster/test_deprecating_cluster_features.py52async def test_features_suppress_works(manager: ManagerClient, build_mode) -> None:
LOWtest/cluster/test_counter_write_timeout_metric.py27async def test_counter_write_timeout_updates_coordinator_metric(manager: ManagerClient):
3288 more matches not shown…
Cross-Language Confusion430 hits · 2360 pts
SeverityFileLineSnippet
HIGHconfigure.py2461 command = {ragel_exec} -G2 -o $out $in && sed -i -e '1h;2,$$H;$$!d;g' -re 's/static const char _nfa[^;]*;//g
HIGHconfigure.py2484 command = rm -rf $out && mkdir -p $out && cp $pkgs $out/
HIGHconfigure.py3028 command = ./configure.py --out={buildfile_final_name}.new --out-final-name={buildfile_final_name} $configure_a
HIGHtest/cluster/util.py124 Polls system.topology until the transition_state column is null,
HIGHtest/cluster/test_ensure_committed_by_group0.py34 # Simulate pre-group0 table (null) and recovery-mode table (false)
HIGHtest/cluster/test_incremental_repair.py980 # is false and being_repaired is null, so S1' lands in the UNREPAIRED view where
HIGHtest/alternator/test_streams.py481 events.append(['INSERT',{'c':c + '0','p':p},null,{'c':c + '0','a':0,'p':p}])
HIGHtest/alternator/test_streams.py485 events.append(['INSERT',{'c':c + '2','p':p},null,{'c':c + '2','a':2,'p':p}])
HIGHtest/alternator/test_streams.py509 events.append(['INSERT',{'c':c,'p':p},null,{'c':c,'e':166,'g':166,'p':p}])
HIGHtest/alternator/test_streams.py540 events.append(['INSERT',{'p':p},null,{'e':166,'g':166,'p':p}])
HIGHtest/alternator/test_item.py50# number, boolean, bytes, null, list, map, string set, number set,
HIGHtest/alternator/test_manual_requests.py491 '{"RequestItems": null}',
HIGHtest/alternator/test_manual_requests.py494 '{"RequestItems": {"__TABLE__": null}}',
HIGHtest/alternator/test_manual_requests.py495 '{"RequestItems": {"__TABLE__": [null]}}',
HIGHtest/alternator/test_manual_requests.py497 '{"RequestItems": {"__TABLE__": [{"PutRequest": null}]}}',
HIGHtest/alternator/test_manual_requests.py499 '{"RequestItems": {"__TABLE__": [{"PutRequest": {"Item": null}}]}}',
HIGHtest/alternator/test_manual_requests.py501 '{"RequestItems": {"__TABLE__": [{"DeleteRequest": null}]}}',
HIGHtest/alternator/test_manual_requests.py503 '{"RequestItems": {"__TABLE__": [{"DeleteRequest": {"Key": null}}]}}',
HIGHtest/cqlpy/test_static.py83 # column. Getting back just the static row, with r=null, would be wrong
HIGHtest/cqlpy/test_cdc.py73 cql.execute(f"insert into {table} (pk, v) values (1, null)")
HIGHtest/cqlpy/test_type_decimal.py322# Java's BigDecimal.toString() specification.
HIGHtest/cqlpy/test_type_decimal.py326# for DecimalType delegates to BigDecimal.toString(). This test can be
HIGHtest/cqlpy/test_type_decimal.py340 # (input, expected toJson output per Java BigDecimal.toString())
HIGHtest/cqlpy/test_uda.py138 state_body = "(acc int, val int) CALLED ON NULL INPUT RETURNS int LANGUAGE lua AS 'if acc == null then return 999 el
HIGHtest/cqlpy/test_null.py257# Cassandra considers the null subscript 'm[null]' to be an invalid request.
HIGHtest/cqlpy/test_null.py258# In Scylla we decided to it differently (we think better): m[null] is simply
HIGHtest/cqlpy/test_null.py259# a null, so the filter 'WHERE m[null] = 3' is not an error - it just doesn't
HIGHtest/cqlpy/test_null.py261# and null < 2 are both defined as returning null), and will also allow us
HIGHtest/cqlpy/test_null.py72 cql.execute(f"INSERT INTO {table1} (p,c) VALUES ('{s}', null) IF NOT EXISTS")
HIGHtest/cqlpy/test_null.py74 cql.execute(f"INSERT INTO {table1} (p,c) VALUES (null, '{s}') IF NOT EXISTS")
HIGHtest/cqlpy/test_null.py86 cql.execute(f"BEGIN BATCH INSERT INTO {table1} (p,c) VALUES ('{s}', null);APPLY BATCH;")
HIGHtest/cqlpy/test_null.py88 cql.execute(f"BEGIN BATCH INSERT INTO {table1} (p,c) VALUES ('{s}', null) IF NOT EXISTS;APPLY BATCH;")
HIGHtest/cqlpy/test_null.py90 cql.execute(f"BEGIN BATCH INSERT INTO {table1} (p,c) VALUES (null, '{s}');APPLY BATCH;")
HIGHtest/cqlpy/test_null.py92 cql.execute(f"BEGIN BATCH INSERT INTO {table1} (p,c) VALUES (null, '{s}') IF NOT EXISTS;APPLY BATCH;")
HIGHtest/cqlpy/test_null.py119 cql.execute(cql.prepare(f"INSERT INTO {table2} (id,b,c) VALUES ('{key}',1,null)"))
HIGHtest/cqlpy/test_null.py122 cql.execute(cql.prepare(f"INSERT INTO {table2} (id,a,c) VALUES ('{key}',1,null)"))
HIGHtest/cqlpy/test_null.py55 cql.execute(f"INSERT INTO {table1} (p,c) VALUES ('{s}', null)")
HIGHtest/cqlpy/test_null.py57 cql.execute(f"INSERT INTO {table1} (p,c) VALUES (null, '{s}')")
HIGHtest/cqlpy/test_null.py275 assert list(cql.execute(f"SELECT p FROM {table1} WHERE m[null] = 3 ALLOW FILTERING")) == []
HIGHtest/cqlpy/test_udf.py104 lang_ret = "LANGUAGE java AS 'return null;'"
HIGHtest/cqlpy/test_materialized_view.py198# key column unset (aka null) do not get copied into the view.
HIGHtest/cqlpy/test_materialized_view.py319 # "restriction '(xyz) IS NOT { null }' is only supported in materialized
HIGHtest/cqlpy/test_materialized_view.py547# be null, so it is pointless to require the "IS NOT NULL". However,
HIGHtest/cqlpy/test_materialized_view.py204 cql.execute(f"INSERT INTO {table} (p,v) VALUES (17, null)")
HIGHtest/cqlpy/test_vector_similarity.py127 result = cql.execute(f"SELECT pk, similarity_{similarity_function}(null, [1.1, 1.2, 20.25]) FROM {table1}")
HIGHtest/cqlpy/test_vector_similarity.py130 result = cql.execute(f"SELECT pk, similarity_{similarity_function}(v1, null) FROM {table1}")
HIGHtest/cqlpy/test_vector_similarity.py134 cql.execute(f"SELECT pk, similarity_{similarity_function}(null, null) FROM {table1}")
HIGHtest/cqlpy/test_vector_similarity.py99 cql.execute(f"SELECT pk, similarity_{similarity_function}(v1, [1.1, null, 20.25]) FROM {table1}")
HIGHtest/cqlpy/test_vector_similarity.py318 result = cql.execute(f"SELECT pk, similarity_{similarity_function}(v, null) FROM {table}")
HIGHtest/cqlpy/test_json.py283 cql.execute(f"INSERT INTO {table1} (p, v) VALUES ({p}, fromJson(null))")
HIGHtest/cqlpy/test_json.py402 cql.execute(stmt, [p, '["a", null]'])
HIGHtest/cqlpy/test_json.py404 cql.execute(stmt, [p, '[null, 2]'])
HIGHtest/cqlpy/test_json.py411 cql.execute(stmt, [p, '["a", null]'])
HIGHtest/cqlpy/test_json.py562 assert list(cql.execute(f"SELECT JSON tup from {table1} where p = {p}")) == [('{"tup": ["hello", null]}',)]
HIGHtest/cqlpy/test_json.py566 assert list(cql.execute(f"SELECT JSON t1 from {table1} where p = {p}")) == [('{"t1": {"t": "hello", "b": null}}',)]
HIGHtest/cqlpy/test_json.py528 'ttl(v)': '{"ttl(v)": null}',
HIGHtest/cqlpy/test_json.py589 'ttl(v)': '{"ttl(v)": null}',
HIGHtest/cqlpy/test_json.py590 'ttl(v) as hi': '{"hi": null}',
HIGHtest/cqlpy/test_sstable_compression.py64# chunk_length_in_kb cannot be zero, negative, null, or non-integer.
HIGHtest/cqlpy/test_tools.py1999 # and leaves it unset (null) for others.
370 more matches not shown…
Over-Commented Block751 hits · 566 pts
SeverityFileLineSnippet
LOWCMakeLists.txt61# Since gcc 13, libgcc doesn't need the exception workaround
LOWconfigure.py301
LOWconfigure.py1941
LOWconfigure.py2041 # We are checking whether the profile archive is compressed,
LOWconfigure.py2061 command = xz --uncompress --stdout $in > $out
LOWconfigure.py2141 seastar_cxx_ld_flags = seastar_cxx_ld_flags.replace(flag, '')
LOWinstall.sh41# A pathname has three components: "$root/$prefix/$rest".
LOWcoverage_excludes.txt1# This file contains regx patterns that should be
LOWinstall-dependencies.sh1#!/bin/bash -e
LOWtest/CMakeLists.txt1find_package(jsoncpp REQUIRED)
LOWtest/pytest.ini41 skip_not_implemented(reason): Skip because the feature is not yet implemented.
LOWtest/cluster/conftest.py141 ssl_context=ssl_context,
LOWtest/cluster/test_ttl_row.py1# Copyright (C) 2025-present ScyllaDB
LOWtest/cluster/test_ttl_row.py121 # so the ALTER TABLE work doesn't pollute the ms_statement
LOWtest/cluster/test_topology_smp.py21
LOWtest/cluster/test_table_drop.py101 # Drop the table while streaming is paused. With the stream_in_progress
LOWtest/cluster/test_strong_consistency.py621 with pytest.raises(InvalidRequest, match=error_msg):
LOW…t_group0_recovers_after_partial_command_application.py81 # Before restarting, enable an error injection which causes the state
LOWtest/cluster/test_alternator.py1#
LOWtest/cluster/test_alternator.py161 # happened, and certainly several scans, all taking CPU which we expect
LOWtest/cluster/test_alternator.py261 # Run two Scylla nodes telling both their broadcast_rpc_address is 127.0.0.0
LOWtest/cluster/test_alternator.py401 # return just one node - not both. Reproduces #19694 (two nodes used to
LOWtest/cluster/test_alternator.py881 if hasattr(self, 'exception'):
LOWtest/cluster/test_alternator.py901# the operations are sent to different nodes - because a single node
LOWtest/cluster/test_commitlog.py21 # Check that commitlog provides durability in case of a node reboot.
LOWtest/cluster/test_topology_remove_decom.py41 table = await random_tables.add_table(ncolumns=5)
LOW…cluster/test_sstable_compression_dictionaries_basic.py421 select = cql.prepare(f'''SELECT c FROM test."{algo}" WHERE pk = ? BYPASS CACHE;''')
LOW…cluster/test_sstable_compression_dictionaries_basic.py441 # "key": "sstable_compression",
LOWtest/cluster/test_bti_index.py41
LOWtest/cluster/test_tablets_lwt.py201 consistency_level=ConsistencyLevel.SERIAL))
LOWtest/cluster/test_tablets_lwt.py641async def test_error_message_for_timeout_due_to_write_uncertainty(manager: ManagerClient):
LOWtest/cluster/test_tablets_lwt.py701async def test_no_uncertainty_for_reads(manager: ManagerClient):
LOWtest/cluster/test_view_building_coordinator.py761# Purpose of this test is to check if staging sstables managed by `view_building_worker`
LOWtest/cluster/test_view_building_coordinator.py961 await unpause_view_building_tasks(manager)
LOWtest/cluster/test_fencing.py301 # Node2 still sees node4 in a bootstrapping state because its group0 is broken.
LOWtest/cluster/test_fencing.py321 # while the second node is starting up, but without DC and rack information.
LOWtest/cluster/test_incremental_repair.py841 await drop_future
LOWtest/cluster/test_incremental_repair.py941 # after mark_sstable_as_repaired() has completed on all replicas for that tablet.
LOWtest/cluster/test_incremental_repair.py961
LOWtest/cluster/test_incremental_repair.py1141# a tombstone T becomes GC-eligible, any data D that T shadows has already
LOWtest/cluster/test_incremental_repair.py1601 # Base repair returns without waiting for staging to complete.
LOWtest/cluster/test_change_ip.py101 return None
LOWtest/cluster/test_raft_no_quorum.py41 # if the majority of the cluster is not available.
LOWtest/cluster/test_vector_store.py1#
LOWtest/cluster/test_unfinished_writes_during_shutdown.py121 # Wait for stop_transport to complete. At this point the local
LOWtest/cluster/tasks/__init__.py1#
LOWtest/cluster/object_store/test_backup.py281 cf_dir = os.listdir(f'{workdir}/data/{ks}')[0]
LOWtest/cluster/auth_cluster/conftest.py1#
LOWtest/cluster/auth_cluster/__init__.py1#
LOWtest/cluster/storage/__init__.py1#
LOWtest/cluster/storage/test_out_of_space_prevention.py721 def list_sstable_files():
LOWtest/cluster/dtest/schema_management_test.py401 rows = session.execute(SimpleStatement("SELECT * FROM cf", consistency_level=ConsistencyLevel.ALL))
LOWtest/cluster/dtest/alternator/__init__.py1#
LOWtest/cluster/dtest/alternator/utils/__init__.py1#
LOWtest/cluster/dtest/tools/__init__.py1#
LOWtest/cluster/dtest/ccmlib/__init__.py1#
LOWtest/cluster/lwt/__init__.py1#
LOWtest/cluster/random_failures/cluster_events.py101#
LOWtest/cluster/mv/test_mv_delete_partitions.py41 tasks = [asyncio.create_task(do_inserts(i)) for i in range(concurrency)]
LOWtest/cluster/mv/test_mv_delete_partitions.py81# Test deleting a large partition when there is a view with the same partition
691 more matches not shown…
Unused Imports365 hits · 348 pts
SeverityFileLineSnippet
LOWtest.py10
LOWtest/scylla_gdb/gdb_utils.py15
LOW…cluster/test_write_query_during_cql_server_shutdown.py11
LOW…cluster/test_write_query_during_cql_server_shutdown.py12
LOW…cluster/test_write_query_during_cql_server_shutdown.py17
LOW…cluster/test_write_query_during_cql_server_shutdown.py17
LOWtest/cluster/test_deprecating_cluster_features.py6
LOWtest/cluster/test_deprecating_cluster_features.py11
LOWtest/cluster/test_restart_cluster.py13
LOWtest/cluster/test_change_replication_factor_1_to_0.py12
LOWtest/cluster/test_change_replication_factor_1_to_0.py16
LOWtest/cluster/test_counter_write_timeout_metric.py14
LOWtest/cluster/conftest.py9
LOWtest/cluster/conftest.py14
LOWtest/cluster/conftest.py16
LOWtest/cluster/test_zero_token_nodes_no_replication.py6
LOWtest/cluster/test_zero_token_nodes_no_replication.py14
LOWtest/cluster/test_uninitialized_conns_semaphore.py9
LOWtest/cluster/test_rpc_compression.py11
LOWtest/cluster/test_rpc_compression.py15
LOWtest/cluster/test_rpc_compression.py21
LOWtest/cluster/test_rpc_compression.py22
LOWtest/cluster/test_tools_perf.py5
LOWtest/cluster/test_tools_perf.py7
LOW…cluster/test_gossiper_empty_self_id_on_shadow_round.py8
LOW…cluster/test_gossiper_empty_self_id_on_shadow_round.py13
LOW…t/cluster/test_start_bootstrapped_with_invalid_seed.py7
LOWtest/cluster/test_topology_smp.py15
LOW…luster/test_remove_rpc_client_with_pending_requests.py10
LOWtest/cluster/test_tablets_intranode.py6
LOWtest/cluster/test_tablets_intranode.py6
LOWtest/cluster/test_tablets_intranode.py10
LOWtest/cluster/test_tablets_intranode.py18
LOWtest/cluster/test_tablets_intranode.py19
LOWtest/cluster/test_guardrails.py9
LOWtest/cluster/test_guardrails.py16
LOWtest/cluster/test_raft_cluster_features.py15
LOWtest/cluster/test_boot_nodes.py7
LOWtest/cluster/test_remove_alive_node.py6
LOWtest/cluster/test_remove_alive_node.py8
LOWtest/cluster/test_remove_alive_node.py10
LOWtest/cluster/test_replace_with_same_ip_twice.py9
LOWtest/cluster/test_truncate_concurrent_writes.py8
LOWtest/cluster/test_truncate_concurrent_writes.py8
LOWtest/cluster/test_truncate_concurrent_writes.py12
LOWtest/cluster/test_truncate_concurrent_writes.py15
LOWtest/cluster/test_truncate_concurrent_writes.py16
LOWtest/cluster/test_truncate_concurrent_writes.py17
LOWtest/cluster/test_truncate_concurrent_writes.py18
LOWtest/cluster/test_multidc.py8
LOWtest/cluster/test_raft_voters.py9
LOWtest/cluster/test_raft_snapshot_request.py8
LOW…ter/test_sstable_compression_dictionaries_autotrain.py8
LOW…ter/test_sstable_compression_dictionaries_autotrain.py12
LOWtest/cluster/test_node_isolation.py9
LOWtest/cluster/test_node_isolation.py9
LOWtest/cluster/test_node_isolation.py9
LOWtest/cluster/test_node_isolation.py10
LOWtest/cluster/test_node_isolation.py10
LOWtest/cluster/test_node_isolation.py11
305 more matches not shown…
Self-Referential Comments93 hits · 280 pts
SeverityFileLineSnippet
MEDIUMinstall-dependencies.sh3# This file is open source software, licensed to you under the terms
MEDIUMinstall-dependencies.sh273 # Create the antlr3 wrapper script
MEDIUMtest/cluster/test_ttl_row.py87 # Create a test table with attribute "e" that will later function
MEDIUMtest/cluster/test_ttl_row.py187 # Create a test table per-row TTL on attribute "e"
MEDIUMtest/cluster/test_ttl_row.py317 # Create a test table, don't enable TTL yet to give us time to check
MEDIUMtest/cluster/test_truncate_with_tablets.py34 # Create a keyspace with tablets and initial_tablets == 2, then insert data
MEDIUMtest/cluster/test_truncate_with_tablets.py88 # Create a keyspace with tablets and initial_tablets == 2, then insert data
MEDIUMtest/cluster/test_truncate_with_tablets.py136 # Create a keyspace with tablets and initial_tablets == 2, then insert data
MEDIUMtest/cluster/test_truncate_with_tablets.py182 # Create a keyspace with tablets and initial_tablets == 2, then insert data
MEDIUMtest/cluster/test_truncate_with_tablets.py227 # Create a keyspace with tablets and initial_tablets == 2, then insert data
MEDIUMtest/cluster/test_truncate_with_tablets.py309 # Create a keyspace with tablets and initial_tablets == 2, then insert data
MEDIUMtest/cluster/test_view_build_status.py58# Create a materialized view and check that the view's build status
MEDIUMtest/cluster/test_alternator.py618 # Create a new role "user2" and make a new connection "alternator2" with it:
MEDIUMtest/cluster/test_alternator.py792 # Create a table with tablets and GSI or LSI - should fail because the keyspace is not RF-rack-valid
MEDIUMtest/cluster/test_alternator.py801 # Create a table with tablets and no indexes, then add a GSI - the update should fail
MEDIUMtest/cluster/test_alternator.py1176 # Create a new table, write 10 different items to it and then read them
MEDIUMtest/cluster/test_vnodes_to_tablets_migration.py182 # Create the table with minor compaction disabled to ensure that Scylla
MEDIUMtest/cluster/test_truncate_with_drop.py21 # Create a keyspace
MEDIUMtest/cluster/test_truncate_with_drop.py52 # Create a keyspace
MEDIUMtest/cluster/test_sstable_compression_config.py169 # Create a table with GSI, LSI and Streams
MEDIUMtest/cluster/test_audit.py1727 # Create a session with the ADMIN category disabled to validate that
MEDIUMtest/cluster/test_logstor.py194 # Create a large value of approximately 100KB, close to segment size
MEDIUMtest/cluster/test_tablets_merge.py620 # Create a table which will go through 3 merge cycles.
MEDIUMtest/cluster/test_concurrent_schema.py42 # Create a bunch of futures to run in parallel (in aws list)
MEDIUMtest/cluster/test_proxy_protocol.py199 # Create a socket and connect
MEDIUMtest/cluster/test_proxy_protocol.py631 # Create a connection that stays open
MEDIUMtest/cluster/test_vector_store.py36 # Creating a vector store index should succeed.
MEDIUMtest/cluster/test_tablets.py1929 # Create the table, insert data and flush
MEDIUMtest/cluster/test_tablets.py2320 # Create a table, which should prevent the coordinator from sleeping
MEDIUMtest/cluster/test_cdc_with_tablets.py104# Create a table with CDC, then disable CDC and drop the CDC log table, and create CDC again.
MEDIUMtest/cluster/test_cdc_with_tablets.py366# Create a CDC table with short TTL, then split the tablets to create a new stream set,
MEDIUMtest/cluster/auth_cluster/test_startup_response.py32 # Define a custom connection class that hangs on startup response
MEDIUMtest/cluster/auth_cluster/test_raft_service_levels.py334 # Create a service level and attach it to the default cassandra user
MEDIUMtest/cluster/auth_cluster/test_raft_service_levels.py646 # Create a service level and a user attached to it.
MEDIUMtest/cluster/dtest/alternator_tests.py426 # Create the table, access it through the two connections, r1 and r2:
MEDIUMtest/cluster/mv/test_mv_with_tablets_restrictions.py124 # Create a keyspace and MV/index/vector with RF=Racks
MEDIUMtest/cluster/mv/tablets/test_mv_tablets.py139 # Create a table with an LSI
MEDIUMtest/cluster/mv/tablets/test_mv_tablets.py243 # Create a table with an LSI, using tablets. Use just 1 tablets,
MEDIUMtest/alternator/test_streams.py1536 # Create an item
MEDIUMtest/alternator/test_scylla.py5# This file contains tests which check Scylla-specific features that do
MEDIUMtest/alternator/conftest.py5# This file contains "test fixtures", a pytest concept described in
MEDIUMtest/alternator/util.py113# The following function, multiset() converts the list into a multiset
MEDIUMtest/alternator/test_condition_expression.py1811 # Create an empty item with key p, but only if no item with p exists yet.
MEDIUMtest/alternator/test_condition_expression.py1832 # Create an empty item with key p, but only an item with p exists yet.
MEDIUMtest/alternator/test_encoding.py38# This file is related to issue #19770.
MEDIUMtest/alternator/test_expression_caching.py16# This file contains tests for the Alternator expression caching.
MEDIUMtest/alternator/test_compressed_response.py351# The following method, from the botocore.auth.SigV4Auth, describes how header values are normalized
MEDIUMtest/alternator/test_gsi.py409 # Create a new GSI row (x1), see that it appears
MEDIUMtest/alternator/test_gsi.py458 # Create a new GSI row (x1), see that it appears
MEDIUMtest/alternator/test_authorization.py185 # Create a new list of signed header names with the same capitalization
MEDIUMtest/alternator/test_vector.py898 # Create the table without a vector index, and add it later:
MEDIUMtest/alternator/test_cql_rbac.py61# Create a new DynamoDB API resource (connection object) similar to the
MEDIUMtest/alternator/test_lsi.py832 # Create an item with the LSI key column 'b' set to b1.
MEDIUMtest/alternator/test_lsi.py806 # Create an item with the LSI key column 'b'.
MEDIUMtest/alternator/test_lsi.py855 # Create an item with the LSI key column 'b'.
MEDIUMtest/alternator/test_lsi.py892 # Create a base table with base_keys and the two LSIs with the
MEDIUMtest/pylib/random_tables.py6"""This module provides helper classes to manage CQL tables, perform random schema changes,
MEDIUMtest/cqlpy/test_secondary_index.py109 # Creating an index should succeed, even though its default name is taken
MEDIUMtest/cqlpy/test_secondary_index.py124 # Creating an index should fail, because it's impossible to create
MEDIUMtest/cqlpy/test_secondary_index.py316 # Create an index on v as the new key. The background index-building
33 more matches not shown…
Deep Nesting360 hits · 278 pts
SeverityFileLineSnippet
LOWconfigure.py71
LOWconfigure.py255
LOWconfigure.py1997
LOWconfigure.py2418
LOWfix_system_distributed_tables.py90
LOWgen_segmented_compress_params.py92
LOWscylla-gdb.py1405
LOWscylla-gdb.py1501
LOWscylla-gdb.py352
LOWscylla-gdb.py1864
LOWscylla-gdb.py2927
LOWscylla-gdb.py3074
LOWscylla-gdb.py3941
LOWscylla-gdb.py4661
LOWscylla-gdb.py4760
LOWscylla-gdb.py4842
LOWscylla-gdb.py6534
LOWscylla-gdb.py6585
LOWidl-compiler.py1120
LOWidl-compiler.py1602
LOWidl-compiler.py1673
LOWidl-compiler.py1693
LOWtools/scyllatop/livedata.py55
LOWtest/cluster/conftest.py222
LOWtest/cluster/test_zero_token_nodes_no_replication.py19
LOWtest/cluster/test_tablets_migration.py120
LOWtest/cluster/test_tablets_migration.py187
LOWtest/cluster/test_tablets_migration.py216
LOWtest/cluster/test_alternator_proxy_protocol.py323
LOWtest/cluster/test_alternator_proxy_protocol.py337
LOWtest/cluster/util.py283
LOWtest/cluster/util.py300
LOWtest/cluster/test_guardrails.py66
LOWtest/cluster/test_tablets2.py884
LOWtest/cluster/test_tablet_repair_scheduler.py566
LOWtest/cluster/test_tablet_repair_scheduler.py608
LOWtest/cluster/test_strong_consistency.py304
LOWtest/cluster/test_alternator.py429
LOWtest/cluster/test_alternator.py905
LOWtest/cluster/test_alternator.py971
LOWtest/cluster/test_alternator.py1020
LOWtest/cluster/test_alternator.py1072
LOWtest/cluster/test_alternator.py1084
LOWtest/cluster/test_audit.py670
LOWtest/cluster/test_audit.py1420
LOWtest/cluster/test_audit.py1737
LOW…cluster/test_sstable_compression_dictionaries_basic.py367
LOW…cluster/test_sstable_compression_dictionaries_basic.py428
LOWtest/cluster/test_view_building_coordinator.py336
LOWtest/cluster/test_cdc_with_alter.py19
LOWtest/cluster/test_cdc_with_alter.py43
LOWtest/cluster/test_proxy_protocol.py522
LOWtest/cluster/test_incremental_repair.py74
LOWtest/cluster/test_incremental_repair.py287
LOWtest/cluster/test_incremental_repair.py907
LOWtest/cluster/test_size_based_load_balancing.py19
LOWtest/cluster/test_tablets.py147
LOWtest/cluster/test_encryption.py439
LOWtest/cluster/test_encryption.py449
LOWtest/cluster/object_store/test_backup.py502
300 more matches not shown…
Excessive Try-Catch Wrapping193 hits · 207 pts
SeverityFileLineSnippet
LOWfix_system_distributed_tables.py126 except Exception:
LOWfix_system_distributed_tables.py129 except Exception:
LOWtest.py216 except Exception:
LOWtest.py400 except Exception as e:
MEDIUMscylla-gdb.py820def __len__(self):
MEDIUMscylla-gdb.py2158def _no_esft_type(self):
MEDIUMscylla-gdb.py4589def __partitions(self, table):
LOWscylla-gdb.py1465 except Exception as e:
LOWscylla-gdb.py1511 except Exception as e:
LOWscylla-gdb.py2094 except Exception:
LOWscylla-gdb.py4563 except Exception as e:
LOWscylla-gdb.py4570 except Exception:
LOWscylla-gdb.py6315 except Exception as e:
LOWscylla-gdb.py6546 except Exception:
LOWtools/scyllatop/collectd.py28 except Exception as e:
MEDIUMtools/scyllatop/collectd.py24def __init__(self, socketName):
LOWtools/scyllatop/scyllatop.py38 except Exception as inst:
LOWtools/scyllatop/scyllatop.py90 except Exception as inst:
MEDIUMtools/scyllatop/scyllatop.py21def shell():
LOWtest/cluster/test_replica_exceptions.py68 except Exception:
LOWtest/cluster/test_replica_exceptions.py73 except Exception:
LOWtest/cluster/test_change_replication_factor_1_to_0.py54 except Exception as e:
LOWtest/cluster/test_counter_write_timeout_metric.py60 except Exception:
LOWtest/cluster/test_rpc_compression.py48 except Exception as e:
LOWtest/cluster/test_tools_perf.py25 except Exception as e:
LOWtest/cluster/test_internode_compression.py66 except Exception as e:
LOWtest/cluster/test_internode_compression.py91 except Exception as e:
LOWtest/cluster/test_ip_mappings.py37 except Exception:
LOWtest/cluster/util.py313 except Exception as e:
MEDIUMtest/cluster/test_tablet_repair_scheduler.py218def run_repair(state):
LOWtest/cluster/test_tablet_repair_scheduler.py222 except Exception as e:
LOWtest/cluster/test_table_drop.py127 except Exception as e:
LOWtest/cluster/test_table_drop.py138 except Exception as e:
LOWtest/cluster/test_table_drop.py170 except Exception:
LOWtest/cluster/test_strong_consistency.py1159 except Exception as e:
LOWtest/cluster/test_strong_consistency.py1165 except Exception as e:
LOWtest/cluster/test_strong_consistency.py835 except Exception as e:
LOWtest/cluster/test_strong_consistency.py876 except Exception as e:
LOWtest/cluster/test_strong_consistency.py1259 except Exception as e:
LOWtest/cluster/test_cdc_generation_data.py68 except Exception:
LOWtest/cluster/test_alternator.py426 except Exception as e:
LOWtest/cluster/test_zero_token_nodes_multidc.py67 except Exception:
LOWtest/cluster/test_topology_remove_decom.py147 except Exception as e:
LOWtest/cluster/test_audit.py511 except Exception as e:
LOWtest/cluster/test_audit.py1787 except Exception:
LOWtest/cluster/test_rest_api_on_startup.py38 except Exception as ex:
LOWtest/cluster/test_batchlog_manager.py49 except Exception as e:
LOWtest/cluster/test_batchlog_manager.py110 except Exception as e:
LOWtest/cluster/test_batchlog_manager.py173 except Exception as e:
LOWtest/cluster/test_batchlog_manager.py263 except Exception as e:
LOWtest/cluster/test_batchlog_manager.py369 except Exception as e:
LOWtest/cluster/test_cdc_with_alter.py55 except Exception as e:
LOWtest/cluster/test_cdc_with_alter.py170 except Exception as e:
LOWtest/cluster/test_proxy_protocol.py291 except Exception:
MEDIUMtest/cluster/test_incremental_repair.py58def get_repaired_at_from_sst(sst_file, scylla_path):
MEDIUMtest/cluster/test_incremental_repair.py74def get_keys_from_sst(sst_file, scylla_path):
LOWtest/cluster/test_incremental_repair.py69 except Exception as e:
LOWtest/cluster/test_incremental_repair.py90 except Exception as e:
LOWtest/cluster/test_incremental_repair.py755 except Exception as e:
LOWtest/cluster/test_incremental_repair.py1301 except Exception:
133 more matches not shown…
Cross-File Repetition39 hits · 195 pts
SeverityFileLineSnippet
HIGHtest/cluster/test_audit.py0_summary_ returns a dictionary mapping audit mode name to a sorted list of audit log, the logs are sorted by the event t
HIGHtest/cluster/test_audit.py0_summary_ returns a dictionary mapping audit mode name to a sorted list of audit log, the logs are sorted by the event t
HIGHtest/cluster/test_audit.py0_summary_ returns a dictionary mapping audit mode name to a sorted list of audit log, the logs are sorted by the event t
HIGHtest/cluster/object_store/test_backup.py0check that backing up a snapshot for a keyspace works
HIGHtest/cluster/object_store/test_backup.py0check that backing up a snapshot for a keyspace works
HIGHtest/cluster/object_store/test_backup.py0check that backing up a snapshot for a keyspace works
HIGHtest/cluster/dtest/dtest_setup.py0returns a connection after it stops throwing nohostavailables due to not being ready. if the timeout is exceeded, the ex
HIGHtest/cluster/dtest/dtest_setup.py0returns a connection after it stops throwing nohostavailables due to not being ready. if the timeout is exceeded, the ex
HIGHtest/cluster/dtest/dtest_setup.py0returns a connection after it stops throwing nohostavailables due to not being ready. if the timeout is exceeded, the ex
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/cluster/dtest/auth_test.py0originally from dtest. **description:** **expected result:**
HIGHtest/nodetool/test_repair.py0\ starting repair command #1, repairing 1 ranges for keyspace ks (parallelism=sequential, full=true) repair session 1 re
HIGHtest/nodetool/test_repair.py0\ starting repair command #1, repairing 1 ranges for keyspace ks (parallelism=sequential, full=true) repair session 1 re
HIGHtest/nodetool/test_repair.py0\ starting repair command #1, repairing 1 ranges for keyspace ks (parallelism=sequential, full=true) repair session 1 re
HIGHtest/nodetool/test_repair.py0\ starting repair command #1, repairing 1 ranges for keyspace ks (parallelism=sequential, full=true) repair session 1 re
HIGHtest/nodetool/test_repair.py0\ starting repair command #1, repairing 1 ranges for keyspace ks (parallelism=sequential, full=true) repair session 1 re
HIGHtest/nodetool/test_repair.py0\ starting repair command #1, repairing 1 ranges for keyspace ks (parallelism=sequential, full=true) repair session 1 re
HIGHtest/nodetool/test_repair.py0\ starting repair command #1, repairing 1 ranges for keyspace ks (parallelism=sequential, full=true) repair session 1 re
HIGHtest/nodetool/test_repair.py0\ starting repair command #1, repairing 1 ranges for keyspace ks (parallelism=sequential, full=true) repair session 1 re
HIGHtest/nodetool/test_cluster_repair.py0\ starting repair with task_id={id1} keyspace=ks table=table1 repair with task_id={id1} finished starting repair with ta
HIGHtest/nodetool/test_cluster_repair.py0\ starting repair with task_id={id1} keyspace=ks table=table1 repair with task_id={id1} finished starting repair with ta
HIGHtest/nodetool/test_cluster_repair.py0\ starting repair with task_id={id1} keyspace=ks table=table1 repair with task_id={id1} finished starting repair with ta
Decorative Section Separators57 hits · 154 pts
SeverityFileLineSnippet
MEDIUMtest/cluster/test_change_rpc_address.py49 # ----------
MEDIUMtest/cluster/test_change_rpc_address.py72 # ----------
MEDIUMtest/cluster/test_incremental_repair.py1133# ----------------------------------------------------------------------------
MEDIUMtest/cluster/test_incremental_repair.py1165# ----------------------------------------------------------------------------
MEDIUMtest/pylib/skip_types.py49# ── Convenience wrappers ────────────────────────────────────────────────
MEDIUMtest/dist_test/test_coredump_setup.py13# ---------------------------------------------------------------------------
MEDIUMtest/dist_test/test_coredump_setup.py16# ---------------------------------------------------------------------------
MEDIUMtest/cqlpy/test_describe.py716# -----------------------------------------------------------------------------
MEDIUMtest/cqlpy/test_describe.py3327### ===========================================================================
MEDIUMtest/cqlpy/test_describe.py843# -----------------------------------------------------------------------------
MEDIUMtest/cqlpy/test_describe.py1552### ---------------------------------------------------------------------------
MEDIUMtest/cqlpy/test_describe.py1731### ===========================================================================
MEDIUMtest/cqlpy/test_vector_search_rescoring_with_mock.py24# ---------------------------------------------------------------------------
MEDIUMtest/cqlpy/test_vector_search_rescoring_with_mock.py26# ---------------------------------------------------------------------------
MEDIUMtest/cqlpy/test_vector_search_rescoring_with_mock.py63# ---------------------------------------------------------------------------
MEDIUMtest/cqlpy/test_vector_search_rescoring_with_mock.py65# ---------------------------------------------------------------------------
MEDIUMtest/cqlpy/test_vector_search_rescoring_with_mock.py109# ---------------------------------------------------------------------------
MEDIUMtest/cqlpy/test_vector_search_rescoring_with_mock.py111# ---------------------------------------------------------------------------
MEDIUM…y/cassandra_tests/validation/operations/select_test.py1729 # --------------------------------------------------
MEDIUM…y/cassandra_tests/validation/operations/select_test.py1731 # --------------------------------------------------
MEDIUM…ra_tests/validation/operations/select_group_by_test.py611 # ------------------------------------
MEDIUM…ra_tests/validation/operations/select_group_by_test.py613 # ------------------------------------
MEDIUM…ra_tests/validation/operations/select_group_by_test.py739 # ------------------------------------
MEDIUM…ra_tests/validation/operations/select_group_by_test.py741 # ------------------------------------
MEDIUM…ra_tests/validation/operations/select_group_by_test.py1576 # ------------------------------------
MEDIUM…ra_tests/validation/operations/select_group_by_test.py1578 # ------------------------------------
MEDIUM…ra_tests/validation/operations/select_group_by_test.py1759 # ------------------------------------
MEDIUM…ra_tests/validation/operations/select_group_by_test.py1761 # ------------------------------------
MEDIUMscripts/compare_build_systems.py731# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py733# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py61# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py63# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py143# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py145# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py258# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py260# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py408# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py410# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py533# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py535# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py827# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py829# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py912# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py914# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py1137# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py1139# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py1168 # ── 1. Per-file compilation flags ─────────────────────────────
MEDIUMscripts/compare_build_systems.py1184 # ── 2. Link targets ───────────────────────────────────────────
MEDIUMscripts/compare_build_systems.py1200 # ── 3. Linker flags & libraries ───────────────────────────────
MEDIUMscripts/compare_build_systems.py1215 # ── 4. IDL-generated files ─────────────────────────────────────
MEDIUMscripts/compare_build_systems.py1239# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py1241# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py1347# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py1349# ═══════════════════════════════════════════════════════════════════════════
MEDIUMscripts/compare_build_systems.py1426 # ── 1. Run configure.py (all modes at once) ──────────────
MEDIUMscripts/compare_build_systems.py1440 # ── 2. Canary mode for fail-fast ──────────────────────────
MEDIUMscripts/compare_build_systems.py1519 # ── Summary ───────────────────────────────────────────────────
Hallucination Indicators11 hits · 110 pts
SeverityFileLineSnippet
CRITICALscylla-gdb.py5637 "org.apache.cassandra.db.marshal.ReversedType(org.apache.cassandra.db.marshal.LongType)"
CRITICALscylla-gdb.py5641 column_kind::clustering_key id=0 ordinal_id=1 "ck" "org.apache.cassandra.db.marshal.ReversedType(org.apache.cass
CRITICALtest/cluster/auth_cluster/test_prepared_metadata_id.py36_TEXT_MAP_TYPE = f"org.apache.cassandra.db.marshal.MapType({_UTF8_TYPE},{_UTF8_TYPE})"
CRITICALtest/alternator/test_system_tables.py138 is_ssl = dynamodb.meta.client._endpoint.host.startswith('https')
CRITICALtest/alternator/util.py233 return dynamodb.meta.client._endpoint.host.endswith('.amazonaws.com')
CRITICALtest/alternator/test_compressed_response.py44 dynamodb.meta.client.meta.events.register(event_name, handler)
CRITICALtest/alternator/test_compressed_response.py48 dynamodb.meta.client.meta.events.unregister(event_name, handler)
CRITICALtest/alternator/test_compressed_response.py319 dynamodb.meta.client._endpoint.http_session._manager.clear() # Exception may leave bad state in connection p
CRITICALdocs/_static/api/js/swagger-ui.min.js13this.statusText=this.req.xhr.statusText,this._setStatusProperties(this.xhr.status),this.header=this.headers=s(this.xhr.g
CRITICALdocs/_ext/scylladb_metrics.py120 return self.env.app.builder.templates.render(template, item)
CRITICALdocs/_ext/scylladb_swagger.py108 app.connect('builder-inited', lambda app: app.builder.templates.environment.globals.update(
AI Slop Vocabulary33 hits · 70 pts
SeverityFileLineSnippet
LOWtest/cluster/conftest.py323# Since connection is managed by manager just return that object
MEDIUMtest/cluster/test_table_drop.py106 # A log-based wait would be more robust but there is no dedicated log
MEDIUMtest/cluster/test_proxy_protocol.py364 # The test harness runs with --smp 2 by default
MEDIUMtest/cluster/test_proxy_protocol.py529 # The test harness runs with --smp 2 by default
LOWtest/cluster/test_encryption.py490 # connect to CQL!), so let's just use that role.
LOWtest/cluster/object_store/test_backup.py200 # If we just use {cf}/backup, files like "schema.cql" and "manifest.json" will remain after previous test
MEDIUMtest/cluster/auth_cluster/test_prepared_metadata_id.py164 # a worker thread instead of blocking the asyncio-based test harness.
LOWtest/cluster/dtest/ccmlib/scylla_node.py803 # out. let's just return an empty list for the partitions, so that
LOWtest/cluster/mv/tablets/test_mv_tablets.py33 # target_server, let's just use that.
LOWtest/alternator/conftest.py100 # connect to CQL!), so let's just use that role.
MEDIUMtest/alternator/test_update_expression.py793 # because boto3 parses a set out of the returned JSON anyway. This check should leverage
LOWtest/alternator/test_metrics.py91 # doesn't have "continue 2" so let's just set val to 0...
LOWtest/alternator/test_table.py575 # test finishes. On DynamoDB, we can't just call DeleteTable -
LOWtest/alternator/test_nested.py40# trying to use a dot in the name of the attribute, will just create one with
MEDIUMtest/alternator/test_gsi.py1176# This test is a comprehensive regression test for issue #5320, testing that
MEDIUMtest/alternator/test_limits.py61# in the aforementioned cases. Note that contrary to what the DynamoDB
MEDIUMtest/pylib/manager_client.py131 # More robust version of get_cql, when topology changes
MEDIUMtest/pylib/host_registry.py50 # pid? The pid changes between restarts, and harness does start and
LOWtest/cqlpy/run.py346# Same as run_scylla_cmd, just use SSL encryption for the CQL port (same
LOWtest/cqlpy/conftest.py120 # If tablets are not available or not enabled, we just create a regular keyspace
LOWtest/cqlpy/test_ttl_row.py68 # will just return the same error - but let's check a few types
LOWtest/cqlpy/util.py55# here does not need to be global - we can just use a simple counter to
LOWtest/cqlpy/util.py97 # we should just return False.
LOWtest/cqlpy/test_clustering_order.py60# reversed), just return results in a the reversed order.
LOWtest/cqlpy/test_unset.py200# Similar to test_unset_insert_where() above, just use an LWT write ("IF
LOWtest/cqlpy/test_wasm.py527 # doesn't have "continue 2" so let's just set val to 0...
MEDIUMtest/cqlpy/test_json.py544# This issue is also reproduced by the much more comprehensive test
MEDIUMtest/cqlpy/test_permissions.py608 # cannot update system tables, especially elevate itself to a superuser
MEDIUMtest/manual/cassandra_latest.yaml14# This version is provided to facilitate pain-free upgrades for existing
MEDIUMtest/manual/cassandra_latest.yaml1832# each write which may be lower in order to facilitate availability.
LOWtest/rest_api/conftest.py90 # If tablets are not available or not enabled, we just create a regular keyspace
MEDIUMpgo/pgo.py613# dataset by dataset name, not by function name) is to facilitate sharing of datasets between trainers.
LOWscripts/get_description.py175 # If not relative to cwd, just use the name as-is
Redundant / Tautological Comments43 hits · 61 pts
SeverityFileLineSnippet
LOWtest/cluster/test_maintenance_mode.py184 # Check if the changes made in maintenance mode are persisted
LOWtest/cluster/conftest.py250 # Check if the test has the check_nodes_for_errors marker
LOWtest/cluster/test_truncate_with_tablets.py57 # Check if we have any data
LOWtest/cluster/test_truncate_with_tablets.py164 # Check if truncate was successful
LOWtest/cluster/test_truncate_with_tablets.py209 # Check if we have any data
LOWtest/cluster/test_truncate_with_tablets.py257 # Check if we have any data
LOWtest/cluster/test_truncate_with_tablets.py337 # Check if we have any data
LOWtest/cluster/test_multidc.py236 # Check if it works if the RF doesn't change.
LOWtest/cluster/test_multidc.py268 # Check if it works if the RF doesn't change.
LOWtest/cluster/test_multidc.py274 # Check if it works if the RF doesn't change.
LOWtest/cluster/test_incremental_repair.py990 # Check if leadership transferred during the restart. Any coordinator
LOWtest/cluster/test_tablets.py1536 # Check if view building was started
LOWtest/cluster/auth_cluster/test_raft_service_levels.py313 # Check if group0 is healthy
LOWtest/alternator/test_streams.py262 # Set found_table to the table found, other_table to the one not
LOWtest/alternator/test_streams.py1503 # Set x to be a map: {'dog': 1, 'cat': 2, 'mouse': 3}.
LOWtest/alternator/test_metrics.py82 # Check if match also matches the requested labels
LOWtest/alternator/test_audit.py655 # Set audit_keyspaces to an unrelated keyspace — NOT the table's keyspace
LOWtest/alternator/test_lsi.py837 # Set b to b2 instead of b1.
LOWtest/pylib/runner.py284 # Check if this is an xdist worker
LOWtest/pylib/runner.py373 # Check if this is an xdist worker - workers should not clean up (only the main process should)
LOWtest/pylib/runner.py374 # Check if test.py has already prepared the environment, so it should clean up
LOWtest/cqlpy/test_describe.py857 # Check if name in create statement is quoted
LOWtest/cqlpy/test_describe.py861 # Check if name if keyspaces listing is quoted
LOWtest/cqlpy/test_describe.py1042 # Check if the log table exists
LOWtest/cqlpy/test_describe.py1071 # Check if base and log tables were recreated
LOWtest/cqlpy/test_uda.py248 # Check if we can use lua, i.e. we're in Scylla
LOWtest/cqlpy/test_wasm.py518 # Check if match also matches the requested labels
LOWtest/cqlpy/cassandra_tests/porting.py222# Check if results is one of two possible result sets.
LOWtest/manual/cassandra_latest.yaml1241# Set sstable_preemptive_open_interval to null for disabled which is equivalent to
LOWtest/rest_api/test_repair_task.py106 # Check if task state is correct.
LOWtest/rest_api/test_compaction_task.py37 # Check if all tasks finished successfully.
LOWtest/rest_api/test_column_family.py119 # Check if index reader is closed on happy path.
LOWtest/rest_api/test_column_family.py123 # Check if index reader is closed if exception is thrown.
LOWscripts/get_description.py208 # Check if add_group and metric are on the same line
LOWscripts/pull_github_pr.sh247# Check if any changed files are in submodule directories
LOW.github/workflows/add-label-when-promoted.yaml68 # Check if a valid backport label exists
LOW.github/workflows/trigger_ci.yaml59 # Check if PR is in draft mode
LOW.github/workflows/trigger_ci.yaml62 # Check if PR has 'conflict' label
LOW.github/workflows/trigger_ci.yaml84 # Check if PR has P0 or P1 labels
LOW.github/workflows/trigger_ci.yaml91 # Check if PR already has force_on_cloud label
LOW.github/scripts/sync_labels.py90 # Check if any other P0/P1 labels remain before removing force_on_cloud
LOW.github/scripts/auto-backport.py86 if len(merge_commit.parents) > 1: # Check if this merge commit includes multiple commits
LOW.github/scripts/auto-backport.py131 # Check if the branch already exists in the remote fork
Synthetic Comment Markers4 hits · 30 pts
SeverityFileLineSnippet
HIGHidl-compiler.py53 * This is an auto-generated code, do not modify directly.
HIGHtest/alternator/test_filter_expression.py685 # as requested by ProjectionExpression. It won't include x - it was just
HIGHtest/alternator/test_query_filter.py549 # as requested by AttributesToGet. It won't include x - it was just
HIGHtest/alternator/test_cql_rbac.py1119# Test that the permissions checks for writing to system tables (as requested
Docstring Block Structure5 hits · 25 pts
SeverityFileLineSnippet
HIGHtest/pylib/coverage_utils.py238Gets the file type description from the shell `file` utility Args: f (PathLike): _description_
HIGHtest/pylib/coverage_utils.py358A function to get the binary id of an ELF file Args: path (PathLike): A path to the file who's id to extrac
HIGHtest/pylib/coverage_utils.py389Maps given files to their build ids, for paths it recursively finds elfs contained in them and maps them. Ar
HIGHtest/pylib/coverage_utils.py445For a given file (assumed to be llvm profile, either raw or indexed), get the profiled binary ids. The reason that c
HIGHtest/pylib/version_fetch_utils.py248Fetch, cache, unpack, and install a ScyllaDB release archive. The archive is resolved from either the supplied versi
Slop Phrases6 hits · 18 pts
SeverityFileLineSnippet
MEDIUMtest/cqlpy/test_compaction_strategy_validation.py21# expression, so you can use the "|" character to allow two options.
MEDIUM…assandra_tests/validation/entities/collections_test.py445# Test you can add columns in a table with collections (CASSANDrA-4982),
MEDIUMtest/manual/cassandra_latest.yaml64# initial_token allows you to specify tokens manually. While you can use it with
MEDIUMtest/manual/cassandra_latest.yaml1035# you may want to adjust max_value_size accordingly. This should be positive and less than 2048.
MEDIUMpgo/conf/scylla.yaml265# initial_token allows you to specify tokens manually. While you can use # it with
MEDIUMconf/scylla.yaml265# initial_token allows you to specify tokens manually. While you can use # it with
Verbosity Indicators11 hits · 16 pts
SeverityFileLineSnippet
LOWtest/cluster/test_tablets_lwt.py251 # Step 2: Inject paxos_error_before_save_proposal - on [n3], paxos_error_before_learn on [n2, n3],
LOWtest/cluster/test_tablets_lwt.py277 # Step 4: execute LWT on n3, n4
LOWtest/cluster/test_tablets_lwt.py382 # Step 4: New node n4 is added to replace n1.
LOWtest/alternator/test_transact.py851# transaction so we need to check if it's also recognized, and whether it
LOWtest/cqlpy/test_permissions.py944 # Step 1: Verify direct execution is blocked (sanity check)
LOWtest/cqlpy/test_permissions.py948 # Step 2: Execute via BATCH — this must fail with Unauthorized,
LOWtest/cqlpy/test_permissions.py955 # Step 3: Now execute the same prepared statement directly
LOWtest/manual/cassandra_latest.yaml1592# Step 1: Set internode_encryption=<dc|rack|all> and explicitly set optional=true. Restart all nodes
LOWtest/manual/cassandra_latest.yaml1594# Step 2: Set optional=false (or remove it) and if you generated truststores and want to use mutual
LOWtest/manual/cassandra_latest.yaml1650# Step 1: Set enabled=true and explicitly set optional=true. Restart all nodes
LOWtest/manual/cassandra_latest.yaml1652# Step 2: Set optional=false (or remove it) and if you generated truststores and want to use mutual
Example Usage Blocks1 hit · 2 pts
SeverityFileLineSnippet
LOWscripts/tablet-mon.py11# Usage:
Fake / Example Data2 hits · 1 pts
SeverityFileLineSnippet
LOWtest/cluster/dtest/tools/assertions.py23 assert_all(session, "SELECT * FROM test", [[1, 'John Doe'], [2, 'Jane Doe'], [3, 'Alex Smith']])
LOWtest/cluster/dtest/tools/assertions.py23 assert_all(session, "SELECT * FROM test", [[1, 'John Doe'], [2, 'Jane Doe'], [3, 'Alex Smith']])