@@ -19,7 +19,7 @@ import (
1919 "github.com/cschleiden/go-workflows/backend/payload"
2020 "github.com/cschleiden/go-workflows/core"
2121 "github.com/cschleiden/go-workflows/internal/activity"
22- margs "github.com/cschleiden/go-workflows/internal/args"
22+ "github.com/cschleiden/go-workflows/internal/args"
2323 "github.com/cschleiden/go-workflows/internal/command"
2424 "github.com/cschleiden/go-workflows/internal/fn"
2525 "github.com/cschleiden/go-workflows/internal/log"
@@ -164,7 +164,7 @@ type workflowTester[TResult any] struct {
164164var _ WorkflowTester [any ] = (* workflowTester [any ])(nil )
165165
166166func NewWorkflowTester [TResult any ](workflow workflow.Workflow , opts ... WorkflowTesterOption ) * workflowTester [TResult ] {
167- if err := margs .ReturnTypeMatch [TResult ](workflow ); err != nil {
167+ if err := args .ReturnTypeMatch [TResult ](workflow ); err != nil {
168168 panic (fmt .Sprintf ("workflow return type does not match: %s" , err ))
169169 }
170170
@@ -578,7 +578,7 @@ func (wt *workflowTester[TResult]) scheduleActivity(wfi *core.WorkflowInstance,
578578 panic ("Could not find activity " + e .Name + " in registry" )
579579 }
580580
581- argValues , addContext , err := margs .InputsToArgs (wt .converter , reflect .ValueOf (afn ), e .Inputs )
581+ argValues , addContext , err := args .InputsToArgs (wt .converter , reflect .ValueOf (afn ), e .Inputs )
582582 if err != nil {
583583 panic ("Could not convert activity inputs to args: " + err .Error ())
584584 }
@@ -737,7 +737,7 @@ func (wt *workflowTester[TResult]) scheduleSubWorkflow(event history.WorkflowEve
737737 panic ("Could not find workflow " + a .Name + " in registry" )
738738 }
739739
740- argValues , addContext , err := margs .InputsToArgs (wt .converter , reflect .ValueOf (wfn ), a .Inputs )
740+ argValues , addContext , err := args .InputsToArgs (wt .converter , reflect .ValueOf (wfn ), a .Inputs )
741741 if err != nil {
742742 panic ("Could not convert workflow inputs to args: " + err .Error ())
743743 }
@@ -795,10 +795,10 @@ func (wt *workflowTester[TResult]) scheduleSubWorkflow(event history.WorkflowEve
795795 }
796796}
797797
798- func (wt * workflowTester [TResult ]) getInitialEvent (wf interface {}, args []interface {}) * history.Event {
798+ func (wt * workflowTester [TResult ]) getInitialEvent (wf interface {}, a []interface {}) * history.Event {
799799 name := fn .Name (wf )
800800
801- inputs , err := margs .ArgsToInputs (wt .converter , args ... )
801+ inputs , err := args .ArgsToInputs (wt .converter , a ... )
802802 if err != nil {
803803 panic (err )
804804 }
0 commit comments