diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go
index 6b7f7a404..f63d4faf1 100644
--- a/flow/connectors/bigquery/bigquery.go
+++ b/flow/connectors/bigquery/bigquery.go
@@ -964,7 +964,8 @@ func (c *BigQueryConnector) SetupNormalizedTables(
 					return nil, fmt.Errorf("destination column %s not found in source: ", existingField.Name)
 				}
 				if existingField.Name != desiredField.Name || existingField.Type != desiredField.Type {
-					return nil, fmt.Errorf("failed to setup normalized table due to incompatible columns: %s (destination) and %s (source)",
+					return nil, fmt.Errorf("failed to setup normalized table due to incompatible columns: "+
+						"%s (destination) and %s (source)",
 						existingField.Name, desiredField.Name)
 				}
 			}
diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go
index 2371aa7ce..b2eee2d21 100644
--- a/flow/connectors/snowflake/snowflake.go
+++ b/flow/connectors/snowflake/snowflake.go
@@ -766,7 +766,8 @@ func (c *SnowflakeConnector) SyncFlowCleanup(jobName string) error {
 	return nil
 }
 
-func (c *SnowflakeConnector) checkIfTableExists(schemaIdentifier string, tableIdentifier string) ([]protos.TableColumn, error) {
+func (c *SnowflakeConnector) checkIfTableExists(
+	schemaIdentifier string, tableIdentifier string) ([]protos.TableColumn, error) {
 	rows, err := c.database.QueryContext(c.ctx, checkIfTableExistsSQL,
 		strings.ToUpper(schemaIdentifier), strings.ToUpper(tableIdentifier))
 	if err != nil {