diff --git a/app/lib/meadow/data/csv/bulk_import.ex b/app/lib/meadow/data/csv/bulk_import.ex index 3dd752269..578ce9793 100644 --- 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 index febd9e1fc..fdc0839ae 100644 --- 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"