Skip to content

Commit

Permalink
Fix whitespace around commas
Browse files Browse the repository at this point in the history
  • Loading branch information
serprex committed Dec 12, 2023
1 parent 13aa46b commit b569852
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion flow/connectors/postgres/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -381,7 +381,7 @@ func (c *PostgresConnector) GetLastSyncBatchID(jobName string) (int64, error) {

var result pgtype.Int8
if !rows.Next() {
c.logger.Info("No row found ,returning 0")
c.logger.Info("No row found, returning 0")
return 0, nil
}
err = rows.Scan(&result)
Expand Down
2 changes: 1 addition & 1 deletion flow/connectors/snowflake/snowflake.go
Original file line number Diff line number Diff line change
Expand Up @@ -300,7 +300,7 @@ func (c *SnowflakeConnector) GetLastOffset(jobName string) (*protos.LastSyncStat
}()

if !rows.Next() {
c.logger.Warn("No row found ,returning nil")
c.logger.Warn("No row found, returning nil")
return nil, nil
}
var result pgtype.Int8
Expand Down
2 changes: 1 addition & 1 deletion flow/e2e/congen.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ func SetupPostgres(suffix string) (*pgxpool.Pool, error) {
$$ language sql;
CREATE OR REPLACE FUNCTION random_bytea(bytea_length integer)
RETURNS bytea AS $body$
SELECT decode(string_agg(lpad(to_hex(width_bucket(random(), 0, 1, 256)-1),2,'0') ,''), 'hex')
SELECT decode(string_agg(lpad(to_hex(width_bucket(random(), 0, 1, 256)-1),2,'0'), ''), 'hex')
FROM generate_series(1, $1);
$body$
LANGUAGE 'sql'
Expand Down

0 comments on commit b569852

Please sign in to comment.