feat(unrelated): WorkflowExecutionAlreadyStartedError

Signed-off-by: Yves Bastide <[email protected]>

Author: ybastide

simpleflow/swf/mapper/exceptions.py

@@ -105,7 +105,7 @@ class RateLimitExceededError(SWFError):
     pass
 
 
-class WorkflowExecutionAlreadyStarted(SWFError):
+class WorkflowExecutionAlreadyStartedError(SWFError):
     pass
 
 
@@ -178,9 +178,7 @@ def wrapped(error, *args, **kwargs):
             raise ValueError(f"cannot extract resource from {error}")
 
         message = extract_message(error)
-        has_nested_resource = match_equals(
-            REGEX_UNKNOWN_RESOURCE, message, ("type", "execution")
-        )
+        has_nested_resource = match_equals(REGEX_UNKNOWN_RESOURCE, message, ("type", "execution"))
         if has_nested_resource:
             matching = match_equals(REGEX_NESTED_RESOURCE, message, resource)
         else:

simpleflow/swf/mapper/models/workflow.py

@@ -13,7 +13,7 @@
     AlreadyExistsError,
     DoesNotExistError,
     ResponseError,
-    WorkflowExecutionAlreadyStarted,
+    WorkflowExecutionAlreadyStartedError,
     extract_error_code,
     extract_message,
     raises,
@@ -223,7 +223,7 @@ def upstream(self) -> WorkflowType:
     @exceptions.catch(
         ClientError,
         raises(
-            WorkflowExecutionAlreadyStarted,
+            WorkflowExecutionAlreadyStartedError,
             when=lambda error, *args, **kwargs: extract_error_code(error) == "WorkflowExecutionAlreadyStartedFault",
             extract=lambda *args, **kwargs: "",
         ),