Skip to content

Commit 9792e64

Browse files
authored
Fix parsing of the preview.pipeline-arch-v2 flag (#2177)
1 parent e9fe7c1 commit 9792e64

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

cmd/conduit/root/config/config_test.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ func TestConfigWithFlags(t *testing.T) {
8282
"--pipelines.path", "/var/lib/conduit/pipelines",
8383
"--preview.pipeline-arch-v2=true",
8484
"--processors.path", "/opt/conduit/processors",
85-
"--schema-registry.confluent.connection-string", "http://localhost:8081",
85+
"--schema-registry.confluent.connection-string", "http://localhost:8888",
8686
"--schema-registry.type", "confluent",
8787
"--dev.blockprofile", "/tmp/block.prof",
8888
"--dev.cpuprofile", "/tmp/cpu.prof",
@@ -106,8 +106,8 @@ func TestConfigWithFlags(t *testing.T) {
106106
"pipelines.error-recovery.max-retries: 10",
107107
"pipelines.error-recovery.max-retries-window: 15m0s",
108108
"schema-registry.type: confluent",
109-
"schema-registry.confluent.connection-string: http://localhost:8081",
110-
"preview.pipeline-arch-v2: false",
109+
"schema-registry.confluent.connection-string: http://localhost:8888",
110+
"preview.pipeline-arch-v2: true",
111111
"dev.cpuprofile: /tmp/cpu.prof",
112112
"dev.memprofile: /tmp/mem.prof",
113113
"dev.blockprofile: /tmp/block.prof",

pkg/conduit/config.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ type Config struct {
119119

120120
Preview struct {
121121
// PipelineArchV2 enables the new pipeline architecture.
122-
PipelineArchV2 bool `long:"preview.pipeline-arch-v2" usage:"enables experimental pipeline architecture v2 (note that the new architecture currently supports only 1 source and 1 destination per pipeline)"`
122+
PipelineArchV2 bool `long:"preview.pipeline-arch-v2" mapstructure:"pipeline-arch-v2" usage:"enables experimental pipeline architecture v2 (note that the new architecture currently supports only 1 source and 1 destination per pipeline)"`
123123
}
124124

125125
Dev struct {

0 commit comments

Comments
 (0)