@@ -10,33 +10,6 @@ import (
1010 "go.uber.org/cadence/worker"
1111)
1212
13- func Test_DataConverterWorkflow (t * testing.T ) {
14- testSuite := & testsuite.WorkflowTestSuite {}
15- env := testSuite .NewTestWorkflowEnvironment ()
16- env .RegisterWorkflow (dataConverterWorkflow )
17- env .RegisterActivity (dataConverterActivity )
18-
19- dataConverter := NewCompressedJSONDataConverter ()
20- workerOptions := worker.Options {
21- DataConverter : dataConverter ,
22- }
23- env .SetWorkerOptions (workerOptions )
24-
25- input := MyPayload {Msg : "test" , Count : 42 }
26-
27- var activityResult MyPayload
28- env .SetOnActivityCompletedListener (func (activityInfo * activity.Info , result encoded.Value , err error ) {
29- result .Get (& activityResult )
30- })
31-
32- env .ExecuteWorkflow (dataConverterWorkflow , input )
33-
34- require .True (t , env .IsWorkflowCompleted ())
35- require .NoError (t , env .GetWorkflowError ())
36- require .Equal (t , "test processed" , activityResult .Msg )
37- require .Equal (t , 43 , activityResult .Count )
38- }
39-
4013func Test_LargeDataConverterWorkflow (t * testing.T ) {
4114 testSuite := & testsuite.WorkflowTestSuite {}
4215 env := testSuite .NewTestWorkflowEnvironment ()
0 commit comments