From 0b4482726bcb1da317e7f4997f3ecca42cd73a35 Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Thu, 29 Feb 2024 17:30:16 +0530 Subject: [PATCH] fixing the fumpt --- flow/connectors/bigquery/qrep.go | 3 ++- flow/connectors/clickhouse/qrep.go | 3 ++- flow/connectors/snowflake/qrep.go | 3 ++- 3 files changed, 6 insertions(+), 3 deletions(-) diff --git a/flow/connectors/bigquery/qrep.go b/flow/connectors/bigquery/qrep.go index 0c93170989..98893a9d33 100644 --- a/flow/connectors/bigquery/qrep.go +++ b/flow/connectors/bigquery/qrep.go @@ -116,6 +116,7 @@ func (c *BigQueryConnector) SetupQRepMetadataTables(ctx context.Context, config } func (c *BigQueryConnector) IsQRepPartitionSynced(ctx context.Context, - req *protos.IsQRepPartitionSyncedInput) (bool, error) { + req *protos.IsQRepPartitionSyncedInput, +) (bool, error) { return c.pgMetadata.IsQrepPartitionSynced(ctx, req.FlowJobName, req.PartitionId) } diff --git a/flow/connectors/clickhouse/qrep.go b/flow/connectors/clickhouse/qrep.go index 329eb0eb07..fe8e8b2bd5 100644 --- a/flow/connectors/clickhouse/qrep.go +++ b/flow/connectors/clickhouse/qrep.go @@ -100,7 +100,8 @@ func (c *ClickhouseConnector) getTableSchema(tableName string) ([]*sql.ColumnTyp } func (c *ClickhouseConnector) IsQRepPartitionSynced(ctx context.Context, - req *protos.IsQRepPartitionSyncedInput) (bool, error) { + req *protos.IsQRepPartitionSyncedInput, +) (bool, error) { //nolint:gosec queryString := fmt.Sprintf(`SELECT COUNT(*) FROM %s WHERE partitionID = '%s'`, qRepMetadataTableName, req.PartitionId) diff --git a/flow/connectors/snowflake/qrep.go b/flow/connectors/snowflake/qrep.go index faeafc8e53..20e424cf32 100644 --- a/flow/connectors/snowflake/qrep.go +++ b/flow/connectors/snowflake/qrep.go @@ -287,6 +287,7 @@ func (c *SnowflakeConnector) getStageNameForJob(job string) string { } func (c *SnowflakeConnector) IsQRepPartitionSynced(ctx context.Context, - req *protos.IsQRepPartitionSyncedInput) (bool, error) { + req *protos.IsQRepPartitionSyncedInput, +) (bool, error) { return c.pgMetadata.IsQrepPartitionSynced(ctx, req.FlowJobName, req.PartitionId) }