supabase / etl

80%

main: 76%

LAST BUILD ON BRANCH riccardobusetti/etl-287-implement-batch-timeout-with-timer

branch: riccardobusetti/etl-287-implement-batch-timeout-with-timer

CHANGE BRANCH

x

Reset

• riccardobusetti/etl-287-implement-batch-timeout-with-timer
• abhi/ensure-pg-14-support
• add-backtrace-staging
• add-bytes-metric
• add-cargo-sort
• add-ddl-deletion
• add-ddl-metrics
• add-destination-metric
• add-destination-tag-sentry
• add-endpoint
• add-flag
• add-force
• add-label
• add-log-for-not-copying
• add-metrics
• add-new-tag
• add-oriole
• add-sentry-errors
• add-shutdown-method
• add-test
• add-test-metric
• add-topology-constraint
• arm
• artyom/co-change
• asynchronous-progress-tracking
• attempt-fix-flaky
• attempt-fix-lost-data
• attempt-size-batching
• attempt-solve-tests-failures
• backoff-bq
• better-defaults
• better-timer
• bnjjj/add_inlined_data_bytes_metrics
• bnjjj/chaos_testing_xtask
• bnjjj/ducklake
• bnjjj/ducklake_catalog_maintenance
• bnjjj/ducklake_fixes
• bnjjj/ducklake_looogs
• bnjjj/ducklake_optim
• bnjjj/etl_api_replicator_resource
• bnjjj/improve_ducklake_maintenances
• bnjjj/improve_ducklake_shutdown
• bnjjj/inline_flush_maintenance
• bnjjj/move_metrics_connections_to_pg
• bnjjj/pipeline_id_metrics_label
• bnjjj/remove_batch_flush
• bnjjj/remove_useless_clone
• bnjjj/simplify_fix_ducklake_flush_maintenance
• bnjjj/sync_rust_toolchain_and_msrv
• bump-bq-client
• change-concurrency-bq
• change-default
• change-default-memory
• change-limit
• chore/match_same_arms
• chore/unused-deps
• ci-fix
• ci-improve
• cleanuo
• cleanup-deps
• cleanup-releases
• codex/change-specs
• codex/implement-fail-rs-for-fault-injection
• concurrency
• connection-retry
• etienne/sec-666-pin-all-github-actions-to-full-commit-sha
• feat/realtime-destination
• fix
• fix-advisory
• fix-bq
• fix-bq-order
• fix-bq-retries
• fix-ci
• fix-ci-docker
• fix-connection
• fix-connection-error
• fix-core
• fix-deduped
• fix-deletion-behavior
• fix-depedency
• fix-docker
• fix-docker-ci
• fix-ducklake
• fix-endpoint
• fix-error
• fix-flaky
• fix-log-level
• fix-many
• fix-null-parse
• fix-permission-denied
• fix-pipeline-update
• 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-startup
• fix-state
• fix-table-mapping
• fix-tasks
• fix-test-flaky
• fix-tests
• fix-url
• fix/add-cargo-lock
• fix/allow-empty-publication
• fix/graceful-k8s-failure
• fix/replicator-rustflags
• fix/vendored-swagger-ui
• general-refactor
• implement-better-cleanup
• implement-better-shutdown
• implement-paralle-table-copy
• improve-allocations
• improve-benchmarking
• improve-billing
• improve-bq-connection
• improve-bq-errors
• improve-bq-handling
• improve-catchup
• improve-ci-bench
• improve-code
• improve-concurrency
• improve-config
• improve-ddl-handling
• improve-docs
• improve-error-handling
• improve-logging-streams
• improve-metric-tag
• improve-metrics-code
• improve-name
• improve-notify-handling
• improve-ordering
• improve-panioc
• improve-pub-docs
• improve-public-docs
• improve-query-performance
• improve-reset
• improve-script
• improve-sequencing
• improve-shutdown
• improve-tag
• improve-tests
• improve-truncation
• improve-validation
• improve-vector-size
• jm/avoid-deser-clones
• jm/ci-security-hardening
• jm/clickhouse
• jm/clippy-lints
• jm/consolidate-integration-tests
• jm/ducklake-test-fixes
• jm/etl-core
• jm/nextest
• jm/nix
• jm/notify-before-start
• jm/retest-flaky-under-load
• jm/retries-flaky-test-setup
• jm/sql-like-slots
• kafaichoi/ensure-unique-per-source-and-destination-pair
• main
• mh/ecr-action
• migrations
• move-arc-clone
• new-label
• new-metric
• new-metrics
• new-reset-endpoint
• new-test-metric
• or/iceberg
• partial-configs
• raminder/etl-148-process_syncing_tables-in-apply-loop-should-be-called-on
• raminder/etl-150-new-table-sync-workers-keep-launching
• ref/improve-minor-things
• ref/remove-end-batch
• refactor/clippy-lints
• refactor/stores-cloning
• refactor/test-db-default-values
• refine-behavior
• release/v0.1.1
• remove-arc-table-descriptor
• remove-pipeline-id
• remove-rollback
• remove-taint
• remove-waiting
• rework-api
• rework-apply-loop
• 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/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-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-61-handle-schema-changes-in-the-source
• 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
• sentry-debug-symbols
• swap-notification-endpoint
• table-id-integer
• trail-whitespaces
• update-allocator
• update-docker
• update-params
• update-runner
• upload-source-code-coveralls
• use-new-version

Build # 17488318779

Build Type

Pull #334

github

Committed by web-flow

Commit Message

Merge 372b0767c into 6960de549

Pull Request Pull Request #334: feat(replication): Use a new timeout stream for the apply loop

Coverage Stats

152 of 177 new or added lines in 3 files covered. (85.88%)

9 existing lines in 2 files now uncovered.

10737 of 13420 relevant lines covered (80.01%)

168.42 hits per line