Update worker and deciders actors to use SWFError subclasses exceptions

Author: Oleiade

swf/actors/decider.py

@@ -44,10 +44,8 @@ def complete(self, task_token,
         except SWFResponseError as e:
             if e.error_code == 'UnknownResourceFault':
                 raise DoesNotExistError(
-                    "Unable to complete decision task with token: {}.\n"
-                    "Possible reasons: decision already completed or "
-                    "workflow execution is closed.\n"
-                    "Details: {}".format(task_token, e.body['message'])
+                    "Unable to complete decision task with token: {}.\n".format(task_token),
+                    e.body['message']
                 )
 
             raise ResponseError(e.body['message'])
@@ -99,9 +97,8 @@ def poll(self, task_list=None,
             except SWFResponseError as e:
                 if e.error_code == 'UnknownResourceFault':
                     raise DoesNotExistError(
-                        "Unable to poll decision task.\n"
-                        "Reason: workflow execution is probably closed.\n"
-                        "Details: {}".format(task_token, e.body['message'])
+                        "Unable to poll decision task.\n",
+                        e.body['message'],
                     )
 
                 raise ResponseError(e.body['message'])

swf/actors/worker.py

@@ -47,10 +47,8 @@ def cancel(self, task_token, details=None):
         except SWFResponseError as e:
             if e.error_code == 'UnknownResourceFault':
                 raise DoesNotExistError(
-                    "Unable to cancel activity task with token: {}.\n"
-                    "Possible reasons: task already canceled or "
-                    "workflow execution is closed.\n"
-                    "Details: {}".format(task_token)
+                    "Unable to cancel activity task with token: {}.\n".format(task_token),
+                    e.body['message']
                 )
 
                 raise ResponseError(e.body['message'])
@@ -72,10 +70,8 @@ def complete(self, task_token, result=None):
         except SWFResponseError as e:
             if e.error_code == 'UnknownResourceFault':
                 raise DoesNotExistError(
-                    "Unable to complete activity task with token: {}.\n"
-                    "Possible reasons: task already completed or "
-                    "workflow execution is closed.\n"
-                    "Details: {}".format(task_token, e.body['message'])
+                    "Unable to complete activity task with token: {}.\n".format(task_token),
+                    e.body['message']
                 )
 
             raise ResponseError(e.body['message'])
@@ -101,10 +97,8 @@ def fail(self, task_token, details=None, reason=None):
         except SWFResponseError as e:
             if e.error_code == 'UnknownResourceFault':
                 raise DoesNotExistError(
-                    "Unable to fail activity task with token: {}.\n"
-                    "Possible reasons: task already failed or "
-                    "workflow execution is closed"
-                    "Details: {}".format(task_token, e.body['message'])
+                    "Unable to fail activity task with token: {}.\n".format(task_token),
+                    e.body['message']
                 )
 
             raise ResponseError(e.body['message'])
@@ -126,9 +120,8 @@ def heartbeat(self, task_token, details=None):
         except SWFResponseError as e:
             if e.error_code == 'UnknownResourceFault':
                 raise DoesNotExistError(
-                    "Unable to send activity task {} heartbeat.\n"
-                    "Possible reason: workflow execution is closed.\n"
-                    "Details: {}".format(task_token, e.body['message'])
+                    "Unable to send activity task {} heartbeat.\n".format(task_token),
+                    e.body['message']
                 )
 
             raise ResponseError(e.body['message'])
@@ -167,9 +160,8 @@ def poll(self, task_list=None, identity=None):
         except SWFResponseError as e:
             if e.error_code == 'UnknownResourceFault':
                 raise DoesNotExistError(
-                    "Unable to poll activity task.\n"
-                    "Possible reason: workflow execution is probably closed.\n"
-                    "Details: {}".format(e.body['message'])
+                    "Unable to poll activity task.\n",
+                    e.body['message']
                 )
 
             raise ResponseError(e.body['message'])