[async tasks] remove task if there is a backend 500 error

src/Gargantext/Context/Progress.purs

@@ -11,6 +11,7 @@ import Effect (Effect)
 import Effect.Aff (Aff, launchAff_)
 import Effect.Class (liftEffect)
 import Effect.Timer (IntervalId, clearInterval, setInterval)
+import Gargantext.AsyncTasks as GAT
 import Gargantext.Components.App.Store as AppStore
 import Gargantext.Components.Forest.Tree.Node.Tools.ProgressBar (QueryProgressData, queryProgress)
 import Gargantext.Components.Notifications as Notifications
@@ -41,7 +42,7 @@ asyncProgress = R2.component asyncProgressCpt
 asyncProgressCpt :: R.Component AsyncProps
 asyncProgressCpt = R2.hereComponent here "asyncProgress" hCpt where
   hCpt hp props@{ onFinish } children = do
-    { errors, wsNotification } <- AppStore.use
+    { errors, tasks, wsNotification } <- AppStore.use
                   
     -- States
     progress /\ progressBox <- R2.useBox' 0.0
@@ -57,6 +58,7 @@ asyncProgressCpt = R2.hereComponent here "asyncProgress" hCpt where
 
         eAsyncProgress <- queryProgress rdata
         liftEffect $ here.log2 "[progress] received asyncProgress" eAsyncProgress
+
         -- exponential backoff in case of errors
         -- liftEffect $ do
         --   case eAsyncProgress of
@@ -64,6 +66,14 @@ asyncProgressCpt = R2.hereComponent here "asyncProgress" hCpt where
         --     Right _ -> T.write_ 1000 interval
         --   interval' <- T.read interval
         --   resetInterval intervalIdRef (Just interval') exec
+
+        -- Handle removal of task in case of 500 error (e.g. server
+        -- was restarted and task id is not found anymore).
+        -- Error logging will be done below, in handleRESTError
+        case eAsyncProgress of
+          Right _ -> pure unit
+          Left _err -> liftEffect $ GAT.finish props.nodeId props.asyncTask tasks
+
         handleRESTError hp errors eAsyncProgress onProgress
       exec (Just jobProgress) = do
         launchAff_ $ onProgress jobProgress