lint

PeerDB-io · Mar 6, 2024 · bc811a6 · bc811a6
1 parent 9c5bcf9
commit bc811a6
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/flow/connectors/postgres/qrep_sql_sync.go b/flow/connectors/postgres/qrep_sql_sync.go
@@ -117,8 +117,7 @@ func (s *QRepStagingTableSync) SyncQRepRecords(
 			newColumns = append(newColumns, fmt.Sprintf("%s %s", QuoteIdentifier(field.Name),
 				qValueKindToPostgresType(string(field.Type))))
 		}
-		newColumns = append(newColumns, fmt.Sprintf("%s TIMESTAMP DEFAULT CURRENT_TIMESTAMP",
-			QuoteIdentifier(syncedAtCol)))
+		newColumns = append(newColumns, QuoteIdentifier(syncedAtCol)+" TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
 		_, err := tx.Exec(ctx, fmt.Sprintf("CREATE UNLOGGED TABLE %s (%s);",
 			overwriteTempTableIdentifier,
 			strings.Join(newColumns, ", "),