Handle already resumed Redshift

mitdbg · Dec 18, 2023 · de68108 · de68108
1 parent c6f7d26
commit de68108
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/brad/provisioning/redshift.py b/src/brad/provisioning/redshift.py
@@ -61,7 +61,14 @@ async def resume_and_fetch_existing_provisioning(
         self, cluster_id: str
     ) -> Provisioning:
         def do_resume():
-            self._redshift.resume_cluster(ClusterIdentifier=cluster_id)
+            try:
+                self._redshift.resume_cluster(ClusterIdentifier=cluster_id)
+            except Exception as ex:
+                message = repr(ex)
+                if "InvalidClusterState" in message:
+                    logger.info("Proceeding past Redshift resume error: %s", message)
+                else:
+                    raise
 
         loop = asyncio.get_running_loop()
         await loop.run_in_executor(None, do_resume)