@@ -654,33 +654,6 @@ func EndToEndBackendTest(t *testing.T, setup func(options ...backend.BackendOpti
654
654
655
655
instance := runWorkflow (t , ctx , c , wf , 0 )
656
656
657
- r , err := client .GetWorkflowResult [int ](ctx , c , instance , time .Second * 10 )
658
- require .NoError (t , err )
659
- require .Equal (t , 3 , r )
660
- },
661
- },
662
- {
663
- name : "ContinueAsNew_Subworkflow" ,
664
- f : func (t * testing.T , ctx context.Context , c client.Client , w worker.Worker , b TestBackend ) {
665
- swf := func (ctx workflow.Context , run int ) (int , error ) {
666
- l := workflow .Logger (ctx )
667
-
668
- run = run + 1
669
- if run < 3 {
670
- l .Debug ("continue as new" , "run" , run )
671
- return run , workflow .ContinueAsNew (ctx , run )
672
- }
673
-
674
- return run , nil
675
- }
676
-
677
- wf := func (ctx workflow.Context , run int ) (int , error ) {
678
- return workflow .CreateSubWorkflowInstance [int ](ctx , workflow .DefaultSubWorkflowOptions , swf , run ).Get (ctx )
679
- }
680
- register (t , ctx , w , []interface {}{wf , swf }, nil )
681
-
682
- instance := runWorkflow (t , ctx , c , wf , 0 )
683
-
684
657
r , err := client .GetWorkflowResult [int ](ctx , c , instance , time .Second * 10 )
685
658
require .NoError (t , err )
686
659
require .Equal (t , 3 , r )
0 commit comments