Distributed PostgreSQL as an extension
This report summarizes scanner evidence for citusdata/citus, a C project with 12,838 GitHub stars. SynthScan examined 514,810 lines of code across 1975 source files, recording 414 pattern matches distributed across 14 syntactic categories. The legacy adjusted pattern signal is 1.0 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.
Can maintainers explain intent, assumptions, and trade-offs? 387 finding(s).
Are imports declared and package/API names verified? 8 finding(s).
Are wrappers, guards, and repeated structures necessary? 57 finding(s).
Which changes need focused human review? 414 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 414 distinct pattern matches across 14 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | autogen.sh | 1 | #!/bin/bash | COMMENT |
| LOW | ci/check_migration_files.sh | 1 | #! /bin/bash | COMMENT |
| LOW | ci/banned.h.sh | 1 | #!/bin/bash | COMMENT |
| LOW | ci/banned.h.sh | 21 | # Required banned from banned.h. These functions are not allowed to be used at | COMMENT |
| LOW | ci/disallow_c_comments_in_migrations.sh | 21 | # */ -> `` (empty string) | COMMENT |
| LOW | ci/remove_useless_declarations.sh | 1 | #!/bin/bash | COMMENT |
| LOW | .github/workflows/build_and_test.yml | 421 | COMMENT | |
| LOW | .github/workflows/nightly_arm64.yml | 1 | name: Nightly arm64 | COMMENT |
| LOW | src/test/regress/pg_regress_multi.pl | 1 | #!/usr/bin/perl -w | COMMENT |
| LOW | …/test/regress/citus_tests/query_generator/query_gen.py | 21 | # on the query via the context. | COMMENT |
| LOW | …/test/regress/citus_tests/query_generator/query_gen.py | 41 | # | COMMENT |
| LOW | …/test/regress/citus_tests/query_generator/query_gen.py | 61 | # Limit | COMMENT |
| LOW | …/test/regress/citus_tests/query_generator/query_gen.py | 81 | # CteRte -> 'randomCteName()' | COMMENT |
| LOW | …st/test_shard_move_no_replica_identity_helper_index.py | 121 | # The slot's snapshot is what the initial copy uses, so once it exists any | COMMENT |
| LOW | src/include/pg_version_compat.h | 21 | /* | COMMENT |
| LOW | src/include/pg_version_compat.h | 321 | ) | COMMENT |
| LOW | src/include/pg_version_compat.h | 341 | #include "catalog/pg_foreign_data_wrapper.h" | COMMENT |
| LOW | src/include/pg_version_compat.h | 721 | * It was introduced in PostgreSQL 18, so provide a fallback for older versions. | COMMENT |
| LOW | src/include/columnar/columnar_tableam.h | 1 | #ifndef COLUMNAR_TABLEAM_H | COMMENT |
| LOW | src/include/columnar/columnar.h | 21 | #include "storage/bufpage.h" | COMMENT |
| LOW | src/include/columnar/columnar.h | 41 | COMMENT | |
| LOW | src/include/distributed/multi_logical_optimizer.h | 21 | COMMENT | |
| LOW | src/include/distributed/multi_physical_planner.h | 21 | #include "datatype/timestamp.h" | COMMENT |
| LOW | src/include/distributed/metadata_utility.h | 21 | #include "access/tupdesc.h" | COMMENT |
| LOW | src/include/distributed/pg_dist_partition.h | 41 | /* ---------------- | COMMENT |
| LOW | src/include/distributed/pg_dist_rebalance_strategy.h | 41 | COMMENT | |
| LOW | src/include/distributed/worker_protocol.h | 21 | #include "lib/stringinfo.h" | COMMENT |
| LOW | src/include/distributed/pg_dist_colocation.h | 41 | #define Anum_pg_dist_colocation_shardcount 2 | COMMENT |
| LOW | src/include/distributed/shard_rebalancer.h | 41 | */ | COMMENT |
| LOW | src/include/distributed/pg_dist_background_task.h | 21 | #define Anum_pg_dist_background_task_owner 3 | COMMENT |
| LOW | src/include/distributed/pg_dist_placement.h | 41 | * compiler constants for pg_dist_placement | COMMENT |
| LOW | src/include/distributed/pg_dist_background_job.h | 21 | #define Anum_pg_dist_background_job_job_type 3 | COMMENT |
| LOW | src/include/distributed/pg_dist_node.h | 21 | * pg_dist_node changes. | COMMENT |
| LOW | src/include/distributed/pg_dist_cleanup.h | 21 | #define Anum_pg_dist_cleanup_record_id 1 | COMMENT |
| LOW | src/backend/columnar/columnar_customscan.c | 21 | #include "catalog/pg_am.h" | COMMENT |
| LOW | src/backend/columnar/columnar_customscan.c | 41 | #include "optimizer/restrictinfo.h" | COMMENT |
| LOW | src/backend/columnar/columnar_writer.c | 21 | COMMENT | |
| LOW | src/backend/columnar/columnar_metadata.c | 21 | COMMENT | |
| LOW | src/backend/columnar/columnar_metadata.c | 41 | #include "commands/trigger.h" | COMMENT |
| LOW | src/backend/columnar/columnar_metadata.c | 181 | #define Anum_columnar_stripe_row_count 7 | COMMENT |
| LOW | src/backend/columnar/write_state_management.c | 1 | COMMENT | |
| LOW | src/backend/columnar/write_state_management.c | 21 | #include "catalog/storage.h" | COMMENT |
| LOW | src/backend/columnar/columnar_reader.c | 21 | #include "access/nbtree.h" | COMMENT |
| LOW | src/backend/columnar/columnar_tableam.c | 1 | #include <math.h> | COMMENT |
| LOW | src/backend/columnar/columnar_tableam.c | 21 | #include "catalog/pg_am.h" | COMMENT |
| LOW | src/backend/columnar/columnar_tableam.c | 41 | #include "utils/builtins.h" | COMMENT |
| LOW | src/backend/columnar/columnar.c | 21 | #include "utils/guc.h" | COMMENT |
| LOW | src/backend/distributed/shared_library_init.c | 21 | #include "fmgr.h" | COMMENT |
| LOW | src/backend/distributed/shared_library_init.c | 41 | #include "postmaster/postmaster.h" | COMMENT |
| LOW | src/backend/distributed/shared_library_init.c | 61 | #include "distributed/citus_nodefuncs.h" | COMMENT |
| LOW | src/backend/distributed/shared_library_init.c | 81 | #include "distributed/metadata_cache.h" | COMMENT |
| LOW | src/backend/distributed/shared_library_init.c | 101 | #include "distributed/remote_transaction.h" | COMMENT |
| LOW | …backend/distributed/transaction/transaction_recovery.c | 21 | #include "miscadmin.h" | COMMENT |
| LOW | …backend/distributed/transaction/transaction_recovery.c | 41 | #include "pg_version_constants.h" | COMMENT |
| LOW | …end/distributed/transaction/relation_access_tracking.c | 21 | #include "common/hashfn.h" | COMMENT |
| LOW | …ckend/distributed/transaction/transaction_management.c | 21 | #include "catalog/dependency.h" | COMMENT |
| LOW | …ckend/distributed/transaction/transaction_management.c | 41 | #include "distributed/local_executor.h" | COMMENT |
| LOW | src/backend/distributed/transaction/lock_graph.c | 21 | #include "storage/proc.h" | COMMENT |
| LOW | …c/backend/distributed/transaction/worker_transaction.c | 21 | #include "miscadmin.h" | COMMENT |
| LOW | …c/backend/distributed/transaction/remote_transaction.c | 21 | #include "access/xact.h" | COMMENT |
| 231 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | .github/workflows/codeql.yml | 36 | # Create the file repository configuration: | COMMENT |
| MEDIUM | src/test/cdc/t/004_cdc_move_shard.pl | 15 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/005_cdc_reference_table_test.pl | 15 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/005_cdc_reference_table_test.pl | 26 | # Create the reference table in the coordinator and cdc client nodes. | COMMENT |
| MEDIUM | src/test/cdc/t/010_cdc_shard_split_parallel_insert.pl | 19 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/010_cdc_shard_split_parallel_insert.pl | 27 | # Create the sensors table and ndexes. | COMMENT |
| MEDIUM | src/test/cdc/t/010_cdc_shard_split_parallel_insert.pl | 87 | # Create the distributed table concurrently in a separate thread. | COMMENT |
| MEDIUM | src/test/cdc/t/008_cdc_shard_split_test.pl | 17 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/008_cdc_shard_split_test.pl | 25 | # Create the sensors table and ndexes. | COMMENT |
| MEDIUM | …cdc/t/002_cdc_create_distributed_table_concurrently.pl | 15 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/012_cdc_restart_test.pl | 14 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/012_cdc_restart_test.pl | 19 | # Create the sensors table and ndexes. | COMMENT |
| MEDIUM | src/test/cdc/t/003_cdc_parallel_insert.pl | 18 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/003_cdc_parallel_insert.pl | 71 | # Create the distributed table concurrently in a separate thread. | COMMENT |
| MEDIUM | src/test/cdc/t/016_cdc_wal2json.pl | 16 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/006_cdc_schema_change_and_move.pl | 16 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/007_cdc_undistributed_table_test.pl | 14 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/007_cdc_undistributed_table_test.pl | 22 | # Create the sensors table and ndexes. | COMMENT |
| MEDIUM | src/test/cdc/t/001_cdc_create_distributed_table_test.pl | 14 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/001_cdc_create_distributed_table_test.pl | 19 | # Create the sensors table and ndexes. | COMMENT |
| MEDIUM | src/test/cdc/t/014_cdc_with_table_like_shard_name.pl | 16 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/cdctestlib.pm | 32 | # Define the SQL query for the first database node | COMMENT |
| MEDIUM | src/test/cdc/t/cdctestlib.pm | 36 | # Define the SQL query for the second database node | COMMENT |
| MEDIUM | src/test/cdc/t/cdctestlib.pm | 176 | # Create a Citus cluster with the given number of workers | COMMENT |
| MEDIUM | …c/test/cdc/t/013_cdc_drop_last_column_for_one_shard.pl | 16 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/009_cdc_shard_split_test_non_blocking.pl | 17 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/009_cdc_shard_split_test_non_blocking.pl | 25 | # Create the sensors table and ndexes. | COMMENT |
| MEDIUM | src/test/cdc/t/011_cdc_alter_distributed_table.pl | 18 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/cdc/t/011_cdc_alter_distributed_table.pl | 26 | # Create the sensors table and ndexes. | COMMENT |
| MEDIUM | src/test/cdc/t/015_cdc_without_citus.pl | 15 | ### Create the citus cluster with coordinator and two worker nodes | COMMENT |
| MEDIUM | src/test/regress/citus_tests/config.py | 344 | # Creating a reference table from a table referred to by a fk | COMMENT |
| MEDIUM | src/test/regress/citus_tests/test/conftest.py | 59 | # Create a dedicated schema for the test and use it by default | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/test/regress/citus_tests/config.py | 164 | def _get_and_update_next_port(self): | CODE |
| LOW | src/test/regress/citus_tests/common.py | 115 | def initialize_temp_dir_if_not_exists(temp_dir): | CODE |
| LOW | src/test/regress/citus_tests/common.py | 130 | def initialize_db_for_cluster(pg_path, rel_data_path, settings, node_names): | CODE |
| LOW | src/test/regress/citus_tests/common.py | 184 | def coordinator_should_haveshards(pg_path, port): | CODE |
| LOW | src/test/regress/citus_tests/common.py | 247 | def run_pg_regress_without_exit( | CODE |
| LOW | src/test/regress/citus_tests/common.py | 334 | def add_coordinator_to_metadata(pg_path, coordinator_port): | CODE |
| LOW | src/test/regress/citus_tests/common.py | 388 | def is_citus_set_coordinator_host_udf_exist(pg_path, port): | CODE |
| LOW | src/test/regress/citus_tests/common.py | 536 | def set_default_connection_options(self, options: dict[str, typing.Any]): | CODE |
| LOW | src/test/regress/citus_tests/common.py | 786 | def set_default_connection_options(self, options): | CODE |
| LOW | src/test/regress/citus_tests/common.py | 1037 | def create_logical_replication_slot( | CODE |
| LOW | src/test/regress/citus_tests/common.py | 1078 | def cleanup_replication_slots(self): | CODE |
| LOW | src/test/regress/citus_tests/common.py | 1266 | def set_default_connection_options(self, options): | CODE |
| LOW | src/test/regress/citus_tests/run_test.py | 417 | def run_single_citus_upgrade_test(test_name, schedule, fake_config_args): | CODE |
| LOW | src/test/regress/citus_tests/run_test.py | 440 | def run_schedule_with_multiregress(test_name, schedule, dependencies, args): | CODE |
| LOW | src/test/regress/citus_tests/run_test.py | 551 | def find_test_schedule_and_line(test_name, args): | CODE |
| LOW | src/test/regress/citus_tests/run_test.py | 659 | def schedule_line_is_upgrade_after(test_schedule_line: str) -> bool: | CODE |
| LOW | …test/regress/citus_tests/upgrade/citus_upgrade_test.py | 198 | def compare_citus_catalog_info(config, pre_upgrade): | CODE |
| LOW | …test/regress/citus_tests/upgrade/citus_upgrade_test.py | 259 | def find_compatible_udf_signature(full_args, return_type, post_signatures): | CODE |
| LOW | …test/regress/citus_tests/upgrade/citus_upgrade_test.py | 402 | def get_before_upgrade_schedule(mixed_mode): | CODE |
| LOW | …test/regress/citus_tests/upgrade/citus_upgrade_test.py | 409 | def get_after_upgrade_schedule(mixed_mode): | CODE |
| LOW | src/test/regress/citus_tests/test/test_json_copy.py | 28 | def test_json_copy_protocol_and_routing(cluster): | CODE |
| LOW | …ts/test/test_shard_move_no_replica_identity_failure.py | 32 | def test_auto_identity_move_failure_restores_source(cluster): | CODE |
| LOW | …t/regress/citus_tests/test/test_cluster_node_health.py | 74 | def set_node_connection_timeout(cluster, timeout_ms): | STRING |
| LOW | …t/regress/citus_tests/test/test_cluster_node_health.py | 100 | def test_cluster_node_health_checks_sources_concurrently(cluster): | STRING |
| LOW | …t/regress/citus_tests/test/test_cluster_node_health.py | 157 | def test_cluster_node_health_cancellation_stops_remote_checks(cluster): | STRING |
| LOW | …t/regress/citus_tests/test/test_cluster_node_health.py | 191 | def cancel_when_checks_are_in_flight(): | STRING |
| LOW | …st/test_shard_move_no_replica_identity_helper_index.py | 45 | def test_auto_identity_move_large_streamed_value_does_not_stall(cluster): | CODE |
| LOW | src/test/regress/citus_tests/test/test_run_test.py | 11 | def test_whole_schedule_line_merges_dependencies(): | CODE |
| LOW | src/test/regress/citus_tests/test/test_run_test.py | 33 | def test_merged_dependencies_include_all_requirements(): | CODE |
| LOW | src/test/regress/citus_tests/test/test_run_test.py | 55 | def test_pruning_tests_include_required_fixtures(): | CODE |
| LOW | src/test/regress/citus_tests/test/test_run_test.py | 79 | def test_follower_schedule_selects_follower_custom_target(monkeypatch): | CODE |
| LOW | src/test/regress/citus_tests/test/test_run_test.py | 109 | def test_multiuser_copy_uses_required_enterprise_setup(): | CODE |
| LOW | src/test/regress/citus_tests/test/test_run_test.py | 126 | def test_multiuser_copy_setup_precedes_repetitions(tmp_path, monkeypatch): | CODE |
| LOW | …tus_tests/arbitrary_configs/citus_arbitrary_configs.py | 128 | def copy_copy_modified_binary(datadir): | CODE |
| LOW | …tus_tests/arbitrary_configs/citus_arbitrary_configs.py | 155 | def copy_test_files_with_names(test_names, sql_dir_path, expected_dir_path, config): | CODE |
| LOW | src/backend/distributed/planner/distributed_planner.c | 2268 | * Citus function AdjustPartitioningForDistributedPlanning(). | COMMENT |
| LOW | src/backend/distributed/planner/distributed_planner.c | 2306 | * Citus function AdjustPartitioningForDistributedPlanning() | COMMENT |
| LOW | src/backend/distributed/executor/adaptive_executor.c | 2185 | * task at a time. See related function ShouldRunTasksSequentially() | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/test/regress/mitmscripts/fluent.py | 404 | except Exception as e: | CODE |
| LOW | src/test/regress/mitmscripts/fluent.py | 413 | except Exception as e: | CODE |
| LOW | src/test/regress/citus_tests/config.py | 88 | except Exception: | CODE |
| LOW | src/test/regress/citus_tests/common.py | 512 | except Exception: | CODE |
| LOW | src/test/regress/citus_tests/common.py | 884 | except Exception: | CODE |
| MEDIUM | src/test/regress/citus_tests/common.py | 881 | def start(self): | CODE |
| LOW | …t/regress/citus_tests/query_generator/config/config.py | 83 | except Exception: | CODE |
| MEDIUM | …t/regress/citus_tests/query_generator/config/config.py | 76 | def parseConfigFile(path): | CODE |
| LOW | src/test/regress/citus_tests/test/conftest.py | 75 | except Exception: | CODE |
| LOW | …ts/test/test_shard_move_no_replica_identity_failure.py | 79 | except Exception as exc: # noqa: BLE001 - terminate is expected to raise | CODE |
| MEDIUM | …ts/test/test_shard_move_no_replica_identity_failure.py | 68 | def run_move(): | CODE |
| LOW | …t/regress/citus_tests/test/test_cluster_node_health.py | 203 | except Exception as e: | STRING |
| MEDIUM | …t/regress/citus_tests/test/test_cluster_node_health.py | 191 | def cancel_when_checks_are_in_flight(): | CODE |
| LOW | …st/test_shard_move_no_replica_identity_helper_index.py | 104 | except Exception as exc: # noqa: BLE001 - a stalled move is a test failure | CODE |
| MEDIUM | …st/test_shard_move_no_replica_identity_helper_index.py | 94 | def run_move(): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | ci/include_grouping.py | 18 | CODE | |
| LOW | src/test/regress/citus_tests/config.py | 78 | CODE | |
| LOW | src/test/regress/citus_tests/common.py | 1078 | CODE | |
| LOW | src/test/regress/citus_tests/common.py | 1166 | CODE | |
| LOW | src/test/regress/citus_tests/common.py | 1200 | CODE | |
| LOW | src/test/regress/citus_tests/run_test.py | 440 | CODE | |
| LOW | src/test/regress/citus_tests/run_test.py | 551 | CODE | |
| LOW | …/test/regress/citus_tests/query_generator/query_gen.py | 361 | CODE | |
| LOW | …egress/citus_tests/query_generator/bin/diff-checker.py | 36 | CODE | |
| LOW | …test/regress/citus_tests/upgrade/citus_upgrade_test.py | 198 | CODE | |
| LOW | …test/regress/citus_tests/upgrade/citus_upgrade_test.py | 259 | CODE | |
| LOW | …t/regress/citus_tests/test/test_cluster_node_health.py | 100 | CODE | |
| LOW | …t/regress/citus_tests/test/test_cluster_node_health.py | 157 | CODE | |
| LOW | …tus_tests/arbitrary_configs/citus_arbitrary_configs.py | 133 | CODE | |
| LOW | …tus_tests/arbitrary_configs/citus_arbitrary_configs.py | 188 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | src/test/regress/mitmscripts/fluent.py | 337 | except queue.Empty: | CODE |
| HIGH | …t/regress/citus_tests/test/test_cluster_node_health.py | 53 | except OSError: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | ci/banned.h.sh | 35 | # Recommended banned from banned.h. If you can change the code not to use these | COMMENT |
| MEDIUM | ci/banned.h.sh | 45 | # Recommended banned from table on liquid. If you can change the code not to use these | COMMENT |
| LOW | src/test/regress/bin/create_test.py | 42 | print(f"Don't forget to add '{test_name}' in multi_schedule somewhere") | STRING |
| LOW | src/test/regress/citus_tests/run_test.py | 597 | # "after" tests depend. So we make sure to execute it always. | COMMENT |
| LOW | src/backend/distributed/commands/alter_table.c | 677 | * Citus keeps InTableTypeConversionFunctionCall flag. Don't forget to set it properly | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | src/test/regress/pg_regress_multi.pl | 2 | #---------------------------------------------------------------------- | COMMENT |
| MEDIUM | src/test/regress/pg_regress_multi.pl | 12 | #---------------------------------------------------------------------- | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …st/test_shard_move_no_replica_identity_helper_index.py | 141 | "SELECT s, string_agg(md5((g * 1000 + s)::text || random()::text), '') " | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .github/packaging/validate_build_output.sh | 51 | # Print the output to the console | COMMENT |
| LOW | src/test/regress/pg_regress_multi.pl | 1020 | # Set signals to shutdown servers | COMMENT |
| LOW | …test/regress/citus_tests/upgrade/citus_upgrade_test.py | 277 | # Check if the argument in post_args_list has a default value | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/test/regress/sql/pg18.sql | 1025 | VALUES(1,'John Doe','(408)-111-1234','john.doe@example.com'), | CODE |
| LOW | src/test/regress/sql/pg18.sql | 1026 | (1,'Jane Doe','(408)-111-1235','jane.doe@example.com'), | CODE |
| LOW | src/test/regress/sql/multi_metadata_sync_domain.sql | 67 | INSERT INTO dist_domain_regular_schema VALUES (1, 'user@example.com'), (2, 'admin@test.org'); | CODE |
| LOW | src/test/regress/sql/multi_metadata_sync_domain.sql | 88 | INSERT INTO dist_domain_regular_schema VALUES (11, 'user@example.com'), (12, 'admin@test.org'); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/test/regress/citus_tests/run_test.py | 2 | CODE | |
| LOW | src/test/regress/citus_tests/upgrade/__init__.py | 1 | CODE | |
| LOW | src/test/regress/citus_tests/upgrade/__init__.py | 1 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/backend/distributed/planner/distributed_planner.c | 3042 | * by an OR clause that was simplified to TRUE, we need to check if the | COMMENT |
| LOW | src/backend/distributed/utils/background_jobs.c | 1171 | * First we find all jobs that are running, we need to check if they are still running | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/test/regress/citus_tests/common.py | 1130 | # Before release 12 walreceiver just set the application name to | COMMENT |