Skip to content

Commit d64689c

Browse files
authored
Correctly pass logger to wf worker
1 parent c4e8fca commit d64689c

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

internal/worker/workflow.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@ import (
88

99
"github.com/benbjohnson/clock"
1010
"github.com/cschleiden/go-workflows/backend"
11-
"github.com/cschleiden/go-workflows/internal/logger"
1211
"github.com/cschleiden/go-workflows/internal/task"
1312
"github.com/cschleiden/go-workflows/internal/workflow"
1413
"github.com/pkg/errors"
@@ -171,7 +170,7 @@ func (ww *workflowWorker) getExecutor(ctx context.Context, t *task.Workflow) (wo
171170
return executor, nil
172171
}
173172

174-
executor, err := workflow.NewExecutor(logger.NewDefaultLogger(), ww.registry, t.WorkflowInstance, clock.New())
173+
executor, err := workflow.NewExecutor(ww.backend.Logger(), ww.registry, t.WorkflowInstance, clock.New())
175174
if err != nil {
176175
return nil, errors.Wrap(err, "could not create workflow executor")
177176
}

0 commit comments

Comments
 (0)