fix: log

PeerDB-io · Dec 11, 2023 · be31624 · be31624
1 parent 231da91
commit be31624
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/flow/connectors/external_metadata/store.go b/flow/connectors/external_metadata/store.go
@@ -153,7 +153,7 @@ func (p *PostgresMetadataStore) FetchLastOffset(jobName string) (*protos.LastSyn
 		return nil, err
 	}
 
-	log.Infof("got last offset for job `%s`: %d", jobName, offset)
+	log.Infof("got last offset for job `%s`: %d", jobName, offset.Int64)
 
 	return &protos.LastSyncState{
 		Checkpoint: offset.Int64,
@@ -181,7 +181,7 @@ func (p *PostgresMetadataStore) GetLastBatchID(jobName string) (int64, error) {
 		return 0, err
 	}
 
-	log.Infof("got last sync batch ID for job `%s`: %d", jobName, syncBatchID)
+	log.Infof("got last sync batch ID for job `%s`: %d", jobName, syncBatchID.Int64)
 
 	return syncBatchID.Int64, nil
 }

diff --git a/flow/e2e/sqlserver/qrep_flow_sqlserver_test.go b/flow/e2e/sqlserver/qrep_flow_sqlserver_test.go
@@ -182,5 +182,5 @@ func (s *PeerFlowE2ETestSuiteSQLServer) Test_Complete_QRep_Flow_SqlServer_Append
 	err = s.pool.QueryRow(context.Background(), countQuery).Scan(&numRowsInDest)
 	s.NoError(err)
 
-	s.Equal(numRows, numRowsInDest.Int64)
+	s.Equal(numRows, int(numRowsInDest.Int64))
 }