Skip to content

Commit 49225a9

Browse files
committed
Add LambdaFunctionTask
Currently SWF only; needs to be moved upward. And with some rough edges... Signed-off-by: Yves Bastide <yves@botify.com>
1 parent 28e69bf commit 49225a9

File tree

1 file changed

+19
-1
lines changed

1 file changed

+19
-1
lines changed

simpleflow/swf/executor.py

Lines changed: 19 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -360,7 +360,7 @@ def _get_future_from_child_workflow_event(self, event):
360360
future.set_finished(format.decode(event['result']))
361361
elif state == 'failed':
362362
future.set_exception(exceptions.TaskFailed(
363-
name=event['id'],
363+
name=event['name'],
364364
reason=event['reason'],
365365
details=event.get('details'),
366366
))
@@ -872,6 +872,24 @@ def resume_lambda_function(self, a_task, event):
872872

873873
return future
874874

875+
def resume_lambda_function(self, a_task, event):
876+
"""
877+
Resume a child workflow.
878+
879+
:param a_task:
880+
:type a_task: LambdaTask
881+
:param event:
882+
:type event: dict
883+
:return:
884+
:rtype: simpleflow.futures.Future
885+
"""
886+
future = self._get_future_from_lambda_function_event(event)
887+
888+
if future.finished and future.exception:
889+
raise future.exception
890+
891+
return future
892+
875893
def schedule_task(self, a_task, task_list=None):
876894
"""
877895
Let a task schedule itself.

0 commit comments

Comments
 (0)