change column names and set team sigma fk-nada table

Makefile

@@ -52,7 +52,8 @@ local-with-auth:
 	--quarto-bucket=nada-quarto-storage-dev \
 	--console-api-key="$(CONSOLE_API_KEY)" \
 	--log-level=debug \
-	--central-data-project=nav-central-data-dev-e170 
+	--central-data-project=nav-central-data-dev-e170 \
+	--fk-nada-table=nav-central-data-dev-e170.fk_nada_test.fk_nada
 
 
 local:

cmd/nada-backend/main.go

@@ -80,7 +80,7 @@ func init() {
 	flag.StringVar(&cfg.AmplitudeAPIKey, "amplitude-api-key", os.Getenv("AMPLITUDE_API_KEY"), "API key for Amplitude")
 	flag.StringVar(&cfg.CentralDataProject, "central-data-project", os.Getenv("CENTRAL_DATA_PROJECT"), "bigquery project for pseudo views")
 	flag.StringVar(&cfg.PseudoDataset, "pseudo-dataset", "markedsplassen_pseudo", "bigquery dataset in producers' project for markedplassen saving pseudo views")
-	flag.StringVar(&cfg.FkNadaTable, "fk-nada-table", "nav-central-data-dev-e170.fk_nada_test.fk_nada", "table for mapping fnr column in datasets to fk-nada")
+	flag.StringVar(&cfg.FkNadaTable, "fk-nada-table", "team-sigma-prod-a20a.fk_person_nada.off_id_til_fk_person_nada", "table for mapping fnr column in datasets to fk-nada")
 }
 
 func main() {

pkg/bigquery/bigquery.go

@@ -19,8 +19,8 @@ type Bigquery struct {
 	fkNadaTable        string
 }
 
-const fnr = "fnr"
-const fkNada = "fk_nada"
+const fnr = "off_id"
+const fkNada = "fk_person_nada"
 
 func New(ctx context.Context, centralDataProject, pseudoDataset string, fkNadaTable string) (*Bigquery, error) {
 	return &Bigquery{
@@ -230,7 +230,7 @@ func (c *Bigquery) ComposeJoinableViewQuery(plainTableUrl models.BigQuery, joina
 
 	if fnrColumnMapToFkNada != "" {
 		qViewJoinSalt = fmt.Sprintf(",vjs AS (SELECT v.*, unified_salt.salt AS __salt, n.%v AS %v FROM `%v` v INNER JOIN `%v` n  ON v.%v=n.%v CROSS JOIN unified_salt)",
-			fkNada, fkNada, viewID, c.fkNadaTable, fnr, fnr)
+			fkNada, fkNada, viewID, c.fkNadaTable, fnrColumnMapToFkNada, fnr)
 		hashColumns = append(hashColumns, fkNada)
 	} else {
 		qViewJoinSalt = fmt.Sprintf(",vjs AS (SELECT v.*, unified_salt.salt AS __salt FROM `%v` v CROSS JOIN unified_salt)",