Decision task failure support (cadence-workflow#422)

Add API on Cadence frontend to support DecisionTaskFailure. Added two new causes: RESET_STICKY_TASKLIST and WORKFLOW_WORKER_UNHANDLED_FAILURE to support scenario of shedding load by clearing sticky tasklist and decider failures during execution respectively. Only first DecisionTaskFailure is reported in history and all subsequent retries are done using state from mutable state. Mutable state keeps track of decision_attempt and decision_timestamp and creates transient decisions while dispatching these decision tasks. These transition decisions are stored in the history and frontend has logic to deliver these events when it is done paginating through all the events from history. New schema changes to support transient decisions on mutable state. Fixes cadence-workflow#117 and cadence-workflow#118 .
code-4-fun · Nov 23, 2017 · 9db7677 · 9db7677
1 parent 6b3fcff
commit 9db7677
Show file tree

Hide file tree

Showing 109 changed files with 2,557 additions and 1,943 deletions.
diff --git a/.gen/go/cadence/idl.go b/.gen/go/cadence/idl.go
diff --git a/.gen/go/cadence/versioncheck.go b/.gen/go/cadence/versioncheck.go
diff --git a/.gen/go/cadence/workflowservice_deprecatedomain.go b/.gen/go/cadence/workflowservice_deprecatedomain.go
diff --git a/.gen/go/cadence/workflowservice_describedomain.go b/.gen/go/cadence/workflowservice_describedomain.go
diff --git a/.gen/go/cadence/workflowservice_describeworkflowexecution.go b/.gen/go/cadence/workflowservice_describeworkflowexecution.go
diff --git a/.gen/go/cadence/workflowservice_getworkflowexecutionhistory.go b/.gen/go/cadence/workflowservice_getworkflowexecutionhistory.go
diff --git a/.gen/go/cadence/workflowservice_listclosedworkflowexecutions.go b/.gen/go/cadence/workflowservice_listclosedworkflowexecutions.go
diff --git a/.gen/go/cadence/workflowservice_listopenworkflowexecutions.go b/.gen/go/cadence/workflowservice_listopenworkflowexecutions.go
diff --git a/.gen/go/cadence/workflowservice_pollforactivitytask.go b/.gen/go/cadence/workflowservice_pollforactivitytask.go
diff --git a/.gen/go/cadence/workflowservice_pollfordecisiontask.go b/.gen/go/cadence/workflowservice_pollfordecisiontask.go
diff --git a/.gen/go/cadence/workflowservice_queryworkflow.go b/.gen/go/cadence/workflowservice_queryworkflow.go
diff --git a/.gen/go/cadence/workflowservice_recordactivitytaskheartbeat.go b/.gen/go/cadence/workflowservice_recordactivitytaskheartbeat.go
diff --git a/.gen/go/cadence/workflowservice_registerdomain.go b/.gen/go/cadence/workflowservice_registerdomain.go
diff --git a/.gen/go/cadence/workflowservice_requestcancelworkflowexecution.go b/.gen/go/cadence/workflowservice_requestcancelworkflowexecution.go
diff --git a/.gen/go/cadence/workflowservice_respondactivitytaskcanceled.go b/.gen/go/cadence/workflowservice_respondactivitytaskcanceled.go
diff --git a/.gen/go/cadence/workflowservice_respondactivitytaskcompleted.go b/.gen/go/cadence/workflowservice_respondactivitytaskcompleted.go
diff --git a/.gen/go/cadence/workflowservice_respondactivitytaskfailed.go b/.gen/go/cadence/workflowservice_respondactivitytaskfailed.go