Deregistration process manager retry the rollup errors from aggregates (

#1473)
trento-project · Jun 16, 2023 · 38f7243 · 38f7243
1 parent 9561988
commit 38f7243
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/lib/trento/application/process_managers/deregistration_process_manager.ex b/lib/trento/application/process_managers/deregistration_process_manager.ex
@@ -289,6 +289,17 @@ defmodule Trento.DeregistrationProcessManager do
     }
   end
 
+  # Retry the rollup errors, stop the process on other errors
+
+  def error({:error, :host_rolling_up}, _command_or_event, %{context: context}),
+    do: {:retry, context}
+
+  def error({:error, :cluster_rolling_up}, _command_or_event, %{context: context}),
+    do: {:retry, context}
+
+  def error({:error, :sap_system_rolling_up}, _command_or_event, %{context: context}),
+    do: {:retry, context}
+
   defp maybe_deregister_cluster_host(nil, _, _), do: []
 
   defp maybe_deregister_cluster_host(cluster_id, host_id, requested_at) do