@@ -602,8 +602,6 @@ func TestAsyncOperationFromWorkflow(t *testing.T) {
602
602
switch action {
603
603
case "wait-for-started" :
604
604
fut .GetNexusOperationExecution ().Get (ctx , nil )
605
- case "sleep" :
606
- workflow .Sleep (ctx , time .Millisecond )
607
605
}
608
606
cancel ()
609
607
})
@@ -761,21 +759,6 @@ func TestAsyncOperationFromWorkflow(t *testing.T) {
761
759
}
762
760
})
763
761
764
- t .Run ("OpCanceledBeforeStarted" , func (t * testing.T ) {
765
- run , err := tc .client .SignalWithStartWorkflow (ctx , uuid .NewString (), "cancel-op" , "sleep" , client.StartWorkflowOptions {
766
- TaskQueue : tc .taskQueue ,
767
- }, callerWorkflow , "fail-to-start" )
768
- require .NoError (t , err )
769
- var execErr * temporal.WorkflowExecutionError
770
- err = run .Get (ctx , nil )
771
- require .ErrorAs (t , err , & execErr )
772
- // The Go SDK unwraps workflow errors to check for cancelation even if the workflow was never canceled, losing
773
- // the error chain, Nexus operation errors are treated the same as other workflow errors for consistency.
774
- var canceledErr * temporal.CanceledError
775
- err = execErr .Unwrap ()
776
- require .ErrorAs (t , err , & canceledErr )
777
- })
778
-
779
762
t .Run ("OpCanceledAfterStarted" , func (t * testing.T ) {
780
763
run , err := tc .client .SignalWithStartWorkflow (ctx , uuid .NewString (), "cancel-op" , "wait-for-started" , client.StartWorkflowOptions {
781
764
TaskQueue : tc .taskQueue ,
0 commit comments