Skip to content

Commit

Permalink
fix lint issue
Browse files Browse the repository at this point in the history
  • Loading branch information
iskakaushik committed Oct 26, 2023
1 parent d715ee8 commit d08a569
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions flow/connectors/utils/monitoring/monitoring.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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")
}
Expand Down

0 comments on commit d08a569

Please sign in to comment.