diff --git a/internal/internal_workflow.go b/internal/internal_workflow.go index e068d7255..e4ea4a6f4 100644 --- a/internal/internal_workflow.go +++ b/internal/internal_workflow.go @@ -395,7 +395,7 @@ func newWorkflowContext(env workflowEnvironment) Context { rootCtx = WithWorkflowTaskStartToCloseTimeout(rootCtx, time.Duration(wInfo.TaskStartToCloseTimeoutSeconds)*time.Second) rootCtx = WithTaskList(rootCtx, wInfo.TaskListName) rootCtx = WithDataConverter(rootCtx, env.GetDataConverter()) - rootCtx = WithContextPropagators(rootCtx, env.GetContextPropagators()) + rootCtx = withContextPropagators(rootCtx, env.GetContextPropagators()) getActivityOptions(rootCtx).OriginalTaskListName = wInfo.TaskListName return rootCtx diff --git a/internal/workflow.go b/internal/workflow.go index 90eb69efd..9a663640c 100644 --- a/internal/workflow.go +++ b/internal/workflow.go @@ -851,8 +851,8 @@ func WithDataConverter(ctx Context, dc encoded.DataConverter) Context { return ctx1 } -// WithContextPropagators adds ContextPropagators to the context. -func WithContextPropagators(ctx Context, contextPropagators []ContextPropagator) Context { +// withContextPropagators adds ContextPropagators to the context. +func withContextPropagators(ctx Context, contextPropagators []ContextPropagator) Context { ctx1 := setWorkflowEnvOptionsIfNotExist(ctx) getWorkflowEnvOptions(ctx1).contextPropagators = contextPropagators return ctx1