File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -391,7 +391,7 @@ func (e *executor) handleWorkflowExecutionStarted(a *history.ExecutionStartedAtt
391
391
return fmt .Errorf ("workflow %s not found" , a .Name )
392
392
}
393
393
394
- e .workflow = NewWorkflow (reflect .ValueOf (wfFn ))
394
+ e .workflow = newWorkflow (reflect .ValueOf (wfFn ))
395
395
396
396
return e .workflow .Execute (e .workflowCtx , a .Inputs )
397
397
}
Original file line number Diff line number Diff line change @@ -19,7 +19,7 @@ type workflow struct {
19
19
err error
20
20
}
21
21
22
- func NewWorkflow (workflowFn reflect.Value ) * workflow {
22
+ func newWorkflow (workflowFn reflect.Value ) * workflow {
23
23
s := sync .NewScheduler ()
24
24
25
25
return & workflow {
Original file line number Diff line number Diff line change @@ -25,7 +25,7 @@ func Test_Workflow_WrapsPanic(t *testing.T) {
25
25
ctx := sync .Background ()
26
26
ctx = contextvalue .WithConverter (ctx , converter .DefaultConverter )
27
27
28
- wf := NewWorkflow (reflect .ValueOf (w ))
28
+ wf := newWorkflow (reflect .ValueOf (w ))
29
29
err := wf .Execute (ctx , nil )
30
30
require .NoError (t , err )
31
31
You can’t perform that action at this time.
0 commit comments