post rebase fix

PeerDB-io · Nov 14, 2024 · 4a66a8c · 4a66a8c
1 parent 2725f82
commit 4a66a8c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/clickhouse/normalize.go b/flow/connectors/clickhouse/normalize.go
@@ -305,7 +305,7 @@ func (c *ClickHouseConnector) NormalizeRecords(
 				chConn = c.database
 			} else {
 				var err error
-				chConn, err = Connect(errCtx, c.config)
+				chConn, err = Connect(errCtx, req.Env, c.config)
 				if err != nil {
 					return err
 				}