updated config

meroxa · Sep 17, 2024 · effa3c5 · effa3c5
1 parent f2f3d34
commit effa3c5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/source.go b/source.go
@@ -72,7 +72,7 @@ func (s *Source) Parameters() config.Parameters {
 
 func (s *Source) Configure(ctx context.Context, cfg config.Config) error {
 	sdk.Logger(ctx).Debug().Msg("Configuring Source connector...")
-	err := sdk.Util.ParseConfig(ctx, cfg, &s.config, s.Parameters())
+	err := sdk.Util.ParseConfig(ctx, cfg, &s.config, NewSource().Parameters())
 	if err != nil {
 		return fmt.Errorf("invalid config: %w", err)
 	}