Skip to content

Commit 5571450

Browse files
authored
Replaced Activity.RegisterWithOptions with replayers own acitivty register (#1242)
* Fixed the spelling of replay_test file. * Added the Activity Registration required failure scenario to replayer test suite * Documentation change * Removed extra file * Replaced Activity.RegisterWithOptions with replayers oen acitivty register * Removed activity from imports: nit
1 parent 311a196 commit 5571450

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

test/replaytests/replay_test.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
package replaytests
2222

2323
import (
24+
"go.uber.org/cadence/activity"
2425
"strings"
2526
"testing"
2627

@@ -29,7 +30,6 @@ import (
2930
"github.com/stretchr/testify/require"
3031
"go.uber.org/zap/zaptest"
3132

32-
"go.uber.org/cadence/activity"
3333
"go.uber.org/cadence/worker"
3434
"go.uber.org/cadence/workflow"
3535
)
@@ -74,7 +74,7 @@ func TestGreetingsWorkflow(t *testing.T) {
7474
// Should have failed but passed. Maybe, because the result recorded in history still matches the return type of the workflow.
7575
func TestGreetingsWorkflow3(t *testing.T) {
7676
replayer := worker.NewWorkflowReplayer()
77-
activity.RegisterWithOptions(getNameActivity3, activity.RegisterOptions{Name: "main.getNameActivity", DisableAlreadyRegisteredCheck: true})
77+
replayer.RegisterActivityWithOptions(getNameActivity3, activity.RegisterOptions{Name: "main.getNameActivity", DisableAlreadyRegisteredCheck: true})
7878
replayer.RegisterWorkflowWithOptions(greetingsWorkflow3, workflow.RegisterOptions{Name: "greetings"})
7979
err := replayer.ReplayWorkflowHistoryFromJSONFile(zaptest.NewLogger(t), "greetings.json")
8080
require.NoError(t, err)
@@ -83,7 +83,7 @@ func TestGreetingsWorkflow3(t *testing.T) {
8383
// Fails because the expected signature was different from history.
8484
func TestGreetingsWorkflow4(t *testing.T) {
8585
replayer := worker.NewWorkflowReplayer()
86-
activity.RegisterWithOptions(getNameActivity4, activity.RegisterOptions{Name: "main.getNameActivity", DisableAlreadyRegisteredCheck: true})
86+
replayer.RegisterActivityWithOptions(getNameActivity4, activity.RegisterOptions{Name: "main.getNameActivity", DisableAlreadyRegisteredCheck: true})
8787
replayer.RegisterWorkflowWithOptions(greetingsWorkflow4, workflow.RegisterOptions{Name: "greetings"})
8888
err := replayer.ReplayWorkflowHistoryFromJSONFile(zaptest.NewLogger(t), "greetings.json")
8989
require.Error(t, err)
@@ -96,7 +96,7 @@ func TestGreetingsWorkflow2(t *testing.T) {
9696

9797
t.Skip("Panic with failed to register activity. Here the activity returns incompatible arguments so the test should fail")
9898
replayer := worker.NewWorkflowReplayer()
99-
activity.RegisterWithOptions(getNameActivity2, activity.RegisterOptions{Name: "main.getNameActivity", DisableAlreadyRegisteredCheck: true})
99+
replayer.RegisterActivityWithOptions(getNameActivity2, activity.RegisterOptions{Name: "main.getNameActivity", DisableAlreadyRegisteredCheck: true})
100100
replayer.RegisterWorkflowWithOptions(greetingsWorkflow2, workflow.RegisterOptions{Name: "greetings"})
101101
err := replayer.ReplayWorkflowHistoryFromJSONFile(zaptest.NewLogger(t), "greetings.json")
102102
require.Error(t, err)

0 commit comments

Comments
 (0)