From 4aeb27447215806dcc4f7a759398ee21d27b234d Mon Sep 17 00:00:00 2001 From: Leonid Ryzhyk Date: Wed, 5 Aug 2026 09:36:02 -0700 Subject: [PATCH] [manager] accept postgres_cdc_input as an input connector A table declaring a postgres_cdc_input connector failed to compile with "expected an input variant but got an output variant". generate_program_info matches the transport against an allow-list of input variants that omitted PostgresCdcInput, and the catch-all arm that follows reports every unlisted variant as an output variant. PR #5988 added the connector to feldera-types, to the SQL compiler's ConnectorValidator and to the adapter, but not to this allow-list, so the usage documented in docs.feldera.com/docs/connectors/sources/postgresql-cdc.md has never compiled on main. This is the same change as 19b8d33d8 on the unmerged pg-cdc-ft-fixes branch, split out so the fix does not wait on that branch. --- crates/pipeline-manager/src/db/types/program.rs | 1 + 1 file changed, 1 insertion(+) diff --git a/crates/pipeline-manager/src/db/types/program.rs b/crates/pipeline-manager/src/db/types/program.rs index 1ddf0c924a1..6166aff191a 100644 --- a/crates/pipeline-manager/src/db/types/program.rs +++ b/crates/pipeline-manager/src/db/types/program.rs @@ -728,6 +728,7 @@ pub fn generate_program_info( | TransportConfig::S3Input(_) | TransportConfig::DeltaTableInput(_) | TransportConfig::PostgresInput(_) + | TransportConfig::PostgresCdcInput(_) | TransportConfig::IcebergInput(_) | TransportConfig::Datagen(_) | TransportConfig::Nexmark(_)