feat(unrelated): WorkflowExecutionAlreadyStartedError

Translate WorkflowExecutionAlreadyStartedFault into
a WorkflowExecutionAlreadyStartedError exception.

Signed-off-by: Yves Bastide <yves@botify.com>

Author: ybastide

simpleflow/swf/mapper/exceptions.py

@@ -9,7 +9,7 @@
 
 
 class SWFError(Exception):
-    def __init__(self, message: str, raw_error: str = "", *args) -> None:
+    def __init__(self, message: str = "", raw_error: str = "", *args) -> None:
         """
         Examples:
 
@@ -105,6 +105,10 @@ class RateLimitExceededError(SWFError):
     pass
 
 
+class WorkflowExecutionAlreadyStartedError(SWFError):
+    pass
+
+
 def ignore(*args, **kwargs):
     return
 
@@ -234,7 +238,7 @@ def raises(exception, when, extract: Callable[[Any], str] = str):
     @wraps(raises)
     def raises_closure(error, *args, **kwargs):
         if when(error, *args, **kwargs) is True:
-            raise exception(extract(error))
+            raise exception(extract(error)) from None
         raise error
 
     return raises_closure

simpleflow/swf/mapper/models/workflow.py

@@ -13,6 +13,7 @@
     AlreadyExistsError,
     DoesNotExistError,
     ResponseError,
+    WorkflowExecutionAlreadyStartedError,
     extract_error_code,
     extract_message,
     raises,
@@ -219,6 +220,14 @@ def upstream(self) -> WorkflowType:
         qs = WorkflowTypeQuerySet(self.domain)
         return qs.get(self.name, self.version)
 
+    @exceptions.catch(
+        ClientError,
+        raises(
+            WorkflowExecutionAlreadyStartedError,
+            when=lambda error, *args, **kwargs: extract_error_code(error) == "WorkflowExecutionAlreadyStartedFault",
+            extract=lambda *args, **kwargs: "",
+        ),
+    )
     def start_execution(
         self,
         workflow_id: str | None = None,