Raise anonymization timeout to infinity

jshmrtn · Mar 9, 2023 · 6fa7f97 · 6fa7f97
1 parent 97f48d6
commit 6fa7f97
Showing 1 changed file with 11 additions and 8 deletions.
diff --git a/lib/hygeia/jobs/anonymization.ex b/lib/hygeia/jobs/anonymization.ex
@@ -69,14 +69,17 @@ defmodule Hygeia.Jobs.Anonymization do
     stream = Repo.stream(query, max_rows: 1000)
 
     {:ok, length} =
-      Repo.transaction(fn ->
-        anonymizations =
-          stream
-          |> Stream.each(anonymization_function)
-          |> Enum.to_list()
-
-        length(anonymizations)
-      end)
+      Repo.transaction(
+        fn ->
+          anonymizations =
+            stream
+            |> Stream.each(anonymization_function)
+            |> Enum.to_list()
+
+          length(anonymizations)
+        end,
+        timeout: :infinity
+      )
 
     {:ok, length}
   end