Skip to content

Commit

Permalink
address comment
Browse files Browse the repository at this point in the history
  • Loading branch information
shreyassrivatsan committed May 3, 2019
1 parent cde9c84 commit 1626ace
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion internal/internal_workflow.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions internal/workflow.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 1626ace

Please sign in to comment.