Skip to content

Commit 3ff13d4

Browse files
committed
Remove internal imports
1 parent 46d7fc8 commit 3ff13d4

File tree

3 files changed

+6
-7
lines changed

3 files changed

+6
-7
lines changed

workflow/activity.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import (
66
"github.com/cschleiden/go-workflows/backend/metadata"
77
a "github.com/cschleiden/go-workflows/internal/args"
88
"github.com/cschleiden/go-workflows/internal/command"
9-
icontextpropagation "github.com/cschleiden/go-workflows/internal/contextpropagation"
9+
"github.com/cschleiden/go-workflows/internal/contextpropagation"
1010
"github.com/cschleiden/go-workflows/internal/converter"
1111
"github.com/cschleiden/go-workflows/internal/fn"
1212
"github.com/cschleiden/go-workflows/internal/log"
@@ -65,9 +65,9 @@ func executeActivity[TResult any](ctx Context, options ActivityOptions, attempt
6565
name := fn.Name(activity)
6666

6767
// Capture context
68-
propagators := icontextpropagation.Propagators(ctx)
68+
propagators := contextpropagation.Propagators(ctx)
6969
metadata := &metadata.WorkflowMetadata{}
70-
if err := icontextpropagation.InjectFromWorkflow(ctx, metadata, propagators); err != nil {
70+
if err := contextpropagation.InjectFromWorkflow(ctx, metadata, propagators); err != nil {
7171
f.Set(*new(TResult), fmt.Errorf("injecting workflow context: %w", err))
7272
return f
7373
}

workflow/replaying.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,10 @@
11
package workflow
22

33
import (
4-
"github.com/cschleiden/go-workflows/internal/sync"
54
"github.com/cschleiden/go-workflows/internal/workflowstate"
65
)
76

8-
func Replaying(ctx sync.Context) bool {
7+
func Replaying(ctx Context) bool {
98
wfState := workflowstate.WorkflowState(ctx)
109
return wfState.Replaying()
1110
}

workflow/subworkflow.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ import (
77
a "github.com/cschleiden/go-workflows/internal/args"
88
"github.com/cschleiden/go-workflows/internal/command"
99
"github.com/cschleiden/go-workflows/internal/contextpropagation"
10-
iconverter "github.com/cschleiden/go-workflows/internal/converter"
10+
"github.com/cschleiden/go-workflows/internal/converter"
1111
"github.com/cschleiden/go-workflows/internal/fn"
1212
"github.com/cschleiden/go-workflows/internal/log"
1313
"github.com/cschleiden/go-workflows/internal/sync"
@@ -63,7 +63,7 @@ func createSubWorkflowInstance[TResult any](ctx Context, options SubWorkflowOpti
6363

6464
name := fn.Name(wf)
6565

66-
cv := iconverter.Converter(ctx)
66+
cv := converter.Converter(ctx)
6767
inputs, err := a.ArgsToInputs(cv, args...)
6868
if err != nil {
6969
f.Set(*new(TResult), fmt.Errorf("converting subworkflow input: %w", err))

0 commit comments

Comments
 (0)