• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

supabase / etl
81%

Build:
DEFAULT BRANCH: main
Repo Added 26 May 2025 07:39AM UTC
Files 250
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst

LAST BUILD ON BRANCH main
branch: SELECT
CHANGE BRANCH
x
  • No branch selected
  • aalexandrov/ducklake_fixed_numerics
  • aalexandrov/local_dev_commands
  • abhi/ensure-pg-14-support
  • add-backtrace-staging
  • add-bytes-metric
  • add-cargo-sort
  • add-clickhouse-timeouts
  • add-ddl-deletion
  • add-ddl-metrics
  • add-destination-metric
  • add-destination-tag-sentry
  • add-endpoint
  • add-flag
  • add-force
  • add-ipv6-support
  • add-label
  • add-latency-endpoint
  • add-log-for-not-copying
  • add-metrics
  • add-new-lag-metrics
  • add-new-script
  • add-new-tag
  • add-oriole
  • add-publication-endpoints
  • add-read-replica-support
  • add-same-limits
  • add-sentry-errors
  • add-shutdown-method
  • add-support-for-multiple-encryption
  • add-table-rename
  • add-test
  • add-test-metric
  • add-tests-edge-cases
  • add-topology-constraint
  • aksel/temporary-replication-slots
  • align-tests
  • arm
  • artyom/co-change
  • asynchronous-progress-tracking
  • attempt-fix-flaky
  • attempt-fix-lost-data
  • attempt-size-batching
  • attempt-solve-tests-failures
  • attempting-sqlx-bump
  • backfill-ids
  • backoff-bq
  • benjamincoenen/etl-534-investigate-possibility-to-add-and-remove-tables-at-runtime
  • benjamincoenen/etl-607-remove-logs
  • benjamincoenen/etl-690-ducklake-pause-trusts-unbounded-cr-status-expiry
  • benjamincoenen/etl-789-build-the-supabase-postgres-fdw-bridge-for-supabase
  • benjamincoenen/etl-832-add-validation-to-check-if-schema-and-tables-for-ducklake-in
  • benjamincoenen/etl-850-use-source-schemas-in-ducklake-and-add-schema-aware
  • benjamincoenen/etl-869-do-not-return-secrets-from-the-etl-api
  • benjamincoenen/etl-901-set-resource-defaults-per-destination-kind
  • benjamincoenen/pipe-1010-implement-better-strategy-to-get-creds-from-etl-api
  • benjamincoenen/pipe-1018-reduce-ducklake-sync-fragmentation-with-deferred-buffered
  • benjamincoenen/pipe-1047-reopen-ducklake-connections-after-inline-flush-maintenance
  • benjamincoenen/pipe-1056-update-ducklake-default-parameters-in-etl
  • benjamincoenen/pipe-1062-spike-evaluate-a-shared-embedded-duckdb-instance-for
  • benjamincoenen/pipe-1080-investigate-flaky-etl-github-actions-test
  • benjamincoenen/pipe-696-ducklake-retention-accepts-destructive-intervals
  • better-defaults
  • better-timer
  • bigquery-avro
  • bnjjj/add_inlined_data_bytes_metrics
  • bnjjj/add_pause_metrics
  • bnjjj/bounded-two-phase-shutdown
  • bnjjj/bump_duckdb
  • bnjjj/chaos_testing_xtask
  • bnjjj/clean_up_all
  • bnjjj/ducklake
  • bnjjj/ducklake-catalog-pooler
  • bnjjj/ducklake-deleted-row-rewrite
  • bnjjj/ducklake-per-batch-timeout
  • bnjjj/ducklake_better_cleanup
  • bnjjj/ducklake_catalog_maintenance
  • bnjjj/ducklake_cleaning_etl_tables
  • bnjjj/ducklake_cleanup_ddl
  • bnjjj/ducklake_ddl
  • bnjjj/ducklake_ext_maintenance_metrics
  • bnjjj/ducklake_fixes
  • bnjjj/ducklake_looogs
  • bnjjj/ducklake_optim
  • bnjjj/ducklake_pooler_catalog_url
  • bnjjj/ducklake_sorted_tables_config
  • bnjjj/enable_expire_snapshot_duck
  • bnjjj/etl_api_replicator_resource
  • bnjjj/ext_maintenance_generic
  • bnjjj/external_maintenances
  • bnjjj/fix_573
  • bnjjj/fix_622
  • bnjjj/fix_670
  • bnjjj/fix_ducklake_default_config
  • bnjjj/fix_ducklake_maintenance_runner_libpq
  • bnjjj/fix_ducklake_mismatches
  • bnjjj/fix_ipv6_sqlx_ducklake_catalog_url
  • bnjjj/fix_libpq_to_host_ipv6
  • bnjjj/hotpath_rs
  • bnjjj/improve_ducklake_maintenances
  • bnjjj/improve_ducklake_shutdown
  • bnjjj/improve_expire_snapshot_maintenance
  • bnjjj/inline_flush_maintenance
  • bnjjj/maintenance-pipeline-id-compat
  • bnjjj/migrate_actix
  • bnjjj/more_context_on_interrupts
  • bnjjj/move_metrics_connections_to_pg
  • bnjjj/pipeline_id_metrics_label
  • bnjjj/prod_defaults_ducklake
  • bnjjj/remove_batch_flush
  • bnjjj/remove_useless_clone
  • bnjjj/simplify_fix_ducklake_flush_maintenance
  • bnjjj/sync_rust_toolchain_and_msrv
  • bnjjj/upgrade_duckdb
  • bnjjj/upgrade_duckdb_2_0
  • bnjjj/warning_reuse_ducklake_schema
  • bump-bq-client
  • bump-vector
  • change-concurrency-bq
  • change-default
  • change-default-memory
  • change-limit
  • chore/assertion-guidance
  • chore/extend-clippy-lints
  • chore/iceberg-agent-scope
  • chore/match_same_arms
  • chore/remove-iceberg
  • chore/remove-legacy-stateful-set-lookup
  • chore/security-transitive-dependencies
  • chore/sim-image-override
  • chore/snowflake-daily-tests
  • chore/unused-deps
  • chore/update-github-actions-node24
  • chore/update-nextest
  • chore/update-rustfmt
  • ci-fix
  • ci-improve
  • cleanuo
  • cleanup-a-few-things
  • cleanup-deps
  • cleanup-releases
  • cleanup-rollback
  • codex/change-specs
  • codex/implement-fail-rs-for-fault-injection
  • codex/json-number-precision
  • codex/pr-991
  • codex/refresh-image-bases
  • codex/string-pipeline-id-cutover
  • codex/workload-scheduling
  • concurrency
  • connection-retry
  • debug-perf
  • debugging-issue
  • deps/bump-rust-sqlx
  • deps/kube-4
  • docs/destination-private-alpha
  • docs/public-alpha-destinations
  • durable-benchmarks
  • emit-synthetic-relation-message
  • enforce-ipv6
  • etienne/sec-666-pin-all-github-actions-to-full-commit-sha
  • experimental-iceberg-impl
  • feat/api-destination-features
  • feat/controlled-experiments
  • feat/copy-deferred-durability
  • feat/deferred-durability
  • feat/durability-age
  • feat/etl-643-snowflake-ci
  • feat/etl-identity-labels
  • feat/extend-xtask-cmds
  • feat/failover-replication-slots
  • feat/fork-ci-protection
  • feat/gated-examples
  • feat/migrate-error-email
  • feat/realtime-destination
  • feat/reject-no-metadata-tbl
  • feat/replicator-destination-features
  • feat/simulator-image-overrides
  • feat/snowflake
  • feat/snowflake-api-config
  • feat/snowflake-benchmarks
  • feat/snowflake-ci-warehouse
  • feat/snowflake-copy-deferred-durability
  • feat/snowflake-k8s
  • feat/snowflake-observability
  • feat/snowflake-partial-updates
  • feat/snowflake-validator
  • feat/streaming-deferred-durability
  • feat/test-snowflake
  • feat/xtask-destination-presets
  • figure-out-memory-leak
  • fix
  • fix-advisory
  • fix-alerts
  • fix-bench
  • fix-bigquery-batch
  • fix-bq
  • fix-bq-comments
  • fix-bq-deletion
  • fix-bq-denied
  • fix-bq-order
  • fix-bq-retries
  • fix-build-stuff
  • fix-check-slot
  • fix-ci
  • fix-ci-docker
  • fix-ci-not-working
  • fix-clickhouse-benchmark-samples
  • fix-connection
  • fix-connection-error
  • fix-core
  • fix-ddl
  • fix-deduped
  • fix-deletion-behavior
  • fix-depedency
  • fix-docker
  • fix-docker-ci
  • fix-docker-image
  • fix-docs
  • fix-docs-content
  • fix-docs-design
  • fix-ducklake
  • fix-endpoint
  • fix-endpoint-error
  • fix-endpoints
  • fix-error
  • fix-errors-returned
  • fix-etl-schema-create-race
  • fix-etl-telemetry-error-message-casing
  • fix-flaky
  • fix-fmt
  • fix-health-failures
  • fix-impl
  • fix-lag
  • fix-lib
  • fix-local-minio-images
  • fix-log-level
  • fix-lsn
  • fix-lsn-check
  • fix-lsn-relation-event
  • fix-many
  • fix-mentions
  • fix-null-parse
  • fix-nullability-bigquery
  • fix-only
  • fix-overrides-behavior
  • fix-perf-db
  • fix-permission-denied
  • fix-picker
  • fix-pipeline-update
  • fix-probing
  • fix-query
  • fix-quoting
  • fix-script
  • fix-security
  • fix-security-advisory
  • fix-security-warning
  • fix-sentry
  • fix-slow
  • fix-stall
  • fix-stalling
  • fix-stalling-test
  • fix-start
  • fix-startup
  • fix-state
  • fix-stuck
  • fix-table-mapping
  • fix-tasks
  • fix-test-flaky
  • fix-tests
  • fix-ui-docs
  • fix-update-endpoints
  • fix-url
  • fix-vpa-warmup
  • fix/add-cargo-lock
  • fix/allow-empty-publication
  • fix/apply-durability-deadline
  • fix/bench-temp-directories
  • fix/bigquery-cleanup-test
  • fix/bigquery-default-string-literals
  • fix/bigquery-oid-int64
  • fix/bigquery-test-skip
  • fix/bounded-slot-wait
  • fix/box-array-delimiter
  • fix/channel-binding
  • fix/ci-permissions-scope
  • fix/clickhouse-copy-lifecycle
  • fix/clickhouse-destination-ssrf-validation
  • fix/clickhouse-native-port-9001
  • fix/clickhouse-test-runner
  • fix/copy-concurrency-cap
  • fix/ddl-metric-labels
  • fix/dependabot-security-updates
  • fix/destination-conflict-guidance
  • fix/destination-shutdown-error
  • fix/docker-publish-provenance
  • fix/docs-concurrency
  • fix/dompurify-3.4.17
  • fix/ducklake-copy-batch-id
  • fix/ducklake-maintenance-stop-wait
  • fix/empty-tls-bundle
  • fix/env-safety
  • fix/fork-pr-notice
  • fix/graceful-k8s-failure
  • fix/h2-0.4.16-advisory
  • fix/iceberg-ns
  • fix/identity-parent-fallback-partitions-only
  • fix/idle-durability-test
  • fix/image-update-missing-target
  • fix/inheritance-copy
  • fix/init-secret-output
  • fix/keepalive-table-sync-durability
  • fix/lock-timeout
  • fix/metadata-timeouts
  • fix/no-pgpassword
  • fix/notification-config
  • fix/pages-main-only
  • fix/pipe-693-ducklake-lifecycle
  • fix/pipeline-api-error-mapping
  • fix/pipeline-single-start
  • fix/postgres-version-predicate
  • fix/preview-url-errors
  • fix/private-deploy-files
  • fix/quote-xtask-identifiers
  • fix/r10-numeric-formatting
  • fix/reduct-creds
  • fix/reject-keyless-partitioned-root
  • fix/replicator-rustflags
  • fix/retry-delay
  • fix/rustls-handshake-validation
  • fix/schema-masks-restart-test-flake
  • fix/security-audit
  • fix/snowflake-default-literals
  • fix/snowflake-deferred-streaming-durability
  • fix/snowflake-encoder-memory
  • fix/snowflake-idle-durability
  • fix/snowflake-json-null
  • fix/snowflake-recovery-barrier
  • fix/snowflake-request-packing
  • fix/snowflake-rest-identifiers
  • fix/snowflake-resync-target
  • fix/snowflake-schema-authority
  • fix/snowflake-schema-rewind
  • fix/snowflake-setup-locking
  • fix/snowflake-sql-request-id
  • fix/snowflake-truncate-recovery
  • fix/ssrf-id-validation
  • fix/table-copy-shutdown-write-race
  • fix/table-names-underscores
  • fix/table-sync-ddl-wait-flake
  • fix/table-sync-slot-lifetime
  • fix/table-sync-terminal-durability
  • fix/temporal-values
  • fix/vendored-swagger-ui
  • fix/workflow-shell-inputs
  • fix/zstd-advisories
  • flexible-name
  • general-refactor
  • implement-better-cleanup
  • implement-better-shutdown
  • implement-new-docs
  • implement-paralle-table-copy
  • implement-partitioning-cluster
  • improve-agents
  • improve-allocations
  • improve-backpressure
  • improve-backpressure-aggressiveness
  • improve-backpressure-calculation
  • improve-backpressure-new
  • improve-benchmarking
  • improve-bigquery
  • improve-billing
  • improve-bq-connection
  • improve-bq-errors
  • improve-bq-files
  • improve-bq-handling
  • improve-bq-handling-not-found
  • improve-catchup
  • improve-ci-bench
  • improve-ci-performance
  • improve-cleanaup
  • improve-code
  • improve-comments
  • improve-concurrency
  • improve-config
  • improve-connection-handling
  • improve-consistency-copy
  • improve-copy
  • improve-ddl
  • improve-ddl-defaults
  • improve-ddl-handling
  • improve-ddl-tests
  • improve-defaults
  • improve-docs
  • improve-docs-alignment
  • improve-docs-ddl
  • improve-docs-mobile
  • improve-durable-behavior
  • improve-endpoint
  • improve-error-handling
  • improve-error-messages
  • improve-errors
  • improve-idle-timeouts
  • improve-impl
  • improve-ipv6
  • improve-keep-size-estimation
  • improve-lagh
  • improve-logging-streams
  • improve-metric-tag
  • improve-metrics
  • improve-metrics-batch
  • improve-metrics-code
  • improve-name
  • improve-notify-handling
  • improve-ordering
  • improve-panioc
  • improve-parsing
  • improve-perf-after-benchmark
  • improve-pub-docs
  • improve-public-docs
  • improve-query-performance
  • improve-replica-identity
  • improve-reset
  • improve-restart
  • improve-script
  • improve-script-xtask
  • improve-script-xtask-test
  • improve-scripts
  • improve-security-vuln
  • improve-sequencing
  • improve-shutdown
  • improve-source-error
  • improve-status-update
  • improve-system
  • improve-tag
  • improve-tests
  • improve-truncation
  • improve-update
  • improve-validation
  • improve-validation-slot
  • improve-vector-size
  • improve-verifcation
  • jm/apply-retry-test-flake
  • jm/async-cdc-clickhouse
  • jm/auth-error-kinds
  • jm/avoid-deser-clones
  • jm/bench-manifest-job-id
  • jm/bigquery-deferrable-pk
  • jm/bigquery-query-table-404-retry
  • jm/bigquery-recopy-fresh-table
  • jm/bigquery-recreate-retry-budget
  • jm/bigquery-table-rename
  • jm/bump-pulldown-cmark
  • jm/bump-webpki-emsign
  • jm/chaos-cdc-workload
  • jm/chaos-copy-crash
  • jm/ci-auto-shards
  • jm/ci-coverage-16vcpu
  • jm/ci-image-target-cache
  • jm/ci-metrics
  • jm/ci-metrics-workflow
  • jm/ci-pg-queue
  • jm/ci-security-hardening
  • jm/clickhouse
  • jm/clickhouse-array-drop-not-null
  • jm/clickhouse-date-range-docs
  • jm/clickhouse-ddl-question-mark
  • jm/clickhouse-docs
  • jm/clickhouse-engine-shared-variant
  • jm/clickhouse-insert-dedup
  • jm/clickhouse-large-row-tests-v2
  • jm/clickhouse-loadtest
  • jm/clickhouse-metrics
  • jm/clickhouse-null-array-as-empty
  • jm/clickhouse-previous-replication-mask
  • jm/clickhouse-primary-key-updates
  • jm/clickhouse-proxy-5xx-retry
  • jm/clickhouse-recovery-error-wording
  • jm/clickhouse-reject-deferrable-pk
  • jm/clickhouse-reject-foreign-tables
  • jm/clickhouse-replacing-merge-tree
  • jm/clickhouse-retryable-errors
  • jm/clickhouse-schema-rewind
  • jm/clickhouse-skip-computed-columns
  • jm/clickhouse-timestamptz-default-render
  • jm/clickhouse-type-changes
  • jm/clickhouse-url
  • jm/clickhouse-user-agent
  • jm/clickhouse-utc-timestamps
  • jm/clickhouse-validation-hygiene
  • jm/clickhouse-value-proptests
  • jm/clippy-lints
  • jm/codec-fuzz-targets
  • jm/codeql-schedule
  • jm/consolidate-integration-tests
  • jm/current-view-collision
  • jm/default-cast-typmod
  • jm/default-changes-rewrite-rows
  • jm/dependency-audit-fixes
  • jm/dirty-restart-convergence
  • jm/docs-clickhouse-type-changes
  • jm/ducklake-exact-float-literals
  • jm/ducklake-full-identity-one-row
  • jm/ducklake-predicate-literals
  • jm/ducklake-redact-catalog-password
  • jm/ducklake-test-fixes
  • jm/durable-write-duration-metric
  • jm/escaping-default-literals
  • jm/etl-core
  • jm/events-count-wait
  • jm/faulty-destination-test-utils
  • jm/fix-dependency-blocks
  • jm/fix-security-audit
  • jm/fuzz-bytea-panic
  • jm/fuzz-corpus-replay
  • jm/fuzz-host-triple
  • jm/fuzz-workflow-fixups
  • jm/generalize-walsender-reconnect
  • jm/hold-response-pipeline-tests
  • jm/more-fuzz-property
  • jm/nextest
  • jm/nix
  • jm/notify-before-start
  • jm/numeric-max-weight-display
  • jm/numeric-structured-property
  • jm/per-worker-application-name
  • jm/pin-bytea-output
  • jm/pin-clickhouse-image
  • jm/read-replica-wait-diagnostics
  • jm/renaming-tables-collision
  • jm/retest-flaky-under-load
  • jm/retries-flaky-test-setup
  • jm/retry-after-schema-change
  • jm/retryability
  • jm/rustls-only-trixie
  • jm/security-maintainers
  • jm/split-clickhouse-tests
  • jm/sql-like-slots
  • jm/taskset-tests
  • jm/update-site-dependencies
  • jm/value-roundtrip-proptests
  • jm/walsender-roulette
  • jm/when-then-comment-clarifications
  • jm/xtask-no-log-test-users
  • kafaichoi/ensure-unique-per-source-and-destination-pair
  • labels-improvement
  • main
  • make-logs-less-verbose
  • make-sentry-more-secure
  • mh/ecr-action
  • migrations
  • move-arc-clone
  • move-crates
  • move-docs
  • move-to-multi-encryption
  • new-endpoints
  • new-label
  • new-metric
  • new-metrics
  • new-reset-endpoint
  • new-root-certificate
  • new-test-metric
  • or/iceberg
  • partial-configs
  • patch-replicator
  • perf/schema-lookup-clone-metrics
  • perf/snowflake-encoder-benchmark
  • perf/xtask-build-isolation
  • performance-improvements
  • pipeline-id-as-str
  • raminder/etl-148-process_syncing_tables-in-apply-loop-should-be-called-on
  • raminder/etl-150-new-table-sync-workers-keep-launching
  • ref/borrow-workers
  • ref/canonical-defaults
  • ref/centralize-etl-error-sources
  • ref/chaos-target-selection
  • ref/config-json-fixture
  • ref/copy-parser-tests
  • ref/defer-task-construction
  • ref/deploy-local-xtask
  • ref/destination-kind
  • ref/ducklake-maintenance-mode
  • ref/error-headline
  • ref/etl-528-scripts-batch
  • ref/fmt-xtask
  • ref/improve-minor-things
  • ref/init-msrv-xtask
  • ref/k8s-secret-env
  • ref/maintenance-mock-tests
  • ref/remove-end-batch
  • ref/remove-stale-modes
  • ref/secret-deserialize
  • ref/snowflake-array-serde
  • ref/snowflake-auth-pem
  • ref/snowflake-column-validation
  • ref/snowflake-default-renderer
  • ref/snowflake-example
  • ref/snowflake-payloads
  • ref/split-validator-tests
  • ref/split-validators
  • ref/table-copy-retry-tests
  • refactor/clippy-lints
  • refactor/group-destination-tests
  • refactor/stores-cloning
  • refactor/test-db-default-values
  • refine-behavior
  • release/v0.1.1
  • remove-api
  • remove-arc-table-descriptor
  • remove-duplicated-logs
  • remove-errored
  • remove-init-validation
  • remove-pipeline-id
  • remove-rollback
  • remove-taint
  • remove-waiting
  • reproduce-failure
  • response-time-slo
  • return-table-ids
  • rework-api
  • rework-apply-loop
  • rework-etl-core
  • rework-table-copy
  • riccardo/add-endpoint
  • riccardo/feat/add-replication-client
  • riccardo/feat/add-taint
  • riccardo/feat/ddl-support
  • riccardo/feat/ddl-support-2
  • riccardo/feat/ddl-support-3
  • riccardo/feat/implement-apply-loop
  • riccardo/feat/workers-structure
  • riccardo/fix-data-conversion
  • riccardo/fix/deadlock
  • riccardo/fix/do-not-remove-mappings
  • riccardo/fix/update-flush-lsn
  • riccardo/pr-503-error-handling-only
  • riccardobusetti/etl-100-allow-multiple-api-keys-from-use-by-different-clients
  • riccardobusetti/etl-104-handle-values-outside-the-range-accepted-by-bigquery
  • riccardobusetti/etl-129-set-sane-options-when-connecting-to-postgres
  • riccardobusetti/etl-141-investigate-the-possibility-to-reduce-the-number-of-error
  • riccardobusetti/etl-146-properly-handle-arraycell-option-values
  • riccardobusetti/etl-15-rename-pgdatabaseoptions-to-pgdatabaseconfig-for-sqlx
  • riccardobusetti/etl-156-find-a-solution-for-inability-to-truncate-bigquery-table
  • riccardobusetti/etl-167-implement-cascade-delete-of-postgres-replication-state
  • riccardobusetti/etl-17-create-new-types-for-oid
  • riccardobusetti/etl-174-add-tests-for-conversions
  • riccardobusetti/etl-19-implement-mechanism-to-cleanup-unused-slots-and-origins
  • riccardobusetti/etl-207-the-pipelineshutdown_and_wait-function-sometimes-returns
  • riccardobusetti/etl-210-extend-the-state-stored-in-postgres
  • riccardobusetti/etl-212-handle-failed-table-sync-workers
  • riccardobusetti/etl-214-simplify-how-a-failure-of-the-pipeline-is-exposed-to-the
  • riccardobusetti/etl-215-its-neighborly-to-re-export-types-used-in-your-public-api
  • riccardobusetti/etl-218-cleanup-unused-dependencies
  • riccardobusetti/etl-225-move-table-schemas-into-the-state-store
  • riccardobusetti/etl-232-store-table-creation-state-in-bigquery-destination
  • riccardobusetti/etl-234-write-from-scratch-the-initial-migrations-before-the-alpha
  • riccardobusetti/etl-236-add-support-for-more-types-in-the-table-schema-of-the
  • riccardobusetti/etl-240-cleanup-replication-slots-on-pipeline-deletion
  • riccardobusetti/etl-252-handle-row-errors-in-fallback-during-streaming-in-bigquery
  • riccardobusetti/etl-254-implement-mechanism-for-defaults
  • riccardobusetti/etl-257-use-gcp-bigquery-client-instead-of-our-fork
  • riccardobusetti/etl-259-force-restart-pipeline-after-starting-it
  • riccardobusetti/etl-262-handle-truncate-event-when-table-was-not-loaded
  • riccardobusetti/etl-265-handle-state-reset-properly
  • riccardobusetti/etl-266-handle-table-schema-and-table-mappings-override
  • riccardobusetti/etl-268-partitioned-tables-do-not-work-directly-due-to-lack-of-pk
  • riccardobusetti/etl-272-detect-tables-being-removed
  • riccardobusetti/etl-273-allow-filtering-logs-by-pipeline-id
  • riccardobusetti/etl-274-avoid-buildup-of-the-replication-states
  • riccardobusetti/etl-277-implement-the-backend-endpoints-for-returning-image
  • riccardobusetti/etl-283-figure-out-test-failure
  • riccardobusetti/etl-285-implement-mechanism-to-version-etl
  • riccardobusetti/etl-287-implement-batch-timeout-with-timer
  • riccardobusetti/etl-288-implement-mechanism-to-defer-shutdown-when-in-a-transaction
  • riccardobusetti/etl-289-add-taints-to-etl-resources
  • riccardobusetti/etl-290-implement-image-update-endpoint
  • riccardobusetti/etl-309-add-support-for-renaming-publication
  • riccardobusetti/etl-319-change-backoff-of-k8s
  • riccardobusetti/etl-326-improve-error-messages
  • riccardobusetti/etl-336-sample-verbose-endpoints-at-a-smaller-rate
  • riccardobusetti/etl-352-add-support-for-publication-with-subset-of-columns
  • riccardobusetti/etl-368-allow-creating-destination-tables-when-source-has-no-data
  • riccardobusetti/etl-413-add-error-notification-for-errors-in-table-sync-workers
  • riccardobusetti/etl-416-postgresql-18-support
  • riccardobusetti/etl-433-validate-correctness-before-starting-etl
  • riccardobusetti/etl-467-for-the-postgres-connection-to-the-main-api-database-do-not
  • riccardobusetti/etl-468-implement-validation-endpoint
  • riccardobusetti/etl-473-skip-to-initial-copy-data
  • riccardobusetti/etl-482-inconsistencies-in-tests-between-a-fork-and-upstream
  • riccardobusetti/etl-494-implement-graceful-handling-of-invalidated-slot
  • riccardobusetti/etl-514-create-metrics-for-the-tokio-runtime-and-expose-them
  • riccardobusetti/etl-525-implement-memory-aware-processing
  • riccardobusetti/etl-56-ensure-theres-always-exactly-one-default-image
  • riccardobusetti/etl-563-add-oriole-to-etl-ci-matrix-testing
  • riccardobusetti/etl-596-investigate-missing-keep-alives-during-shutdown
  • riccardobusetti/etl-61-handle-schema-changes-in-the-source
  • riccardobusetti/etl-636-recreate-bigquery-view-when-schema-is-updated
  • riccardobusetti/etl-66-ensure-unique-table-names-in-destinations
  • riccardobusetti/feat/add-agents-file
  • riccardobusetti/feat/add-configcat
  • riccardobusetti/feat/add-diagram
  • riccardobusetti/feat/add-error-notifications
  • riccardobusetti/feat/add-function
  • riccardobusetti/feat/add-labels
  • riccardobusetti/feat/add-memory-profiling-script
  • riccardobusetti/feat/add-more-data-to-logs
  • riccardobusetti/feat/add-more-metrics
  • riccardobusetti/feat/add-rust-docs
  • riccardobusetti/feat/add-sentry-replicator
  • riccardobusetti/feat/add-trusted
  • riccardobusetti/feat/add-update-endpoint
  • riccardobusetti/feat/arm
  • riccardobusetti/feat/better-resource-provisioning
  • riccardobusetti/feat/default-to-manual
  • riccardobusetti/feat/do-not-return-password
  • riccardobusetti/feat/emit-project-logs
  • riccardobusetti/feat/etl-docs
  • riccardobusetti/feat/expose-errors
  • riccardobusetti/feat/expose-lag
  • riccardobusetti/feat/fail-rs-setup
  • riccardobusetti/feat/implement-state-for-tables
  • riccardobusetti/feat/improve-application-name
  • riccardobusetti/feat/improve-big-query
  • riccardobusetti/feat/improve-bigquery
  • riccardobusetti/feat/improve-deletio
  • riccardobusetti/feat/improve-endpoints
  • riccardobusetti/feat/improve-errors
  • riccardobusetti/feat/improve-exports
  • riccardobusetti/feat/improve-github
  • riccardobusetti/feat/improve-k8s
  • riccardobusetti/feat/improve-logs
  • riccardobusetti/feat/improve-pipeline
  • riccardobusetti/feat/improve-readme
  • riccardobusetti/feat/improve-refresh
  • riccardobusetti/feat/improve-rx
  • riccardobusetti/feat/improve-tests
  • riccardobusetti/feat/improve-vector-flushing
  • riccardobusetti/feat/improve-version-handling
  • riccardobusetti/feat/integrate-sentry
  • riccardobusetti/feat/limit-pipelines
  • riccardobusetti/feat/log-error
  • riccardobusetti/feat/new-endpoint
  • riccardobusetti/feat/new-endpooint
  • riccardobusetti/feat/new-logo
  • riccardobusetti/feat/pre-stop-hook
  • riccardobusetti/feat/publish-rust-docs
  • riccardobusetti/feat/remove-bg-emulator
  • riccardobusetti/feat/remove-context-path
  • riccardobusetti/feat/return-key
  • riccardobusetti/feat/return-table-id
  • riccardobusetti/feat/rework-logs
  • riccardobusetti/feat/status-endpoint
  • riccardobusetti/feat/swap-image
  • riccardobusetti/feat/update-dependencies
  • riccardobusetti/feat/update-docs
  • riccardobusetti/feat/update-migration
  • riccardobusetti/feat/use-mutex
  • riccardobusetti/feat/use-secret
  • riccardobusetti/feat/use-sentry-secret
  • riccardobusetti/feat/write-docs-mkdocs
  • riccardobusetti/fix/bigquery-conversion
  • riccardobusetti/fix/ci
  • riccardobusetti/fix/config
  • riccardobusetti/fix/docker-build
  • riccardobusetti/fix/formating
  • riccardobusetti/fix/improve-ci
  • riccardobusetti/fix/improve-output
  • riccardobusetti/fix/optional-skip
  • riccardobusetti/fix/panics
  • riccardobusetti/fix/run-action
  • riccardobusetti/fix/send-more-keep-alive
  • riccardobusetti/fix/sentry-setup
  • riccardobusetti/fix/shutdown-signal
  • riccardobusetti/fix/tests-stuck
  • riccardobusetti/fix/unwrap
  • riccardobusetti/fix/workflows
  • riccardobusetti/improve
  • riccardobusetti/inject-version-env-variable
  • riccardobusetti/psql-551-fill-schema-cache-from-destination
  • riccardobusetti/psql-553-implement-bigquery-destination-v2
  • riccardobusetti/psql-557-hook-the-v2-pipeline-in-the-replicator
  • riccardobusetti/ref/change-application-name
  • riccardobusetti/ref/change-defaults
  • riccardobusetti/ref/change-endpoint
  • riccardobusetti/ref/improve
  • riccardobusetti/ref/improve-actions
  • riccardobusetti/ref/improve-exports
  • riccardobusetti/ref/improve-messages
  • riccardobusetti/ref/increase-timeout
  • riccardobusetti/ref/move-notify-state
  • riccardobusetti/ref/remove-readme-section
  • riccardobusetti/ref/rename-crates
  • riccardobusetti/ref/simplify-schema
  • rs/abort-on-panic
  • rs/add-array-support
  • rs/add-k8s-json-tests
  • rs/add-metrics-port
  • rs/add-missing-project-ref-in-logs
  • rs/add-pipeline-id-to-metrics
  • rs/add-postgres-team-as-codeowners
  • rs/add-rest-catalog-params
  • rs/add-scalar-support
  • rs/add-stopping-status
  • rs/add-update-config-endpoint
  • rs/allow-enabling-debug-logs
  • rs/api-metrics
  • rs/benchmarking
  • rs/build-mac-image
  • rs/bump-editions
  • rs/bump-iceberg-rust
  • rs/bump-local-image
  • rs/bump-max-replication-slots
  • rs/clippy-fixes
  • rs/clippy-no-deps
  • rs/db-sinks-to-destinations
  • rs/debug-stuck-tests
  • rs/docs
  • rs/egress-metric
  • rs/emit-iceberg-egress-metrics
  • rs/encrypt-s3-access-key-id
  • rs/expect-clippy
  • rs/feat/improve-logs
  • rs/fix-abort-on-panic
  • rs/fix-api-binary-name
  • rs/fix-app-env
  • rs/fix-assets
  • rs/fix-batch-sent-metric
  • rs/fix-clippy-errors
  • rs/fix-compiler-error
  • rs/fix-docker-build
  • rs/fix-failing-test
  • rs/fix-links-in-readme
  • rs/fix-panic
  • rs/fix-secrets-serialization
  • rs/fix-sentry-config
  • rs/fix-test-tracing
  • rs/fix-tests
  • rs/fix-wrong-null-values-encoding
  • rs/fix/sync-done-bug
  • rs/fix/update-config
  • rs/gh-disk-space
  • rs/iceberg-client
  • rs/iceberg-destination
  • rs/iceberg_scripts
  • rs/ignore-stuck-tests
  • rs/improve-config
  • rs/improve-connections
  • rs/improve-etl-error-macro
  • rs/improve-logging
  • rs/improve-metrics
  • rs/improve-replication-client
  • rs/init-crypto-provider
  • rs/limit-max-connections
  • rs/listen-on-all-interfaces
  • rs/make-tests-run-in-parallel-with-clippy-and-fmt
  • rs/mock-k8s-client
  • rs/no-primary-key
  • rs/one-ns-for-one-schema
  • rs/reduce-logging-in-api
  • rs/remove-array-null
  • rs/remove-duplicate-code
  • rs/remove-duplicate-config
  • rs/remove-expect
  • rs/remove-old-advisories
  • rs/remove-old-code
  • rs/remove-rustls-pemfile
  • rs/remove-unknown-types-to-bytes-feature
  • rs/remove-unused-method
  • rs/remove_double_underscores
  • rs/rename-namespaces
  • rs/rename-pg_replicate-to-supabase_etl
  • rs/rename-supabase_etl-to-etl
  • rs/renames-and-other-cleanup
  • rs/replicator-metrics
  • rs/return-conflict-error
  • rs/run-iceberg-replicator
  • rs/show-all-tables
  • rs/sinks-to-destinations
  • rs/state-store
  • rs/state-store-new
  • rs/tls-config
  • rs/toast
  • rs/tracing-in-tests
  • rs/update-api-for-iceberg-config
  • rs/update-app-labels
  • rs/update-benchmark-scripts
  • rs/update-codeowners
  • rs/use-blacksmith-docker
  • rs/use-blacksmith-runners
  • rs/use-consts
  • rs/use-orbstack-for-dev
  • scale
  • scripts/improve-k8s-check
  • sentry-debug-symbols
  • snowflake-bench-run-schema
  • sqlx-aws-lc-rs-main
  • swap-notification-endpoint
  • table-id-integer
  • test/improve-streaming-test
  • test/postgres-store-dirty-restart
  • test/snowflake-truncate-recovery-unit-tests
  • tls-in-tests
  • trail-whitespaces
  • update-allocator
  • update-billing-semantics
  • update-docker
  • update-nix-setup
  • update-params
  • update-public-docs
  • update-runner
  • upload-source-code-coveralls
  • use-cancellation-token
  • use-new-version
  • vividata-pr/opt-in-source-migrations
  • vividata-pr/serialise-first-table-creation
  • vpa

