diff --git a/integ/workflow/any_command_combination/routers.go b/integ/workflow/any_command_combination/routers.go index 6c0f2015..d914fb9d 100644 --- a/integ/workflow/any_command_combination/routers.go +++ b/integ/workflow/any_command_combination/routers.go @@ -15,7 +15,7 @@ import ( * This test workflow has 2 states, using REST controller to implement the workflow directly. * * State1: - * - WaitUntil method will run for two attempts. The first attempt attempt will wait for an invalid list of commands. + * - WaitUntil method will have two attempts. The first attempt attempt will wait for an invalid list of commands. * This will be rejected by server can cause a 2nd attempt. * The second attempt will wait for a valid list of commands of signals and timers, using ANY_COMMAND_COMBINATION_COMPLETED * - Execute method will go to State2 diff --git a/integ/workflow/any_timer_signal/routers.go b/integ/workflow/any_timer_signal/routers.go index e0be00aa..90041311 100644 --- a/integ/workflow/any_timer_signal/routers.go +++ b/integ/workflow/any_timer_signal/routers.go @@ -11,6 +11,16 @@ import ( "time" ) +/** + * This test workflow has 2 states, using REST controller to implement the workflow directly. + * + * State1: + * - WaitUntil method will wait for a timer or a signal + * - Execute method will go to State1 again for the first stateExecution(State1-1), and go to State2 for the second. + * State2: + * - WaitUntil method does nothing + * - Execute method will gracefully complete workflow + */ const ( WorkflowType = "any_timer_signal" State1 = "S1" diff --git a/integ/workflow/basic/routers.go b/integ/workflow/basic/routers.go index 1309ac90..b43f0686 100644 --- a/integ/workflow/basic/routers.go +++ b/integ/workflow/basic/routers.go @@ -8,6 +8,16 @@ import ( "net/http" ) +/** + * This test workflow has 2 states, using REST controller to implement the workflow directly. + * + * State1: + * - WaitUntil method does nothing + * - Execute method will go to State2 with some options(api timeout, retry policy) + * State2: + * - WaitUntil method does nothing + * - Execute method will gracefully complete workflow + */ const ( WorkflowType = "basic" State1 = "S1" diff --git a/integ/workflow/conditional_close/routers.go b/integ/workflow/conditional_close/routers.go index a5172298..b0b1036b 100644 --- a/integ/workflow/conditional_close/routers.go +++ b/integ/workflow/conditional_close/routers.go @@ -10,6 +10,15 @@ import ( "time" ) +/** + * This test workflow has 1 state and a RPC, using REST controller to implement the workflow directly. + * + * RPC: publish message to internal channel TestChannelName + * State1: + * - WaitUntil method: if the input is "use-signal-channel", then wait for TestChannelName signal, otherwise wait for TestChannelName internalChannel + * - Execute method: for the first stateExecution(State1-1), it will wait for 3 seconds to let the channel have a new message. + * Then it will conditionally go to State1 again using WorkflowConditionalClose, otherwise it will gracefully complete the workflow. + */ const ( WorkflowType = "conditional_close" RpcPublishInternalChannel = "publish_internal_channel" diff --git a/integ/workflow/deadend/routers.go b/integ/workflow/deadend/routers.go index 0035c1f5..39a97224 100644 --- a/integ/workflow/deadend/routers.go +++ b/integ/workflow/deadend/routers.go @@ -9,6 +9,15 @@ import ( "net/http" ) +/** + * This test workflow has 1 state and a RPC, using REST controller to implement the workflow directly. + * + * RPC: publish message to internal channel TestChannelName + * State1: + * - WaitUntil method: if the input is "use-signal-channel", then wait for TestChannelName signal, otherwise wait for TestChannelName internalChannel + * - Execute method: for the first stateExecution(State1-1), it will wait for 3 seconds to let the channel have a new message. + * Then it will conditionally go to State1 again using WorkflowConditionalClose, otherwise it will gracefully complete the workflow. + */ const ( WorkflowType = "deadend" RPCTriggerState = "test-RPCTriggerState"