49
// WorkflowPanicPolicy is always set to worker.FailWorkflow so that workflow executions
50
// fail fast when workflow code panics or detects non-determinism.
51
>
func (ts *TestServer) NewWorkerWithOptions(taskQueue string, registerFunc func(registry worker.Registry), opts worker.Options) worker.Worker {
server.go
52
>
opts.WorkflowPanicPolicy = worker.FailWorkflow
53
>
54
>
w := worker.New(ts.GetDefaultClient(), taskQueue, opts)
55
>
registerFunc(w)
56
>
ts.workers = append(ts.workers, w)
57
>
58
>
if err := w.Start(); err != nil {
59
ts.fatal(err)
60
}
61
63
}
64