@@ -534,8 +534,8 @@ func (pgw *PostgresWriter) MaintainUniqueSources() {
534534 metricName := strings .Replace (tableName , "public." , "" , 1 )
535535 allDistinctMetricTables [i ] = metricName // later usage in sqlDroppedTables requires no "public." prefix.
536536 logger .Debugf ("Updating admin.all_distinct_dbname_metrics listing for metric: %s" , metricName )
537- var deletedRowsCnt , insertedRowsCnt int ;
538- err = pgw .sinkDb .QueryRow (pgw .ctx , sqlUpdateListingTable , tableName ).Scan (& deletedRowsCnt , & insertedRowsCnt );
537+ var deletedRowsCnt , insertedRowsCnt int
538+ err = pgw .sinkDb .QueryRow (pgw .ctx , sqlUpdateListingTable , tableName ).Scan (& deletedRowsCnt , & insertedRowsCnt )
539539 if err != nil {
540540 logger .Errorf ("Could not update admin.all_distinct_dbname_metrics listing for metric '%s': %s" , metricName , err )
541541 }
@@ -550,7 +550,7 @@ func (pgw *PostgresWriter) MaintainUniqueSources() {
550550
551551 // removes all entries for any non-existing table.
552552 sqlRemoveDroppedTables := "SELECT admin.remove_dropped_tables_listing(existing_metrics => $1)"
553- var deletedRowsCnt int ;
553+ var deletedRowsCnt int
554554 err = pgw .sinkDb .QueryRow (pgw .ctx , sqlRemoveDroppedTables , allDistinctMetricTables ).Scan (& deletedRowsCnt )
555555 if err != nil {
556556 logger .Errorf ("Could not update admin.all_distinct_dbname_metrics listing table for dropped metric tables: %s" , err )
0 commit comments