fix: verify if task was concurrently deleted (#750)

aeternity · Jun 29, 2022 · 17e7be7 · 17e7be7
1 parent f62033c
commit 17e7be7
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/ae_mdw/sync/async_tasks/store.ex b/lib/ae_mdw/sync/async_tasks/store.ex
@@ -70,7 +70,12 @@ defmodule AeMdw.Sync.AsyncTasks.Store do
   defp fetch_all() do
     Model.AsyncTask
     |> Database.all_keys()
-    |> Enum.map(&Database.fetch!(Model.AsyncTask, &1))
+    |> Enum.flat_map(fn key ->
+      case Database.fetch(Model.AsyncTask, key) do
+        {:ok, m_task} -> [m_task]
+        :not_found -> []
+      end
+    end)
   end
 
   defp cache_tasks_by_args() do