File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -25,9 +25,6 @@ type Worker struct {
25
25
26
26
workflowWorker * internal.Worker [backend.WorkflowTask , workflowinternal.ExecutionResult ]
27
27
activityWorker * internal.Worker [backend.ActivityTask , history.Event ]
28
-
29
- workflows map [string ]interface {}
30
- activities map [string ]interface {}
31
28
}
32
29
33
30
func New (backend backend.Backend , options * Options ) * Worker {
@@ -46,7 +43,9 @@ func New(backend backend.Backend, options *Options) *Worker {
46
43
registry := workflowinternal .NewRegistry ()
47
44
48
45
// Register internal activities
49
- registry .RegisterActivity (& signals.Activities {Signaler : client .New (backend )})
46
+ if err := registry .RegisterActivity (& signals.Activities {Signaler : client .New (backend )}); err != nil {
47
+ panic (fmt .Errorf ("registering internal activities: %w" , err ))
48
+ }
50
49
51
50
return & Worker {
52
51
backend : backend ,
You can’t perform that action at this time.
0 commit comments