Neon: Serverless Postgres. We separated storage and compute to offer autoscaling, code-like database branching, and scale to zero.
1880 matches across 19 categories. Click a row to expand file-level details.
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | run_clippy.sh | 1 | #!/usr/bin/env bash |
| LOW | .config/hakari.toml | 1 | # This file contains settings for `cargo hakari`. |
| LOW | test_runner/websocket_tunnel.py | 1 | #!/usr/bin/env python3 |
| LOW | test_runner/regress/test_pg_regress.py | 61 | # 9.5) is that all the regression tests that deal with unlogged tables |
| LOW | test_runner/regress/test_tenant_relocation.py | 461 | pageserver_http.configure_failpoints(("pageserver-wal-ingest-logical-message-sleep", "off")) |
| LOW | test_runner/regress/test_tenant_relocation.py | 481 | # |
| LOW | test_runner/regress/test_tenant_relocation.py | 501 | # The bug occurs if the child branch's walreceiver runs before the |
| LOW | test_runner/regress/test_tenant_relocation.py | 521 | # put_rel_creation: |
| LOW | test_runner/regress/test_next_xid.py | 301 | # run a workload that consumes a lot of multi-XIDs until we approach that, but that |
| LOW | test_runner/regress/test_compatibility.py | 41 | # The path to the snapshot is configured by COMPATIBILITY_SNAPSHOT_DIR environment variable. |
| LOW | test_runner/regress/test_compatibility.py | 61 | # ./scripts/pytest -k test_create_snapshot |
| LOW | test_runner/regress/test_compatibility.py | 81 | # # Build previous version of binaries and store them somewhere: |
| LOW | test_runner/regress/test_compatibility.py | 101 | # export DEFAULT_PG_VERSION=17 |
| LOW | test_runner/regress/test_sharding.py | 681 | # Assert on how many reconciles happened during the process. This is something of an |
| LOW | test_runner/regress/test_sharding.py | 1481 | workload.validate() |
| LOW | test_runner/regress/test_remote_storage.py | 41 | # |
| LOW | test_runner/regress/test_timeline_detach_ancestor.py | 741 | |
| LOW | test_runner/regress/test_timeline_detach_ancestor.py | 1921 | # TEST: 1. tad which partially succeeds, one returns 500 |
| LOW | test_runner/regress/test_hot_standby.py | 121 | # in protocol version v2 two LSNs were introduced: main request_lsn (apply LSN |
| LOW | test_runner/regress/test_download_extensions.py | 261 | # when the library is used in the query. |
| LOW | test_runner/regress/test_tenant_detach.py | 141 | |
| LOW | test_runner/regress/test_tenant_detach.py | 161 | # signal to all in-progress tasks associated with the tenant. |
| LOW | test_runner/regress/test_pageserver_secondary.py | 161 | |
| LOW | test_runner/regress/test_wal_acceptor.py | 1181 | # Now recheck again flush_lsn and exit if it is good |
| LOW | test_runner/regress/test_wal_acceptor.py | 1781 | sk.http_client().timeline_digest(tenant_id, timeline_id, timeline_start_lsn, dst_flush_lsn) |
| LOW | test_runner/regress/test_branch_and_gc.py | 21 | # Consider two LSNs `lsn1` and `lsn2` with some delta files as follows: |
| LOW | test_runner/regress/test_branch_and_gc.py | 41 | # ... |
| LOW | test_runner/regress/test_branch_and_gc.py | 101 | ) |
| LOW | test_runner/regress/test_nbtree_pagesplit_cycleid.py | 81 | "DECLARE foo NO SCROLL CURSOR FOR SELECT row_number() over () FROM t ORDER BY id ASC" |
| LOW | test_runner/regress/test_nbtree_pagesplit_cycleid.py | 101 | ses3t = threading.Thread(target=vacuum_freeze_t, args=(ses3, wait_evt)) |
| LOW | test_runner/regress/test_wal_restore.py | 201 | assert restored.safe_psql("select count(*) from t", user="cloud_admin") == [(300000,)] |
| LOW | test_runner/regress/test_wal_restore.py | 221 | # superuser_name = "databricks_superuser" |
| LOW | test_runner/regress/test_wal_restore.py | 241 | # } |
| LOW | test_runner/regress/test_wal_restore.py | 261 | # test_instance_name_1, |
| LOW | test_runner/regress/test_wal_restore.py | 281 | |
| LOW | test_runner/regress/test_wal_restore.py | 301 | |
| LOW | test_runner/regress/test_replica_start.py | 341 | # The transaction in primary has not committed yet. |
| LOW | test_runner/performance/test_compaction.py | 141 | compaction_mapped_rss = after - before |
| LOW | …st_runner/performance/test_storage_controller_scale.py | 381 | f.result() |
| LOW | test_runner/performance/test_random_writes.py | 21 | env = neon_with_baseline |
| LOW | test_runner/performance/test_compute_startup.py | 21 | # `ping localhost` |
| LOW | test_runner/performance/test_compute_startup.py | 41 | endpoint = None |
| LOW | test_runner/performance/test_write_amplification.py | 1 | # Demonstrate Write Amplification with naive oldest-first layer checkpointing |
| LOW | test_runner/performance/test_write_amplification.py | 41 | cur.execute(f"create index on tbl{i} (i);") |
| LOW | …est_pageserver_max_throughput_getpage_at_latest_lsn.py | 181 | 0, 17 |
| LOW | storage_scrubber/src/lib.rs | 41 | const CLOUD_ADMIN_API_TOKEN_ENV_VAR: &str = "CLOUD_ADMIN_API_TOKEN"; |
| LOW | safekeeper/spec/modelcheck.sh | 41 | echo "" >> $outfile |
| LOW | safekeeper/src/control_file_upgrade.rs | 101 | /// of last record streamed to everyone) |
| LOW | safekeeper/src/control_file_upgrade.rs | 121 | pub proposer_uuid: PgUuid, |
| LOW | safekeeper/src/control_file_upgrade.rs | 161 | /// Since which LSN safekeeper has (had) WAL for this timeline. |
| LOW | safekeeper/src/control_file_upgrade.rs | 181 | // Peers and their state as we remember it. Knowing peers themselves is |
| LOW | safekeeper/src/control_file_upgrade.rs | 201 | /// for correctness, exists for monitoring purposes. |
| LOW | safekeeper/src/control_file_upgrade.rs | 221 | /// only by walproposer. |
| LOW | safekeeper/src/control_file_upgrade.rs | 281 | /// Unique id of the last *elected* proposer we dealt with. Not needed |
| LOW | safekeeper/src/control_file_upgrade.rs | 301 | /// walproposer proto called 'truncate_lsn'. Updates are currently drived |
| LOW | safekeeper/src/recovery.rs | 41 | let cancel = tli.cancel.clone(); |
| LOW | safekeeper/src/timeline.rs | 601 | self.cancel.cancel(); |
| LOW | safekeeper/src/timeline.rs | 641 | Ok(dir_existed) |
| LOW | safekeeper/src/pull_timeline.rs | 121 | /// Build a tokio_tar stream that sends encoded bytes into a Bytes channel. |
| LOW | safekeeper/src/pull_timeline.rs | 281 | |
| 680 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test_runner/regress/test_compute_http.py | 17 | def test_compute_no_scope_claim(neon_simple_env: NeonEnv): |
| LOW | test_runner/regress/test_compute_http.py | 50 | def test_compute_admin_scope_claim(neon_simple_env: NeonEnv, audience: str | None): |
| LOW | test_runner/regress/test_sni_router.py | 156 | def test_pg_sni_router_in_proxy( |
| LOW | …st_runner/regress/test_pageserver_metric_collection.py | 203 | def test_metric_collection_cleans_up_tempfile( |
| LOW | …st_runner/regress/test_pageserver_metric_collection.py | 329 | def iterate_pageserver_workdir(path: Path, prefix: str) -> PrefixPartitionedFiles: |
| LOW | test_runner/regress/test_pg_regress.py | 420 | def test_tx_abort_with_many_relations( |
| LOW | test_runner/regress/test_tenants_with_remote_storage.py | 102 | def test_tenants_attached_after_download(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_tenants_with_remote_storage.py | 199 | def test_tenant_redownloads_truncated_file_on_startup( |
| LOW | test_runner/regress/test_tenant_relocation.py | 148 | def switch_pg_to_new_pageserver( |
| LOW | test_runner/regress/test_tenant_relocation.py | 396 | def test_emergency_relocate_with_branches_slow_replay( |
| LOW | test_runner/regress/test_tenant_relocation.py | 550 | def test_emergency_relocate_with_branches_createdb( |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 49 | def test_min_resident_size_override_handling( |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 169 | def pageserver_start_with_disk_usage_eviction( |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 360 | def test_broken_tenants_are_skipped(eviction_env: EvictionEnv): |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 413 | def test_pageserver_evicts_until_pressure_is_relieved( |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 447 | def test_pageserver_respects_overridden_resident_size( |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 524 | def test_pageserver_falls_back_to_global_lru(eviction_env: EvictionEnv, order: EvictionOrder): |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 557 | def test_partial_evict_tenant(eviction_env: EvictionEnv, order: EvictionOrder): |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 734 | def test_statvfs_error_handling(eviction_env: EvictionEnv): |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 756 | def test_statvfs_pressure_usage(eviction_env: EvictionEnv): |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 807 | def test_statvfs_pressure_min_avail_bytes(eviction_env: EvictionEnv): |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 843 | def more_than_min_avail_bytes_freed(): |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 852 | def test_secondary_mode_eviction(eviction_env_ha: EvictionEnv): |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 900 | def test_import_timeline_disk_pressure_eviction( |
| LOW | test_runner/regress/test_pageserver_catchup.py | 13 | def test_pageserver_catchup_while_compute_down(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_next_xid.py | 287 | def test_multixid_wraparound_import( |
| LOW | test_runner/regress/test_compatibility.py | 214 | def test_backward_compatibility( |
| LOW | test_runner/regress/test_compatibility.py | 243 | def test_forward_compatibility( |
| LOW | test_runner/regress/test_compatibility.py | 506 | def test_historic_storage_formats( |
| LOW | test_runner/regress/test_pageserver_api.py | 64 | def test_pageserver_http_get_wal_receiver_not_found(neon_simple_env: NeonEnv): |
| LOW | test_runner/regress/test_pageserver_api.py | 113 | def test_pageserver_http_get_wal_receiver_success(neon_simple_env: NeonEnv): |
| LOW | test_runner/regress/test_pageserver_api.py | 132 | def test_pageserver_http_api_client(neon_simple_env: NeonEnv): |
| LOW | test_runner/regress/test_pageserver_api.py | 138 | def test_pageserver_http_api_client_auth_enabled(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_pageserver_api.py | 149 | def test_pageserver_http_index_part_force_patch(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_pageserver_api.py | 170 | def test_pageserver_get_tenant_visible_size(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_unstable_extensions.py | 12 | def test_unstable_extensions_installation(neon_simple_env: NeonEnv): |
| LOW | test_runner/regress/test_neon_cli.py | 23 | def helper_compare_timeline_list( |
| LOW | test_runner/regress/test_neon_cli.py | 69 | def helper_compare_tenant_list(pageserver_http_client: PageserverHttpClient, env: NeonEnv): |
| LOW | test_runner/regress/test_neon_cli.py | 156 | def test_cli_start_stop_multi(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_neon_cli.py | 205 | def test_parse_project_git_version_output_positive(): |
| LOW | test_runner/regress/test_neon_cli.py | 225 | def test_parse_project_git_version_output_local_docker(): |
| LOW | test_runner/regress/test_neon_cli.py | 240 | def test_binaries_version_parses(neon_binpath: Path): |
| LOW | test_runner/regress/test_layer_eviction.py | 260 | def ensure_resident_and_remote_size_metrics(): |
| LOW | test_runner/regress/test_ddl_forwarding.py | 314 | def test_ddl_forwarding_invalid_db(neon_simple_env: NeonEnv): |
| LOW | test_runner/regress/test_ddl_forwarding.py | 358 | def test_ddl_forwarding_role_specs(neon_simple_env: NeonEnv): |
| LOW | test_runner/regress/test_event_trigger_extension.py | 23 | def neon_env_builder_event_trigger_extension( |
| LOW | test_runner/regress/test_event_trigger_extension.py | 51 | def test_event_trigger_extension(neon_env_builder_event_trigger_extension: NeonEnvBuilder): |
| LOW | test_runner/regress/test_safekeeper_migration.py | 24 | def test_safekeeper_migration_simple(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_safekeeper_migration.py | 91 | def test_new_sk_set_validation(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_safekeeper_migration.py | 126 | def test_safekeeper_migration_common_set_failpoints(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_safekeeper_migration.py | 202 | def test_sk_generation_aware_tombstones(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_safekeeper_migration.py | 291 | def test_safekeeper_migration_stale_timeline(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_safekeeper_migration.py | 383 | def test_pull_from_most_advanced_sk(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_safekeeper_migration.py | 465 | def test_abort_safekeeper_migration(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_auth.py | 27 | def assert_client_not_authorized(env: NeonEnv, http_client: PageserverHttpClient): |
| LOW | test_runner/regress/test_auth.py | 75 | def test_compute_auth_to_pageserver(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_auth.py | 94 | def test_pageserver_multiple_keys(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_auth.py | 148 | def test_pageserver_key_reload(neon_env_builder: NeonEnvBuilder): |
| LOW | test_runner/regress/test_proxy_metric_collection.py | 43 | def proxy_with_metric_collector( |
| LOW | test_runner/regress/test_proxy_metric_collection.py | 80 | async def test_proxy_metric_collection( |
| 486 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | test_runner/regress/test_pageserver_secondary.py | 611 | # ============================== |
| MEDIUM | test_runner/regress/test_pageserver_secondary.py | 626 | # =================================================================== |
| MEDIUM | test_runner/regress/test_pageserver_secondary.py | 659 | # ================================================================== |
| MEDIUM | test_runner/regress/test_pageserver_secondary.py | 691 | # ======================== |
| MEDIUM | test_runner/regress/test_pageserver_secondary.py | 697 | # =================================== |
| MEDIUM | test_runner/performance/test_branching.py | 15 | # ----------------------------------------------------------------------- |
| MEDIUM | test_runner/performance/test_branching.py | 17 | # ----------------------------------------------------------------------- |
| MEDIUM | test_runner/performance/test_branching.py | 99 | # ----------------------------------------------------------------------- |
| MEDIUM | test_runner/performance/test_branching.py | 101 | # ----------------------------------------------------------------------- |
| MEDIUM | .github/workflows/random-ops-test.yml | 6 | # ┌───────────── minute (0 - 59) |
| MEDIUM | .github/workflows/random-ops-test.yml | 7 | # │ ┌───────────── hour (0 - 23) |
| MEDIUM | .github/workflows/random-ops-test.yml | 8 | # │ │ ┌───────────── day of the month (1 - 31) |
| MEDIUM | .github/workflows/random-ops-test.yml | 9 | # │ │ │ ┌───────────── month (1 - 12 or JAN-DEC) |
| MEDIUM | .github/workflows/random-ops-test.yml | 10 | # │ │ │ │ ┌───────────── day of the week (0 - 6 or SUN-SAT) |
| MEDIUM | .github/workflows/force-test-extensions-upgrade.yml | 5 | # ┌───────────── minute (0 - 59) |
| MEDIUM | .github/workflows/force-test-extensions-upgrade.yml | 6 | # │ ┌───────────── hour (0 - 23) |
| MEDIUM | .github/workflows/force-test-extensions-upgrade.yml | 7 | # │ │ ┌───────────── day of the month (1 - 31) |
| MEDIUM | .github/workflows/force-test-extensions-upgrade.yml | 8 | # │ │ │ ┌───────────── month (1 - 12 or JAN-DEC) |
| MEDIUM | .github/workflows/force-test-extensions-upgrade.yml | 9 | # │ │ │ │ ┌───────────── day of the week (0 - 6 or SUN-SAT) |
| MEDIUM | .github/workflows/ingest_benchmark.yml | 9 | # ┌───────────── minute (0 - 59) |
| MEDIUM | .github/workflows/ingest_benchmark.yml | 10 | # │ ┌───────────── hour (0 - 23) |
| MEDIUM | .github/workflows/ingest_benchmark.yml | 11 | # │ │ ┌───────────── day of the month (1 - 31) |
| MEDIUM | .github/workflows/ingest_benchmark.yml | 12 | # │ │ │ ┌───────────── month (1 - 12 or JAN-DEC) |
| MEDIUM | .github/workflows/ingest_benchmark.yml | 13 | # │ │ │ │ ┌───────────── day of the week (0 - 6 or SUN-SAT) |
| MEDIUM | .github/workflows/periodic_pagebench.yml | 6 | # ┌───────────── minute (0 - 59) |
| MEDIUM | .github/workflows/periodic_pagebench.yml | 7 | # │ ┌───────────── hour (0 - 23) |
| MEDIUM | .github/workflows/periodic_pagebench.yml | 8 | # │ │ ┌───────────── day of the month (1 - 31) |
| MEDIUM | .github/workflows/periodic_pagebench.yml | 9 | # │ │ │ ┌───────────── month (1 - 12 or JAN-DEC) |
| MEDIUM | .github/workflows/periodic_pagebench.yml | 10 | # │ │ │ │ ┌───────────── day of the week (0 - 6 or SUN-SAT) |
| MEDIUM | .github/workflows/large_oltp_growth.yml | 8 | # ┌───────────── minute (0 - 59) |
| MEDIUM | .github/workflows/large_oltp_growth.yml | 9 | # │ ┌───────────── hour (0 - 23) |
| MEDIUM | .github/workflows/large_oltp_growth.yml | 10 | # │ │ ┌───────────── day of the month (1 - 31) |
| MEDIUM | .github/workflows/large_oltp_growth.yml | 11 | # │ │ │ ┌───────────── month (1 - 12 or JAN-DEC) |
| MEDIUM | .github/workflows/large_oltp_growth.yml | 12 | # │ │ │ │ ┌───────────── day of the week (0 - 6 or SUN-SAT) |
| MEDIUM | .github/workflows/cloud-regress.yml | 5 | # ┌───────────── minute (0 - 59) |
| MEDIUM | .github/workflows/cloud-regress.yml | 6 | # │ ┌───────────── hour (0 - 23) |
| MEDIUM | .github/workflows/cloud-regress.yml | 7 | # │ │ ┌───────────── day of the month (1 - 31) |
| MEDIUM | .github/workflows/cloud-regress.yml | 8 | # │ │ │ ┌───────────── month (1 - 12 or JAN-DEC) |
| MEDIUM | .github/workflows/cloud-regress.yml | 9 | # │ │ │ │ ┌───────────── day of the week (0 - 6 or SUN-SAT) |
| MEDIUM | .github/workflows/large_oltp_benchmark.yml | 10 | # ┌───────────── minute (0 - 59) |
| MEDIUM | .github/workflows/large_oltp_benchmark.yml | 11 | # │ ┌───────────── hour (0 - 23) |
| MEDIUM | .github/workflows/large_oltp_benchmark.yml | 12 | # │ │ ┌───────────── day of the month (1 - 31) |
| MEDIUM | .github/workflows/large_oltp_benchmark.yml | 13 | # │ │ │ ┌───────────── month (1 - 12 or JAN-DEC) |
| MEDIUM | .github/workflows/large_oltp_benchmark.yml | 14 | # │ │ │ │ ┌───────────── day of the week (0 - 6 or SUN-SAT) |
| MEDIUM | .github/workflows/build_and_test_fully.yml | 6 | # ┌───────────── minute (0 - 59) |
| MEDIUM | .github/workflows/build_and_test_fully.yml | 7 | # │ ┌───────────── hour (0 - 23) |
| MEDIUM | .github/workflows/build_and_test_fully.yml | 8 | # │ │ ┌───────────── day of the month (1 - 31) |
| MEDIUM | .github/workflows/build_and_test_fully.yml | 9 | # │ │ │ ┌───────────── month (1 - 12 or JAN-DEC) |
| MEDIUM | .github/workflows/build_and_test_fully.yml | 10 | # │ │ │ │ ┌───────────── day of the week (0 - 6 or SUN-SAT) |
| MEDIUM | .github/workflows/cloud-extensions.yml | 5 | # ┌───────────── minute (0 - 59) |
| MEDIUM | .github/workflows/cloud-extensions.yml | 6 | # │ ┌───────────── hour (0 - 23) |
| MEDIUM | .github/workflows/cloud-extensions.yml | 7 | # │ │ ┌───────────── day of the month (1 - 31) |
| MEDIUM | .github/workflows/cloud-extensions.yml | 8 | # │ │ │ ┌───────────── month (1 - 12 or JAN-DEC) |
| MEDIUM | .github/workflows/cloud-extensions.yml | 9 | # │ │ │ │ ┌───────────── day of the week (0 - 6 or SUN-SAT) |
| MEDIUM | .github/workflows/benchbase_tpcc.yml | 6 | # ┌───────────── minute (0 - 59) |
| MEDIUM | .github/workflows/benchbase_tpcc.yml | 7 | # │ ┌───────────── hour (0 - 23) |
| MEDIUM | .github/workflows/benchbase_tpcc.yml | 8 | # │ │ ┌───────────── day of the month (1 - 31) |
| MEDIUM | .github/workflows/benchbase_tpcc.yml | 9 | # │ │ │ ┌───────────── month (1 - 12 or JAN-DEC) |
| MEDIUM | .github/workflows/benchbase_tpcc.yml | 10 | # │ │ │ │ ┌───────────── day of the week (0 - 6 or SUN-SAT) |
| MEDIUM | .github/workflows/pg-clients.yml | 6 | # ┌───────────── minute (0 - 59) |
| 19 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | …st_runner/regress/test_pageserver_metric_collection.py | 0 | insert into foo select g, 0, 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | …st_runner/regress/test_pageserver_metric_collection.py | 0 | insert into foo select g, 0, 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_gc_aggressive.py | 0 | insert into foo select g, 0, 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_old_request_lsn.py | 0 | select setting::int * pg_size_bytes(unit) as shared_buffers, pg_relation_size('foo') as tbl_size from pg_settings where |
| HIGH | test_runner/regress/test_bad_connection.py | 0 | select setting::int * pg_size_bytes(unit) as shared_buffers, pg_relation_size('foo') as tbl_size from pg_settings where |
| HIGH | test_runner/regress/test_bad_connection.py | 0 | select setting::int * pg_size_bytes(unit) as shared_buffers, pg_relation_size('foo') as tbl_size from pg_settings where |
| HIGH | test_runner/regress/test_bad_connection.py | 0 | select setting::int * pg_size_bytes(unit) as shared_buffers, pg_relation_size('foo') as tbl_size from pg_settings where |
| HIGH | test_runner/regress/test_change_pageserver.py | 0 | select setting::int * pg_size_bytes(unit) as shared_buffers, pg_relation_size('foo') as tbl_size from pg_settings where |
| HIGH | test_runner/regress/test_pageserver_restart.py | 0 | select setting::int * pg_size_bytes(unit) as shared_buffers, pg_relation_size('foo') as tbl_size from pg_settings where |
| HIGH | test_runner/regress/test_pageserver_restart.py | 0 | select setting::int * pg_size_bytes(unit) as shared_buffers, pg_relation_size('foo') as tbl_size from pg_settings where |
| HIGH | …nner/regress/test_walredo_not_left_behind_on_detach.py | 0 | select setting::int * pg_size_bytes(unit) as shared_buffers, pg_relation_size('foo') as tbl_size from pg_settings where |
| HIGH | test_runner/regress/test_pageserver_catchup.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 10000) g |
| HIGH | test_runner/regress/test_pageserver_catchup.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 10000) g |
| HIGH | test_runner/regress/test_timeline_size.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 10000) g |
| HIGH | test_runner/regress/test_readonly_node.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100) g |
| HIGH | test_runner/regress/test_branch_behind.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100) g |
| HIGH | test_runner/regress/test_timeline_size.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100) g |
| HIGH | test_runner/regress/test_readonly_node.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 200000) g |
| HIGH | test_runner/regress/test_readonly_node.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 200000) g |
| HIGH | test_runner/regress/test_branch_behind.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 200000) g |
| HIGH | test_runner/regress/test_branch_behind.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 200000) g |
| HIGH | test_runner/regress/test_bad_connection.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_bad_connection.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_bad_connection.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_change_pageserver.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_tenant_detach.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_pageserver_restart.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_timeline_size.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_timeline_size.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_timeline_size.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_timeline_size.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_timeline_size.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_timeline_size.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_timeline_size.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | …nner/regress/test_walredo_not_left_behind_on_detach.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_layer_writers_fail.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_layer_writers_fail.py | 0 | insert into foo select 'long string to consume some space' || g from generate_series(1, 100000) g |
| HIGH | test_runner/regress/test_logical_replication.py | 0 | insert into wal_generator (data) select repeat('a', 1024) -- generates a kilobyte of data per row from generate_series(1 |
| HIGH | test_runner/regress/test_logical_replication.py | 0 | insert into wal_generator (data) select repeat('a', 1024) -- generates a kilobyte of data per row from generate_series(1 |
| HIGH | test_runner/regress/test_logical_replication.py | 0 | insert into wal_generator (data) select repeat('a', 1024) -- generates a kilobyte of data per row from generate_series(1 |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | pre-commit.py | 3 | |
| LOW | test_runner/conftest.py | 1 | |
| LOW | test_runner/test_broken.py | 1 | |
| LOW | test_runner/regress/test_read_validation.py | 1 | |
| LOW | test_runner/regress/test_compute_http.py | 1 | |
| LOW | test_runner/regress/test_lfc_prefetch.py | 1 | |
| LOW | test_runner/regress/test_sni_router.py | 1 | |
| LOW | …st_runner/regress/test_pageserver_metric_collection.py | 1 | |
| LOW | test_runner/regress/test_pg_regress.py | 4 | |
| LOW | test_runner/regress/test_close_fds.py | 1 | |
| LOW | test_runner/regress/test_tenants_with_remote_storage.py | 9 | |
| LOW | test_runner/regress/test_ancestor_branch.py | 1 | |
| LOW | test_runner/regress/test_lfc_resize.py | 1 | |
| LOW | test_runner/regress/test_old_request_lsn.py | 1 | |
| LOW | test_runner/regress/test_prefetch_buffer_resize.py | 1 | |
| LOW | test_runner/regress/test_tenant_relocation.py | 1 | |
| LOW | test_runner/regress/test_setup.py | 3 | |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 1 | |
| LOW | test_runner/regress/test_s3_restore.py | 1 | |
| LOW | test_runner/regress/test_pageserver_catchup.py | 1 | |
| LOW | test_runner/regress/test_next_xid.py | 1 | |
| LOW | test_runner/regress/test_compatibility.py | 1 | |
| LOW | test_runner/regress/test_pageserver_api.py | 1 | |
| LOW | test_runner/regress/test_logging.py | 1 | |
| LOW | test_runner/regress/test_unstable_extensions.py | 1 | |
| LOW | test_runner/regress/test_neon_cli.py | 1 | |
| LOW | test_runner/regress/test_layer_eviction.py | 1 | |
| LOW | test_runner/regress/test_ddl_forwarding.py | 1 | |
| LOW | test_runner/regress/test_event_trigger_extension.py | 1 | |
| LOW | test_runner/regress/test_attach_tenant_config.py | 1 | |
| LOW | test_runner/regress/test_build_info_metric.py | 1 | |
| LOW | test_runner/regress/test_safekeeper_migration.py | 1 | |
| LOW | test_runner/regress/test_auth.py | 1 | |
| LOW | test_runner/regress/test_proxy_metric_collection.py | 1 | |
| LOW | test_runner/regress/test_basebackup_error.py | 1 | |
| LOW | test_runner/regress/test_timeline_gc_blocking.py | 1 | |
| LOW | test_runner/regress/test_readonly_node.py | 1 | |
| LOW | test_runner/regress/test_neon_local_cli.py | 1 | |
| LOW | …unner/regress/test_physical_and_logical_replicaiton.py | 1 | |
| LOW | test_runner/regress/test_basebackup.py | 1 | |
| LOW | test_runner/regress/test_combocid.py | 1 | |
| LOW | test_runner/regress/test_fsm_truncate.py | 1 | |
| LOW | …t_runner/regress/test_communicator_metrics_exporter.py | 1 | |
| LOW | test_runner/regress/test_layers_from_future.py | 1 | |
| LOW | test_runner/regress/test_truncate.py | 1 | |
| LOW | test_runner/regress/test_sharding.py | 1 | |
| LOW | test_runner/regress/test_multixact.py | 1 | |
| LOW | test_runner/regress/test_remote_storage.py | 1 | |
| LOW | test_runner/regress/test_recovery.py | 1 | |
| LOW | test_runner/regress/test_subscriber_restart.py | 1 | |
| LOW | test_runner/regress/test_compute_locales.py | 1 | |
| LOW | test_runner/regress/test_compute_locales.py | 8 | |
| LOW | test_runner/regress/test_compaction.py | 1 | |
| LOW | test_runner/regress/test_compute_reconfigure.py | 1 | |
| LOW | test_runner/regress/test_proxy_websockets.py | 1 | |
| LOW | test_runner/regress/test_timeline_detach_ancestor.py | 1 | |
| LOW | test_runner/regress/test_compute_termination.py | 1 | |
| LOW | test_runner/regress/test_clog_truncate.py | 1 | |
| LOW | test_runner/regress/test_tenant_tasks.py | 1 | |
| LOW | test_runner/regress/test_fullbackup.py | 1 | |
| 136 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | .config/hakari.toml | 1 | # This file contains settings for `cargo hakari`. |
| MEDIUM | test_runner/regress/test_compute_http.py | 29 | # Create an admin-scoped HTTP client |
| MEDIUM | test_runner/regress/test_compute_http.py | 65 | # Create an admin-scoped HTTP client |
| MEDIUM | test_runner/regress/test_signed_char.py | 43 | # Create a test table |
| MEDIUM | test_runner/regress/test_signed_char.py | 45 | # Create a GIN based index |
| MEDIUM | test_runner/regress/test_disk_usage_eviction.py | 869 | # Create a secondary mode location for the tenant, all tenants on one pageserver that will only |
| MEDIUM | test_runner/regress/test_compatibility.py | 594 | # Create the timeline on safekeepers manually. |
| MEDIUM | test_runner/regress/test_neon_cli.py | 50 | # Create a branch for us |
| MEDIUM | test_runner/regress/test_neon_cli.py | 54 | # Create a nested branch |
| MEDIUM | test_runner/regress/test_layer_eviction.py | 36 | # Create a number of layers in the tenant |
| MEDIUM | test_runner/regress/test_rest_broker.py | 19 | # Create the required roles for PostgREST authentication |
| MEDIUM | test_runner/regress/test_rest_broker.py | 26 | # Create the pgrst schema and configuration function required by the rest broker |
| MEDIUM | test_runner/regress/test_layers_from_future.py | 97 | # Create a number of layers in the tenant |
| MEDIUM | test_runner/regress/test_sharding.py | 1335 | # Create a tenant with secondary locations enabled |
| MEDIUM | test_runner/regress/test_sharding.py | 2060 | # Create a branch and write some data |
| MEDIUM | test_runner/regress/test_recovery.py | 35 | # Create a branch for us |
| MEDIUM | test_runner/regress/test_timeline_archive.py | 312 | # Create a branch and archive it |
| MEDIUM | test_runner/regress/test_timeline_archive.py | 772 | # Create a branch and write some additional data to the parent |
| MEDIUM | test_runner/regress/test_timeline_archive.py | 931 | # Create a branch and archive it |
| MEDIUM | test_runner/regress/test_timeline_archive.py | 1046 | # Create a branch and archive it |
| MEDIUM | test_runner/regress/test_timeline_archive.py | 1163 | # Create a branch |
| MEDIUM | test_runner/regress/test_branching.py | 284 | # Create a timeline whose creation will succeed. The tenant will need at least one |
| MEDIUM | test_runner/regress/test_branching.py | 290 | # Create a timeline whose upload to remote storage will be blocked |
| MEDIUM | test_runner/regress/test_gc_aggressive.py | 22 | # Create a table with {NUM_ROWS} rows, and perform {UPDATES_TO_PERFORM} random |
| MEDIUM | test_runner/regress/test_branch_behind.py | 16 | # Create a couple of branches off the main branch, at a historical point in time. |
| MEDIUM | test_runner/regress/test_subscriber_branching.py | 58 | # Create a test user to avoid using superuser |
| MEDIUM | test_runner/regress/test_createuser.py | 26 | # Create a branch |
| MEDIUM | test_runner/regress/test_wal_acceptor.py | 1520 | # Create the environment in the test-specific output dir |
| MEDIUM | test_runner/regress/test_wal_acceptor.py | 2762 | # Create a timeline and endpoint |
| MEDIUM | …_runner/regress/test_hadron_ps_connectivity_metrics.py | 55 | # Create a tenant that has one primary and one secondary. Due to primary/secondary placement constraints, |
| MEDIUM | test_runner/regress/test_twophase.py | 69 | # Create a branch with the transaction in prepared state |
| MEDIUM | test_runner/regress/test_storage_scrubber.py | 237 | # Create an extra timeline, to ensure the scrubber isn't confused by multiple timelines |
| MEDIUM | test_runner/regress/test_storage_scrubber.py | 261 | # Create a timeline after split, to ensure scrubber can handle timelines that exist in child shards but not ancestor |
| MEDIUM | test_runner/regress/test_storage_scrubber.py | 395 | # Create a second timeline so that when we delete the first one, child shards still have some content in S3. |
| MEDIUM | test_runner/regress/test_vm_bits.py | 27 | # Create a test table for a few different scenarios and freeze it to set the VM bits. |
| MEDIUM | test_runner/regress/test_vm_bits.py | 150 | # Create a test table and freeze it to set the all-frozen VM bit on all pages. |
| MEDIUM | test_runner/regress/test_vm_bits.py | 234 | # Create a test table and freeze it to set the all-frozen VM bit on all pages. |
| MEDIUM | test_runner/regress/test_backpressure.py | 105 | # Create a branch for us |
| MEDIUM | test_runner/regress/test_storage_controller.py | 384 | # Create a tenant directly via pageserver HTTP API, skipping the storage controller |
| MEDIUM | test_runner/regress/test_storage_controller.py | 2243 | # Create a second timeline to ensure that import finds both |
| MEDIUM | test_runner/regress/test_broken_timeline.py | 122 | # Creating the timeline didn't finish. The other timelines on tenant should still be present and work normally. |
| MEDIUM | test_runner/regress/test_broken_timeline.py | 174 | # Creating the timeline didn't finish. The other timelines on tenant should still be present and work normally. |
| MEDIUM | test_runner/regress/test_broken_timeline.py | 208 | # Creating the timeline didn't finish. The other timelines on tenant should still be present and work normally. |
| MEDIUM | test_runner/regress/test_tenant_delete.py | 425 | # Create an unsharded tenant. |
| MEDIUM | test_runner/regress/test_lsn_mapping.py | 292 | # Create a new branch |
| MEDIUM | test_runner/regress/test_createdropdb.py | 35 | # Create a branch |
| MEDIUM | test_runner/regress/test_relations.py | 23 | # Create a relation in v1 |
| MEDIUM | test_runner/regress/test_relations.py | 65 | # Create a relation in v2 |
| MEDIUM | test_runner/regress/test_ondemand_slru_download.py | 36 | # Create a test table |
| MEDIUM | test_runner/regress/test_ondemand_slru_download.py | 98 | # Create a test table |
| MEDIUM | test_runner/regress/test_ondemand_slru_download.py | 152 | # Create a test table |
| MEDIUM | test_runner/regress/test_replica_start.py | 87 | # Create a replica. It should start up normally, thanks to the CLOG-scanning |
| MEDIUM | test_runner/regress/test_replica_start.py | 130 | # Create a replica. It should start up normally, thanks to the CLOG-scanning |
| MEDIUM | test_runner/regress/test_replica_start.py | 212 | # Create a replica. but before that, wait for the wal to be flushed to |
| MEDIUM | test_runner/regress/test_replica_start.py | 334 | # Create a replica at this LSN |
| MEDIUM | test_runner/regress/test_replica_start.py | 472 | # Create a replica. It should start up normally, thanks to the CLOG-scanning |
| MEDIUM | test_runner/regress/test_replica_start.py | 554 | # Create a replica. It should start up normally, thanks to the CLOG-scanning |
| MEDIUM | test_runner/regress/test_replica_start.py | 629 | # Create a replica. It should start up normally, thanks to the CLOG-scanning |
| MEDIUM | test_runner/regress/test_replica_start.py | 687 | # Create a replica. It should start up normally, because of ignore policy |
| MEDIUM | test_runner/regress/test_compute_monitor.py | 30 | # Create a new database |
| 8 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test_runner/websocket_tunnel.py | 61 | except Exception as e: |
| LOW | test_runner/websocket_tunnel.py | 74 | except Exception as e: |
| LOW | test_runner/websocket_tunnel.py | 98 | except Exception as e: |
| MEDIUM | test_runner/websocket_tunnel.py | 51 | def handle_tcp_to_websocket(tcp_reader, ws): |
| MEDIUM | test_runner/websocket_tunnel.py | 65 | def handle_websocket_to_tcp(ws, tcp_writer): |
| LOW | test_runner/regress/test_disk_usage_eviction.py | 975 | except Exception: |
| LOW | test_runner/regress/test_next_xid.py | 52 | except Exception as error: |
| LOW | test_runner/regress/test_import_pgdata.py | 364 | except Exception: |
| LOW | test_runner/regress/test_import_pgdata.py | 450 | except Exception: |
| LOW | test_runner/regress/test_import_pgdata.py | 678 | except Exception as e: |
| LOW | test_runner/regress/test_import_pgdata.py | 707 | except Exception as e: |
| LOW | test_runner/regress/test_recovery.py | 62 | except Exception as err: |
| LOW | test_runner/regress/test_compute_reconfigure.py | 141 | except Exception as e: |
| LOW | test_runner/regress/test_proxy_websockets.py | 236 | except Exception as e: |
| MEDIUM | test_runner/regress/test_proxy_websockets.py | 232 | def run_tunnel(): |
| LOW | test_runner/regress/test_timeline_archive.py | 638 | except Exception as e: |
| LOW | test_runner/regress/test_large_schema.py | 57 | except Exception as error: |
| LOW | test_runner/regress/test_tenant_detach.py | 52 | except Exception as e: |
| LOW | test_runner/regress/test_physical_replication.py | 167 | except Exception as e: |
| MEDIUM | test_runner/regress/test_wal_acceptor.py | 181 | def run(self) -> None: |
| LOW | test_runner/regress/test_wal_acceptor.py | 414 | except Exception as e: |
| LOW | test_runner/regress/test_wal_acceptor.py | 1565 | except Exception as e: |
| LOW | test_runner/regress/test_wal_acceptor.py | 1649 | except Exception as e: |
| LOW | test_runner/regress/test_wal_acceptor_async.py | 381 | except Exception as e: |
| LOW | …nner/regress/test_walredo_not_left_behind_on_detach.py | 98 | except Exception as e: |
| LOW | …_runner/regress/test_hadron_ps_connectivity_metrics.py | 16 | except Exception as e: |
| LOW | test_runner/regress/test_compute_metrics.py | 287 | except Exception: |
| MEDIUM | test_runner/regress/test_compute_metrics.py | 282 | def stop(self) -> None: |
| LOW | test_runner/regress/test_storage_scrubber.py | 466 | except Exception as e: |
| LOW | test_runner/regress/test_timeline_delete.py | 513 | except Exception: |
| MEDIUM | test_runner/regress/test_timeline_delete.py | 505 | def first_call(result_queue): |
| LOW | test_runner/regress/test_tenant_conf.py | 53 | except Exception as e: |
| LOW | test_runner/regress/test_pageserver_layer_rolling.py | 102 | except Exception: |
| LOW | test_runner/regress/test_backpressure.py | 87 | except Exception as e: |
| LOW | test_runner/regress/test_backpressure.py | 145 | except Exception as e: |
| MEDIUM | test_runner/regress/test_storage_controller.py | 3179 | def passed_split_abort(): |
| LOW | test_runner/regress/test_storage_controller.py | 3165 | except Exception: |
| LOW | test_runner/regress/test_storage_controller.py | 3185 | except Exception: |
| LOW | test_runner/regress/test_storage_controller.py | 3345 | except Exception: |
| LOW | test_runner/regress/test_wal_receiver.py | 53 | except Exception as e: |
| LOW | test_runner/regress/test_wal_receiver.py | 74 | except Exception as e: |
| MEDIUM | test_runner/regress/test_wal_receiver.py | 50 | def all_sks_in_wareceiver_state(): |
| MEDIUM | test_runner/regress/test_wal_receiver.py | 71 | def all_but_stopped_sks_in_wareceiver_state(): |
| LOW | test_runner/performance/test_ingest_insert_bulk.py | 101 | except Exception as e: |
| LOW | test_runner/performance/test_wal_backpressure.py | 283 | except Exception as err: |
| LOW | …/performance/test_cumulative_statistics_persistence.py | 219 | except Exception as e: |
| LOW | test_runner/performance/test_physical_replication.py | 134 | except Exception as e: |
| LOW | test_runner/performance/test_physical_replication.py | 319 | except Exception as e: |
| MEDIUM | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 29 | print(f"Error: Summary JSON file not found: {json_file_path}") |
| MEDIUM | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 32 | print(f"Error: Invalid JSON in file {json_file_path}: {e}") |
| MEDIUM | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 35 | print(f"Error loading JSON file {json_file_path}: {e}") |
| MEDIUM | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 260 | print(f"Error: CSV file not found: {csv_file_path}") |
| MEDIUM | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 263 | print(f"Error processing CSV file {csv_file_path}: {e}") |
| MEDIUM | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 223 | print(f"Error: Missing required columns in CSV: {missing_columns}") |
| MEDIUM | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 344 | print(f"Error parsing load log file {log_file_path}: {e}") |
| MEDIUM | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 445 | print(f"Error: Summary JSON file does not exist: {args.summary_json}") |
| MEDIUM | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 449 | print("Error: Either summary JSON or load log file must be provided") |
| LOW | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 34 | except Exception as e: |
| MEDIUM | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 159 | print(f"Error inserting metrics into database: {e}") |
| LOW | …e_tpc_c_helpers/upload_results_to_perf_test_results.py | 262 | except Exception as e: |
| 20 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …st_runner/regress/test_pageserver_metric_collection.py | 36 | |
| LOW | test_runner/regress/test_tenant_relocation.py | 46 | |
| LOW | test_runner/regress/test_next_xid.py | 23 | |
| LOW | test_runner/regress/test_compatibility.py | 405 | |
| LOW | test_runner/regress/test_layer_eviction.py | 158 | |
| LOW | test_runner/regress/test_ddl_forwarding.py | 34 | |
| LOW | test_runner/regress/test_import_pgdata.py | 498 | |
| LOW | test_runner/regress/test_import_pgdata.py | 619 | |
| LOW | test_runner/regress/test_sharding.py | 887 | |
| LOW | test_runner/regress/test_recovery.py | 16 | |
| LOW | test_runner/regress/test_timeline_detach_ancestor.py | 79 | |
| LOW | test_runner/regress/test_timeline_detach_ancestor.py | 1214 | |
| LOW | test_runner/regress/test_compute_termination.py | 100 | |
| LOW | test_runner/regress/test_timeline_archive.py | 417 | |
| LOW | test_runner/regress/test_timeline_archive.py | 510 | |
| LOW | test_runner/regress/test_hot_standby.py | 22 | |
| LOW | test_runner/regress/test_hot_standby.py | 132 | |
| LOW | test_runner/regress/test_neon_extension.py | 41 | |
| LOW | test_runner/regress/test_large_schema.py | 20 | |
| LOW | test_runner/regress/test_tenant_detach.py | 184 | |
| LOW | test_runner/regress/test_tenant_detach.py | 194 | |
| LOW | test_runner/regress/test_physical_replication.py | 16 | |
| LOW | test_runner/regress/test_physical_replication.py | 52 | |
| LOW | test_runner/regress/test_safekeeper_deletion.py | 150 | |
| LOW | test_runner/regress/test_safekeeper_deletion.py | 175 | |
| LOW | test_runner/regress/test_pageserver_secondary.py | 78 | |
| LOW | test_runner/regress/test_pageserver_secondary.py | 165 | |
| LOW | test_runner/regress/test_wal_acceptor.py | 496 | |
| LOW | test_runner/regress/test_timeline_size.py | 74 | |
| LOW | test_runner/regress/test_timeline_size.py | 155 | |
| LOW | test_runner/regress/test_wal_acceptor_async.py | 311 | |
| LOW | test_runner/regress/test_backpressure.py | 28 | |
| LOW | test_runner/regress/test_backpressure.py | 103 | |
| LOW | test_runner/regress/test_tenant_size.py | 685 | |
| LOW | test_runner/regress/test_storage_controller.py | 3553 | |
| LOW | test_runner/regress/test_storage_controller.py | 3970 | |
| LOW | test_runner/regress/test_tenants.py | 454 | |
| LOW | test_runner/regress/test_tenants.py | 486 | |
| LOW | test_runner/logical_repl/test_debezium.py | 120 | |
| LOW | test_runner/random_ops/test_random_ops.py | 433 | |
| LOW | test_runner/performance/test_ingest_logical_message.py | 18 | |
| LOW | test_runner/performance/test_sharded_ingest.py | 18 | |
| LOW | test_runner/performance/test_ingest_insert_bulk.py | 28 | |
| LOW | test_runner/performance/test_seqscans.py | 43 | |
| LOW | test_runner/performance/test_bulk_insert.py | 22 | |
| LOW | test_runner/performance/test_copy.py | 49 | |
| LOW | test_runner/performance/test_compaction.py | 21 | |
| LOW | test_runner/performance/test_compaction.py | 67 | |
| LOW | test_runner/performance/test_hot_table.py | 22 | |
| LOW | …st_runner/performance/test_storage_controller_scale.py | 65 | |
| LOW | …_runner/performance/test_perf_ingest_using_pgcopydb.py | 163 | |
| LOW | test_runner/performance/test_physical_replication.py | 54 | |
| LOW | test_runner/performance/test_physical_replication.py | 143 | |
| LOW | test_runner/performance/test_physical_replication.py | 180 | |
| LOW | test_runner/performance/test_random_writes.py | 20 | |
| LOW | test_runner/performance/test_gist_build.py | 15 | |
| LOW | test_runner/performance/test_write_amplification.py | 23 | |
| LOW | test_runner/performance/test_logical_replication.py | 107 | |
| LOW | test_runner/performance/test_logical_replication.py | 207 | |
| LOW | test_runner/performance/test_logical_replication.py | 306 | |
| 3 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test_runner/regress/test_bad_connection.py | 46 | # shared_buffers, otherwise the SELECT after restart will just return answer |
| LOW | test_runner/regress/test_bad_connection.py | 105 | # shared_buffers, otherwise the SELECT after restart will just return answer |
| LOW | test_runner/regress/test_bad_connection.py | 207 | # shared_buffers, otherwise the SELECT after restart will just return answer |
| LOW | test_runner/regress/test_change_pageserver.py | 69 | # shared_buffers, otherwise the SELECT after restart will just return answer |
| LOW | test_runner/regress/test_tenant_detach.py | 353 | # shared_buffers, otherwise the SELECT after restart will just return answer |
| LOW | test_runner/regress/test_pageserver_restart.py | 40 | # shared_buffers, otherwise the SELECT after restart will just return answer |
| LOW | test_runner/regress/test_pageserver_restart.py | 181 | # shared_buffers, otherwise the SELECT after restart will just return answer |
| MEDIUM | test_runner/regress/test_pageserver_generations.py | 461 | # Initially, the tenant will be attached to the first pageserver (first is default in our test harness) |
| LOW | …nner/regress/test_walredo_not_left_behind_on_detach.py | 59 | # shared_buffers, otherwise the SELECT after restart will just return answer |
| MEDIUM | test_runner/regress/test_tenant_delete.py | 85 | # may need to retry on some remote storage errors injected by the test harness |
| MEDIUM | test_runner/regress/test_tenant_delete.py | 459 | # The initial tenant created by the test harness should still be there. |
| MEDIUM | test_runner/regress/test_replica_start.py | 357 | # robust even if PGPROC_MAX_CACHED_SUBXIDS changes. |
| LOW | …r/performance/pageserver/test_page_service_batching.py | 111 | # name is not a metric, we just use it to identify the test easily in the `test_...[...]`` notation |
| MEDIUM | compute_tools/src/communicator_socket_client.rs | 40 | // it would be more robust if the data directory is moved around or unlinked for |
| MEDIUM | docker-compose/docker_compose_test.sh | 106 | # We want to run the longest tests first to better utilize parallelization and reduce overall test time. |
| MEDIUM | pageserver/src/tenant/mgr.rs | 1629 | // split operation less seamless for clients, as we will may detach the parent |
| MEDIUM | pageserver/src/tenant/storage_layer.rs | 685 | /// Absolutely read [`IoConcurrency::spawn_io`] to learn about assumptions & pitfalls. |
| MEDIUM | pageserver/src/tenant/remote_timeline_client.rs | 299 | /// Behavioral modes that enable seamless live migration. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | test_runner/random_ops/README.md | 64 | NEON_API_KEY=your_api_key ./scripts/pytest test_runner/random_ops/test_random_ops.py -m remote_cluster |
| HIGH | test_runner/random_ops/README.md | 70 | RANDOM_SEED=12345 NEON_API_KEY=your_api_key ./scripts/pytest test_runner/random_ops/test_random_ops.py -m remote_cluster |
| HIGH | test_runner/random_ops/README.md | 76 | NUM_OPERATIONS=500 NEON_API_KEY=your_api_key ./scripts/pytest test_runner/random_ops/test_random_ops.py -m remote_cluste |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | test_runner/regress/test_layer_eviction.py | 193 | cur.execute("create table a (id bigserial primary key, some_value bigint not null)") |
| HIGH | test_runner/regress/test_sharding.py | 1872 | # on 2024-03-05, the default config on prod was [15MB, 10GB, null] |
| HIGH | test_runner/regress/test_timeline_detach_ancestor.py | 662 | ep.safe_psql("create table integers (i bigint not null);") |
| HIGH | test_runner/regress/test_ondemand_download.py | 606 | cur.execute("create table a (id bigserial primary key, some_value bigint not null)") |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | storage_controller/src/persistence.rs | 506 | // So we need to check if the node has lifecycle set to deleted. |
| LOW | storage_controller/src/service.rs | 9799 | // Step 1: collect all shards that we are required to migrate back to this node because their AZ preference |
| LOW | storage_controller/src/service.rs | 9850 | // Step 2: also promote any AZ-agnostic shards as required to achieve the target number of attachments |
| LOW | pageserver/src/tenant/timeline/compaction.rs | 2679 | // Step 1: split history into len(retain_lsn_below_horizon) + 2 buckets, where the last bucket is for all deltas |
| LOW | pageserver/src/tenant/timeline/compaction.rs | 2698 | // Step 2: filter out duplicated records due to the k-merge of image/delta layers |
| LOW | pageserver/src/tenant/timeline/compaction.rs | 2723 | // Step 3: generate images when necessary |
| LOW | pageserver/src/tenant/timeline/compaction.rs | 3309 | // Step 0: pick all delta layers + image layers below/intersect with the GC horizon. |
| LOW | pageserver/src/tenant/timeline/compaction.rs | 3511 | // Step 1: construct a k-merge iterator over all layers. |
| LOW | pageserver/src/tenant/timeline/compaction.rs | 3612 | // Step 2: Produce images+deltas. |
| LOW | pageserver/src/tenant/timeline/compaction.rs | 4075 | // Step 3: Place back to the layer map. |
| LOW | pageserver/src/tenant/secondary/downloader.rs | 481 | // Step 1: identify some tenants that we may work on |
| LOW | pageserver/src/tenant/secondary/downloader.rs | 488 | // Step 2: filter out tenants which are not yet elegible to run |
| LOW | pageserver/src/tenant/secondary/downloader.rs | 524 | // Step 3: sort by target execution time to run most urgent first. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test_runner/regress/test_compaction.py | 916 | # Check if there's a metric for our tenant and timeline that has value 1 |
| LOW | test_runner/regress/test_compute_termination.py | 117 | # Check if it's in expected status |
| LOW | test_runner/regress/test_compute_termination.py | 123 | # Check if process has exited |
| LOW | test_runner/regress/test_import.py | 194 | # Check if the backup data contains multiple segment files |
| LOW | test_runner/regress/test_relations.py | 53 | # Check if both relations are still accessible |
| LOW | test_runner/regress/test_relations.py | 61 | # Check if both relations are still accessible again after restart |
| LOW | test_runner/regress/test_relations.py | 73 | # Check if both relations are still accessible |
| LOW | test_runner/regress/test_relations.py | 83 | # Check if both relations are still accessible after restart |
| LOW | test_runner/regress/test_relations.py | 96 | # Check if relations are still accessible |
| LOW | test_runner/regress/test_relations.py | 113 | # Check if the relation is still accessible |
| LOW | test_runner/regress/test_feature_flag.py | 56 | # Check if the properties exist |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | storage_controller/src/service.rs | 7897 | /// Configure in-memory and persistent state of a node as requested |
| HIGH | pageserver/src/tenant/upload_queue.rs | 1350 | // For other operations, assert as requested. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …r/performance/large_synthetic_oltp/insert_webhooks.sql | 31 | '{"order_id": 987654, "customer": {"name": "John Doe", "email": "john.doe@example.com"}, "items": [{"product_id": 12 |
| LOW | …r/performance/large_synthetic_oltp/insert_webhooks.sql | 32 | '{"order_id": 987654, "customer": {"name": "John Doe", "email": "john.doe@example.com"}, "items": [{"product_id": 12 |
| LOW | …_bge_small_en_v15-src/sql/basic_functions_enhanced.sql | 4 | SELECT rag_bge_small_en_v15.chunks_by_token_count('Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusm |
| LOW | …_bge_small_en_v15-src/sql/basic_functions_enhanced.sql | 4 | SELECT rag_bge_small_en_v15.chunks_by_token_count('Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusm |
| LOW | …_small_en_v15-src/sql/embedding_functions_enhanced.sql | 6 | vector_dims(rag_bge_small_en_v15.embedding_for_passage('Lorem ipsum dolor sit amet')) > 0 AS result; |
| LOW | …_small_en_v15-src/sql/embedding_functions_enhanced.sql | 6 | vector_dims(rag_bge_small_en_v15.embedding_for_passage('Lorem ipsum dolor sit amet')) > 0 AS result; |
| LOW | …_small_en_v15-src/sql/embedding_functions_enhanced.sql | 15 | vector_dims(rag_bge_small_en_v15.embedding_for_query('Lorem ipsum dolor sit amet')) > 0 AS result; |
| LOW | …_small_en_v15-src/sql/embedding_functions_enhanced.sql | 15 | vector_dims(rag_bge_small_en_v15.embedding_for_query('Lorem ipsum dolor sit amet')) > 0 AS result; |
| LOW | …r-compose/ext-src/pgrag-src/sql/chunking_functions.sql | 4 | SELECT rag.chunks_by_character_count('Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor inc |
| LOW | …r-compose/ext-src/pgrag-src/sql/chunking_functions.sql | 4 | SELECT rag.chunks_by_character_count('Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor inc |
| Severity | File | Line | Snippet |
|---|---|---|---|
| CRITICAL | scripts/comment-test-report.js | 233 | const branchName = context.payload.pull_request.head.ref.replace(/^refs\/heads\//, "") |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | run_clippy.sh | 7 | # If your text editor has rust-analyzer integration, you can also use this new |
| LOW | libs/postgres_versioninfo/src/lib.rs | 15 | // !!! When you add a new PgMajorVersion, don't forget to update PgMajorVersion::ALL |
| MEDIUM | pageserver/src/tenant/storage_layer/layer/tests.rs | 225 | // this just updates the remote_physical_size for demonstration purposes |
| LOW | pageserver/src/virtual_file/io_engine.rs | 242 | // Don't forget to use retry_ecanceled_once |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | pageserver/src/page_cache.rs | 394 | /// Example usage: |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test_runner/regress/test_wal_acceptor.py | 2350 | def do_something(): |