From 17e7be76382c90084a00a8fb004fcf1b3c4476a7 Mon Sep 17 00:00:00 2001
From: Rogerio Pontual <44991200+jyeshe@users.noreply.github.com>
Date: Wed, 29 Jun 2022 16:50:55 -0300
Subject: [PATCH] fix: verify if task was concurrently deleted (#750)

---
 lib/ae_mdw/sync/async_tasks/store.ex | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/lib/ae_mdw/sync/async_tasks/store.ex b/lib/ae_mdw/sync/async_tasks/store.ex
index 2c362b7c3..2678987a9 100644
--- 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