03 Nov 2026 04:29PM UTC coverage: 80.582% (+0.02%) from 80.562%
41674793996

push

github

web-flow
fix(clickhouse): increase leniency of retries on proxy 5xx errors and startup probe (#1200)

* fix(clickhouse): retry proxy 5xx error bodies

The clickhouse crate keeps the HTTP status only when an error body is
empty. A proxy that answers with its own body, such as a bare
"Bad Gateway" or an nginx error page, therefore produced a BadResponse
with neither a ClickHouse code nor a status. It was classified as
permanent and stopped replication for manual retry.

Recognize the server errors proxies commonly report in their own body,
as a bare reason phrase or a status line in an error page, and treat
them like the bare 5xx status. Redaction keeps that status, so errors
read "502 Response body omitted" instead of an opaque
"Response body omitted".

* fix(clickhouse): retry startup version probe

The engine support check runs one SELECT version() at startup under the
12 second connectivity budget. A timeout or proxy 5xx failed startup at
once, and replicators retried only through pod restarts. Prod saw this
across several pipelines in the same minutes.

Retry retryable probe failures with the shared backoff helper: four
retries with 2, 4, 8, and 16 second delays. A destination that never
answers now fails startup after up to about 90 seconds. Permanent
failures, such as a rejected login, still fail on the first attempt.
A shutdown signal still cancels startup, including the backoff sleep.

Integration tests put a proxy in front of the test ClickHouse: startup
recovers after a 502 body and fails at once on a 403 body.

34 of 35 new or added lines in 2 files covered. (97.14%)

16 existing lines in 5 files now uncovered.

60758 of 75399 relevant lines covered (80.58%)

29960.4 hits per line

Relevant lines Covered
Build:
Build:
75399 RELEVANT LINES 60758 COVERED LINES
29960.4 HITS PER LINE
Source Files on main
  • Tree
  • List 250
  • Changed 10
  • Source Changed 3
  • Coverage Changed 10
Coverage ∆ File Lines Relevant Covered Missed Hits/Line

Recent builds

Builds Branch Commit Type Ran Committer Via Coverage
41674793996 main fix(clickhouse): increase leniency of retries on proxy 5xx errors and startup probe (#1200) * fix(clickhouse): retry proxy 5xx error bodies The clickhouse crate keeps the HTTP status only when an error body is empty. A proxy that answers with it... push 03 Nov 2026 04:39PM UTC web-flow github
80.58
41671116447 codex/string-pipeline-id-cutover Merge 428741419 into 3aff53f1d Pull #1198 03 Nov 2026 04:20PM UTC web-flow github
80.49
41670980870 jm/clickhouse-proxy-5xx-retry Merge 341d6c09a into 3aff53f1d Pull #1200 03 Nov 2026 04:17PM UTC web-flow github
80.54
41667499999 fix/snowflake-recovery-barrier Merge 72fa2b1dc into 3aff53f1d Pull #1199 03 Nov 2026 03:59PM UTC web-flow github
80.66
41650142572 fix/identity-parent-fallback-partitions-only Merge ffa1dff13 into 3aff53f1d Pull #1117 03 Nov 2026 02:25PM UTC web-flow github
79.56
41650679573 bnjjj/ducklake-catalog-pooler Merge e4e885925 into 3aff53f1d Pull #1197 03 Nov 2026 02:19PM UTC web-flow github
80.92
41633848208 main feat(migration): Backfill pipeline IDs and prepare string keys (#1194) push 03 Nov 2026 12:23PM UTC web-flow github
80.56
41626089456 main refactor(config): derive secret string deserialization (#1196) push 03 Nov 2026 11:27AM UTC web-flow github
80.56
41625723959 bnjjj/ducklake-catalog-pooler Merge 204d39903 into f9928aa13 Pull #1197 03 Nov 2026 11:25AM UTC web-flow github
80.94
41619852410 backfill-ids Merge 157ef32a7 into f9928aa13 Pull #1194 03 Nov 2026 10:40AM UTC web-flow github
80.56
See All Builds (3395)
  • Repo on GitHub
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE TRIAL · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc