Merge pull request #3660 from nulib/4315-csv-update-inserted-at

Preserve inserted_at during CSV metadata update jobs
nulib · Nov 15, 2023 · 15205be · 15205be
2 parents 6b7e083 + 838157c
commit 15205be
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/app/lib/meadow/data/csv/bulk_import.ex b/app/lib/meadow/data/csv/bulk_import.ex
@@ -53,6 +53,10 @@ defmodule Meadow.Data.CSV.BulkImport do
       rows |> Enum.into(SQL.stream(repo, sql))
       # credo:disable-for-previous-line Credo.Check.Warning.UnusedEnumOperation
 
+      repo.query(
+        "UPDATE #{temp_table} SET inserted_at = works.inserted_at FROM works WHERE #{temp_table}.id = works.id"
+      )
+
       repo.query(
         "UPDATE works SET #{set_clause} FROM #{temp_table} WHERE works.id = #{temp_table}.id"
       )

diff --git a/app/test/meadow/data/csv/metadata_update_jobs_test.exs b/app/test/meadow/data/csv/metadata_update_jobs_test.exs
@@ -59,11 +59,9 @@ defmodule Meadow.Data.CSV.MetadataUpdateJobsTest do
       assert MetadataUpdateJobs.apply_job(job) ==
                {:error, "Update Job cannot be applied: status is complete."}
 
-      with work <-
-             Enum.at(works, 31)
-             |> Map.get(:id)
-             |> Works.get_work()
-             |> Repo.preload(:metadata_update_jobs) do
+      with original <- Enum.at(works, 31),
+           work <- Works.get_work(original.id) |> Repo.preload(:metadata_update_jobs) do
+        assert work.inserted_at == original.inserted_at
         assert work.published
         assert work.visibility.id == "AUTHENTICATED"