command_thread_completion

const (
	WorkflowType = "command_thread_completion"
	State1       = "S1"
	State2       = "S2"
	State3       = "S3"
	StateAnyCmd  = "StateAnyCmd" // Tests ANY_COMMAND_COMPLETED with CAN

)

*

• This test workflow validates that all command threads complete before continue-as-new snapshots state.
• It tests the fix for the bug where internal channel signals were lost during continue-as-new. *
• Workflow structure:
• State1:
• - WaitUntil: Set up timer, signal, and internal channel commands with ANY_COMMAND_COMPLETED
• - Execute: Publish to internal channel, move to State2
• State2:
• - WaitUntil: Wait for the internal channel from State1
• - Execute: Complete workflow *
• The test triggers continue-as-new after State1 execute but before State2 starts.
• This ensures the internal channel signal published by State1 is captured before continue-as-new.