From d08a56958efdfb7d435b80820507264ec85ee9e0 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Thu, 26 Oct 2023 10:11:47 -0400 Subject: [PATCH] fix lint issue --- flow/connectors/utils/monitoring/monitoring.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/flow/connectors/utils/monitoring/monitoring.go b/flow/connectors/utils/monitoring/monitoring.go index d52b544896..ee8677a61d 100644 --- a/flow/connectors/utils/monitoring/monitoring.go +++ b/flow/connectors/utils/monitoring/monitoring.go @@ -4,9 +4,10 @@ import ( "context" "errors" "fmt" - "google.golang.org/protobuf/types/known/timestamppb" "time" + "google.golang.org/protobuf/types/known/timestamppb" + "github.com/PeerDB-io/peer-flow/generated/protos" "github.com/jackc/pglogrepl" "github.com/jackc/pgx/v5" @@ -89,7 +90,8 @@ func (c *CatalogMirrorMonitor) UpdateLatestLSNAtTargetForCDCFlow(ctx context.Con return nil } -func (c *CatalogMirrorMonitor) GetLastLSNUpdatedAtTargetForCDCFlow(ctx context.Context, flowJobName string) (*protos.LastSyncState, error) { +func (c *CatalogMirrorMonitor) GetLastLSNUpdatedAtTargetForCDCFlow( + ctx context.Context, flowJobName string) (*protos.LastSyncState, error) { if c == nil || c.catalogConn == nil { return nil, fmt.Errorf("catalog hasn't been configured") }