- Converted to python 3.x, dropped 2.x compatibility.
- Added support for retrying lambda invocations which fail due to internal errors
- Added additional parameters to
start_workflow()
- Added
workflow_time()
method that returns a consistent datetime. - Fixed a problem where too large lambda input would cause decider to crash
- Fixed problem with
invoke_once
hanging.
- Added
timed_wait_for_all
andtimed_wait_for_any
, which raise aWaitTimedOutException
if the requested condition isn't satisfied after a given time. - Added
invoke_once
method, to support invoking a callable only once in a workflow, but propagate the result to other decider instances.
- Rewrote the way workflow functions execute, to make replay behavior more consistent.
- Added
is_replaying
property toWorkflowInvocationHelper
- Added
wait_for_any
method, and madewait_for_all
return a list of the futures in the order they finished. - Added
start_timer
method which returns a Future which completes after a given time.