temp fix missing mapper correlation id

neicnordic · Oct 18, 2023 · 01d7f97 · 01d7f97
1 parent 37674cd
commit 01d7f97
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/internal/database/db.go b/internal/database/db.go
@@ -424,16 +424,16 @@ func (dbs *SQLdb) updateDatasetEvent(datasetID, status, correlationID, user stri
 
 	db := dbs.DB
 	const dataset = "SELECT id FROM sda.datasets WHERE stable_id = $1;"
-	const markFile = "INSERT INTO sda.file_event_log(file_id, event, correlation_id, user_id) " +
-		"SELECT file_id, $2, $3, $4 from sda.file_dataset " +
+	const markFile = "INSERT INTO sda.file_event_log(file_id, event, user_id) " +
+		"SELECT file_id, $2, $3 from sda.file_dataset " +
 		"WHERE dataset_id = $1;"
 
 	var datasetInternalID int
 	if err := db.QueryRow(dataset, datasetID).Scan(&datasetInternalID); err != nil {
 		return err
 	}
 
-	result, err := db.Exec(markFile, datasetInternalID, status, correlationID, user)
+	result, err := db.Exec(markFile, datasetInternalID, status, user)
 	if err != nil {
 		return err
 	}